- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 152 for column (0.21 sec)
-
internal/s3select/parquet/reader.go
if !ok { dstRec = &jsonfmt.Record{} } dstRec.SelectFormat = sql.SelectFmtParquet dstRec.KVS = kvs return dstRec, nil } // convertFromAnnotation - converts values based on the Parquet column's type // annotations. LogicalType annotations if present override the deprecated // ConvertedType annotations. Ref: // https://github.com/apache/parquet-format/blob/master/LogicalTypes.md
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/csv/record.go
if err != nil { return nil, fmt.Errorf("column %v not found", name) } // The position count starts at 1. idx-- if idx >= len(r.csvRecord) || idx < 0 { // If field index > number of columns, return null return sql.FromNull(), nil } return sql.FromBytes([]byte(r.csvRecord[idx])), nil } // TODO: Return Missing? return nil, fmt.Errorf("column %v not found", name) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Sep 13 00:00:59 GMT 2022 - 4.1K bytes - Viewed (0) -
internal/s3select/csv/reader.go
r.err = errCSVParsingError(err) return errCSVParsingError(err) } return err } if r.args.FileHeaderInfo == use { // Copy column names since records will be reused. columns := append(make([]string, 0, len(record)), record...) r.columnNames = columns } } r.bufferPool.New = func() interface{} { return make([]byte, csvSplitSize+1024) } // Return first block
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/s3select/select_test.go
wantResult string }{ { name: "Select a column containing dot", query: `select "na.me" from S3Object s`, wantResult: `apple mango`, }, { name: "Select column containing dot with table name prefix", query: `select count(S3Object."na.me") from S3Object`, wantResult: `2`, }, { name: "Select column containing dot with table alias prefix",
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Dec 23 07:19:11 GMT 2023 - 76.2K bytes - Viewed (0) -
cmd/batch-expire.go
type purge BatchJobExpirePurge var tmp purge err := val.Decode(&tmp) if err != nil { return err } *p = BatchJobExpirePurge(tmp) p.line, p.col = val.Line, val.Column return nil } // Validate returns nil if value is valid, ie > 0. func (p BatchJobExpirePurge) Validate() error { if p.RetainVersions < 0 { return BatchJobYamlErr{ line: p.line, col: p.col,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 21K bytes - Viewed (1) -
cmd/api-errors.go
HTTPStatusCode: http.StatusBadRequest, }, ErrEvaluatorBindingDoesNotExist: { Code: "ErrEvaluatorBindingDoesNotExist", Description: "A column name or a path provided does not exist in the SQL expression", HTTPStatusCode: http.StatusBadRequest, }, ErrMissingHeaders: { Code: "MissingHeaders",
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 91.4K bytes - Viewed (7) -
cmd/signature-v4-utils.go
defaultSha256Cksum = emptySHA256 v, ok = r.Header[xhttp.AmzContentSha256] } // We found 'X-Amz-Content-Sha256' return the captured value. if ok { return v[0] } // We couldn't find 'X-Amz-Content-Sha256'. return defaultSha256Cksum } // isValidRegion - verify if incoming region value is valid with configured Region. func isValidRegion(reqRegion string, confRegion string) bool {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Jan 31 18:56:45 GMT 2024 - 9K bytes - Viewed (0) -
cmd/batch-job-common-types.go
// UnmarshalYAML - BatchJobNotification extends unmarshal to extract line, column information func (b *BatchJobNotification) UnmarshalYAML(val *yaml.Node) error { type notification BatchJobNotification var tmp notification err := val.Decode(&tmp) if err != nil { return err } *b = BatchJobNotification(tmp) b.line, b.col = val.Line, val.Column return nil }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 01 21:53:26 GMT 2024 - 7.9K bytes - Viewed (0) -
cmd/erasure-object.go
// healed upon regular heal process. if missingBlocks > 0 && missingBlocks < fi.Erasure.DataBlocks { globalMRFState.addPartialOp(partialOperation{ bucket: fi.Volume, object: fi.Name, versionID: fi.VersionID, queued: time.Now(), setIndex: er.setIndex, poolIndex: er.poolIndex, }) } return }() validResp := 0
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 77.2K bytes - Viewed (2) -
internal/s3select/json/record.go
return b, nil } // Record - is JSON record. type Record struct { // Used in Set(), Marshal*() KVS jstream.KVS SelectFormat sql.SelectObjectFormat } // Get - gets the value for a column name. func (r *Record) Get(name string) (*sql.Value, error) { // Get is implemented directly in the sql package. return nil, errors.New("not implemented here") } // Reset the record. func (r *Record) Reset() {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Feb 25 20:31:19 GMT 2022 - 5.2K bytes - Viewed (0)