- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for ObjectAsKVS (0.25 sec)
-
internal/s3select/sql/jsonpath_test.go
"reflect" "testing" "github.com/alecthomas/participle" "github.com/bcicen/jstream" ) func getJSONStructs(b []byte) ([]interface{}, error) { dec := jstream.NewDecoder(bytes.NewBuffer(b), 0).ObjectAsKVS() var result []interface{} for parsedVal := range dec.Stream() { result = append(result, parsedVal.Value) } if err := dec.Err(); err != nil { return nil, err } return result, nil }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Sep 19 18:05:16 UTC 2022 - 2.8K bytes - Viewed (0) -
internal/s3select/json/reader.go
} // NewReader - creates new JSON reader using readCloser. func NewReader(readCloser io.ReadCloser, args *ReaderArgs) *Reader { readCloser = &syncReadCloser{rc: readCloser} d := jstream.NewDecoder(readCloser, 0).ObjectAsKVS() return &Reader{ args: args, decoder: d, valueCh: d.Stream(), readCloser: readCloser, } } // syncReadCloser will wrap a readcloser and make it safe to call Close while
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Mar 24 03:58:53 UTC 2022 - 3K bytes - Viewed (0) -
internal/s3select/json/preader.go
continue } dst, ok := r.kvDstPool.Get().([]jstream.KVS) if !ok { dst = make([]jstream.KVS, 0, 1000) } d := jstream.NewDecoder(bytes.NewBuffer(in.input), 0).ObjectAsKVS() stream := d.Stream() all := dst[:0] for mv := range stream { var kvs jstream.KVS if mv.ValueType == jstream.Object { // This is a JSON object type (that preserves key
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sun Mar 05 04:57:35 UTC 2023 - 6.4K bytes - Viewed (0) -
cmd/postpolicyform.go
// keys, so we need to use this technique to merge the // keys. func sanitizePolicy(r io.Reader) (io.Reader, error) { var buf bytes.Buffer e := json.NewEncoder(&buf) d := jstream.NewDecoder(r, 0).ObjectAsKVS() sset := set.NewStringSet() for mv := range d.Stream() { var kvs jstream.KVS if mv.ValueType == jstream.Object { // This is a JSON object type (that preserves key order) kvs = mv.Value.(jstream.KVS)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon May 06 10:52:41 UTC 2024 - 12.3K bytes - Viewed (0)