Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for elseif (0.22 sec)

  1. internal/s3select/json/reader.go

    		}
    		return nil, io.EOF
    	}
    
    	var kvs jstream.KVS
    	if v.ValueType == jstream.Object {
    		// This is a JSON object type (that preserves key
    		// order)
    		kvs = v.Value.(jstream.KVS)
    	} else {
    		// To be AWS S3 compatible Select for JSON needs to
    		// output non-object JSON as single column value
    		// i.e. a map with `_1` as key and value as the
    		// non-object.
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Mar 24 03:58:53 GMT 2022
    - 3K bytes
    - Viewed (0)
  2. internal/s3select/parquet/reader.go

    					}
    					value = sql.FormatSQLTimestamp(time.Unix(0, 0).Add(duration))
    				}
    			} else if se.GetConvertedType() == parquettypes.ConvertedType_TIMESTAMP_MILLIS {
    				duration := time.Duration(val) * time.Millisecond
    				value = sql.FormatSQLTimestamp(time.Unix(0, 0).Add(duration))
    			} else if se.GetConvertedType() == parquettypes.ConvertedType_TIMESTAMP_MICROS {
    				duration := time.Duration(val) * time.Microsecond
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 14 13:54:47 GMT 2022
    - 4.5K bytes
    - Viewed (0)
  3. src/archive/tar/reader.go

    				hdr.Linkname = gnuLongLink
    			}
    			if hdr.Typeflag == TypeRegA {
    				if strings.HasSuffix(hdr.Name, "/") {
    					hdr.Typeflag = TypeDir // Legacy archives use trailing slash for directories
    				} else {
    					hdr.Typeflag = TypeReg
    				}
    			}
    
    			// The extended headers may have updated the size.
    			// Thus, setup the regFileReader again after merging PAX headers.
    Go
    - Registered: Tue Apr 23 11:13:09 GMT 2024
    - Last Modified: Fri Mar 08 01:59:14 GMT 2024
    - 26.8K bytes
    - Viewed (0)
  4. internal/bucket/bandwidth/reader.go

    			need = int(math.Min(float64(b-hdr), float64(need))) // use remaining tokens towards payload
    			tokens = need + hdr
    
    		} else { // part of header can be accommodated
    			r.opts.HeaderSize -= b - 1
    			need = 1 // to ensure we read at least one byte for every Read
    			tokens = b
    		}
    	} else { // all tokens go towards payload
    		need = int(math.Min(float64(b), float64(need)))
    		tokens = need
    	}
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Wed Sep 06 03:21:59 GMT 2023
    - 3.1K bytes
    - Viewed (0)
  5. src/archive/zip/reader.go

    		}
    		if r.desr != nil {
    			if err1 := readDataDescriptor(r.desr, r.f); err1 != nil {
    				if err1 == io.EOF {
    					err = io.ErrUnexpectedEOF
    				} else {
    					err = err1
    				}
    			} else if r.hash.Sum32() != r.f.CRC32 {
    				err = ErrChecksum
    			}
    		} else {
    			// If there's not a data descriptor, we still compare
    			// the CRC32 of what we've read against the file header
    Go
    - Registered: Tue Apr 23 11:13:09 GMT 2024
    - Last Modified: Fri Oct 13 18:36:46 GMT 2023
    - 27.7K bytes
    - Viewed (0)
  6. internal/hash/reader.go

    	if size >= 0 {
    		r := ioutil.HardLimitReader(src, size)
    		if !disableMD5 {
    			if _, ok := src.(etag.Tagger); !ok {
    				src = etag.NewReader(ctx, r, MD5, forceMD5)
    			} else {
    				src = etag.Wrap(r, src)
    			}
    		} else {
    			src = r
    		}
    	} else if _, ok := src.(etag.Tagger); !ok {
    		if !disableMD5 {
    			src = etag.NewReader(ctx, src, MD5, forceMD5)
    		}
    	}
    	var h hash.Hash
    	if len(SHA256) != 0 {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Mon Sep 18 17:00:54 GMT 2023
    - 10.8K bytes
    - Viewed (0)
Back to top