Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for WriteJSON (0.14 sec)

  1. internal/s3select/simdj/reader_amd64_test.go

    				}
    				gotB.Reset()
    				wantB.Reset()
    
    				err = rec.WriteJSON(&gotB)
    				if err != nil {
    					t.Error(err)
    				}
    				err = want.WriteJSON(&wantB)
    				if err != nil {
    					t.Error(err)
    				}
    				// truncate newline from 'want'
    				wantB.Truncate(wantB.Len() - 1)
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 3.9K bytes
    - Viewed (0)
  2. internal/s3select/csv/record.go

    	w.Quote = opts.Quote
    	w.QuoteEscape = opts.QuoteEscape
    	if err := w.Write(r.csvRecord); err != nil {
    		return err
    	}
    	w.Flush()
    	return w.Error()
    }
    
    // WriteJSON - encodes to JSON data.
    func (r *Record) WriteJSON(writer io.Writer) error {
    	var kvs jstream.KVS = make([]jstream.KV, 0, len(r.columnNames))
    	for i, cn := range r.columnNames {
    		if i < len(r.csvRecord) {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 4.1K bytes
    - Viewed (0)
  3. internal/s3select/json/record.go

    	w.Flush()
    	return w.Error()
    }
    
    // Raw - returns the underlying representation.
    func (r *Record) Raw() (sql.SelectObjectFormat, any) {
    	return r.SelectFormat, r.KVS
    }
    
    // WriteJSON - encodes to JSON data.
    func (r *Record) WriteJSON(writer io.Writer) error {
    	return json.NewEncoder(writer).Encode(r.KVS)
    }
    
    // Replace the underlying buffer of json data.
    func (r *Record) Replace(k any) error {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 5.2K bytes
    - Viewed (0)
  4. internal/s3select/simdj/record.go

    	return w.Error()
    }
    
    // Raw - returns the underlying representation.
    func (r *Record) Raw() (sql.SelectObjectFormat, any) {
    	return sql.SelectFmtSIMDJSON, r.object
    }
    
    // WriteJSON - encodes to JSON data.
    func (r *Record) WriteJSON(writer io.Writer) error {
    	o := r.object
    	elems, err := o.Parse(nil)
    	if err != nil {
    		return err
    	}
    	b, err := elems.MarshalJSON()
    	if err != nil {
    		return err
    	}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 5.4K bytes
    - Viewed (0)
  5. internal/s3select/sql/record.go

    type Record interface {
    	Get(name string) (*Value, error)
    
    	// Set a value.
    	// Can return a different record type.
    	Set(name string, value *Value) (Record, error)
    	WriteCSV(writer io.Writer, opts WriteCSVOpts) error
    	WriteJSON(writer io.Writer) error
    
    	// Clone the record and if possible use the destination provided.
    	Clone(dst Record) Record
    	Reset()
    
    	// Returns underlying representation
    	Raw() (SelectObjectFormat, any)
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 3.4K bytes
    - Viewed (0)
Back to top