- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for Rec (0.12 sec)
-
internal/s3select/parquet/reader.go
fr, err := parquetgo.NewFileReader(rsc) if err != nil { return nil, errParquetParsingError(err) } return &Reader{Closer: rsc, r: fr}, nil } func (pr *Reader) Read(dst sql.Record) (rec sql.Record, rerr error) { nextRow, err := pr.r.NextRow() if err != nil { if err == io.EOF { return nil, err } return nil, errParquetParsingError(err) } kvs := jstream.KVS{}
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/sql/jsonpath_test.go
recs, err := getJSONStructs(b) if err != nil || len(recs) != 3 { t.Fatalf("%v or length was not 3", err) } for j, rec := range recs { // fmt.Println(rec) r, _, err := jsonpathEval(jp.PathExpr, rec) if err != nil { t.Errorf("Error: %d %d %v", i, j, err) } if !reflect.DeepEqual(r, tc.res[j]) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 19 18:05:16 GMT 2022 - 2.8K bytes - Viewed (0) -
internal/s3select/simdj/reader_amd64_test.go
dst <- *o default: t.Fatal("unexpected type:", typ.String()) } } refDec := json.NewReader(io.NopCloser(bytes.NewBuffer(ref)), &json.ReaderArgs{ContentType: "json"}) for { rec, err := dec.Read(nil) if err == io.EOF { break } if err != nil { t.Error(err) } want, err := refDec.Read(nil) if err != nil { t.Error(err) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 19 18:05:16 GMT 2022 - 3.9K bytes - Viewed (0) -
internal/s3select/sql/statement.go
} _, rawVal := input.Raw() if format != "json" { return nil, errDataSource(errors.New("path not supported")) } switch rec := rawVal.(type) { case jstream.KVS: txedRec, _, err := jsonpathEval(e.selectAST.From.Table.PathExpr[1:], rec) if err != nil { return nil, err } var kvs jstream.KVS switch v := txedRec.(type) { case jstream.KVS: kvs = v
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jan 09 17:19:11 GMT 2024 - 8.9K bytes - Viewed (0) -
cmd/metacache.go
id string `msg:"id"` error string `msg:"err"` root string `msg:"root"` fileNotFound bool `msg:"fnf"` status scanStatus `msg:"stat"` recursive bool `msg:"rec"` dataVersion uint8 `msg:"v"` } func (m *metacache) finished() bool { return !m.ended.IsZero() } // worthKeeping indicates if the cache by itself is worth keeping.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 5K bytes - Viewed (0)