Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for checkID (0.18 sec)

  1. internal/s3select/parquet/reader.go

    	if se == nil {
    		return v, nil
    	}
    
    	var value interface{}
    	switch val := v.(type) {
    	case []byte:
    		// TODO: only strings are supported in s3select output (not
    		// binary arrays) - perhaps we need to check the annotation to
    		// ensure it's UTF8 encoded.
    		value = string(val)
    	case [12]byte:
    		// TODO: This is returned for the parquet INT96 type. We just
    		// treat it same as []byte (but AWS S3 treats it as a large int)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 14 13:54:47 GMT 2022
    - 4.5K bytes
    - Viewed (0)
  2. internal/hash/reader.go

    }
    
    // SetExpectedMax set expected max data expected from reader
    func (r *Reader) SetExpectedMax(expectedMax int64) {
    	r.expectedMax = expectedMax
    }
    
    // AddChecksum will add checksum checks as specified in
    // https://docs.aws.amazon.com/AmazonS3/latest/userguide/checking-object-integrity.html
    // Returns ErrInvalidChecksum if a problem with the checksum is found.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Sep 18 17:00:54 GMT 2023
    - 10.8K bytes
    - Viewed (0)
  3. internal/s3select/csv/reader.go

    		}
    	}
    
    	r.bufferPool.New = func() interface{} {
    		return make([]byte, csvSplitSize+1024)
    	}
    
    	// Return first block
    	next, nextErr := r.nextSplit(csvSplitSize, r.bufferPool.Get().([]byte))
    	// Check if first block is valid.
    	if !utf8.Valid(next) {
    		return errInvalidTextEncodingError()
    	}
    
    	// Create queue
    	r.queue = make(chan *queueItem, runtime.GOMAXPROCS(0))
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 8.9K bytes
    - Viewed (0)
  4. src/archive/tar/reader.go

    		nb = 0
    	}
    	if nb < 0 {
    		return ErrHeader
    	}
    
    	tr.pad = blockPadding(nb)
    	tr.curr = &regFileReader{r: tr.r, nb: nb}
    	return nil
    }
    
    // handleSparseFile checks if the current file is a sparse format of any type
    // and sets the curr reader appropriately.
    func (tr *Reader) handleSparseFile(hdr *Header, rawHdr *block) error {
    	var spd sparseDatas
    	var err error
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Fri Mar 08 01:59:14 GMT 2024
    - 26.8K bytes
    - Viewed (0)
  5. internal/etag/reader.go

    )
    
    // Tagger is the interface that wraps the basic ETag method.
    type Tagger interface {
    	ETag() ETag
    }
    
    type wrapReader struct {
    	io.Reader
    	Tagger
    }
    
    var _ Tagger = wrapReader{} // compiler check
    
    // ETag returns the ETag of the underlying Tagger.
    func (r wrapReader) ETag() ETag {
    	if r.Tagger == nil {
    		return nil
    	}
    	return r.Tagger.ETag()
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 4.8K bytes
    - Viewed (0)
Back to top