- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for type (0.15 sec)
-
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) -
internal/s3select/json/reader.go
package json import ( "io" "sync" "github.com/minio/minio/internal/s3select/sql" "github.com/bcicen/jstream" ) // Reader - JSON record reader for S3Select. type Reader struct { args *ReaderArgs decoder *jstream.Decoder valueCh chan *jstream.MetaValue readCloser io.ReadCloser } // Read - reads single record.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 24 03:58:53 GMT 2022 - 3K bytes - Viewed (0) -
internal/hash/reader.go
// ContentCRCType returns the content checksum type. func (r *Reader) ContentCRCType() ChecksumType { return r.contentHash.Type } // ContentCRC returns the content crc if set. func (r *Reader) ContentCRC() map[string]string { if r.contentHash.Type == ChecksumNone || !r.contentHash.Valid() { return nil } if r.contentHash.Type.Trailing() {
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) -
internal/bucket/bandwidth/reader.go
type MonitoredReader struct { r io.Reader throttle *bucketThrottle ctx context.Context // request context lastErr error // last error reported, if this non-nil all reads will fail. m *Monitor opts *MonitorReaderOptions } // BucketOptions represents the bucket and optionally its replication target pair. type BucketOptions struct { Name string
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Sep 06 03:21:59 GMT 2023 - 3.1K bytes - Viewed (0) -
internal/s3select/csv/reader.go
"bufio" "bytes" "fmt" "io" "runtime" "sync" "unicode/utf8" csv "github.com/minio/csvparser" "github.com/minio/minio/internal/s3select/sql" ) // Reader - CSV record reader for S3Select. type Reader struct { args *ReaderArgs readCloser io.ReadCloser // raw input buf *bufio.Reader // input to the splitter columnNames []string // names of columns
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) -
internal/etag/reader.go
package etag import ( "context" "crypto/md5" "fmt" "hash" "io" ) // 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 {
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) -
internal/s3select/simdj/reader.go
for { var next simdjson.Iter typ, err := i.AdvanceIter(&next) if err != nil { r.err = &err return } switch typ { case simdjson.TypeNone: break readloop case simdjson.TypeRoot: typ, obj, err := next.Root(nil) if err != nil { r.err = &err return } if typ != simdjson.TypeObject { if typ == simdjson.TypeNone { continue }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue May 30 17:02:22 GMT 2023 - 4.9K bytes - Viewed (0)