Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 19 18:05:16 UTC 2022
    - 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 4.1K bytes
    - Viewed (0)
  3. internal/s3select/json/record.go

    	return w.Error()
    }
    
    // Raw - returns the underlying representation.
    func (r *Record) Raw() (sql.SelectObjectFormat, interface{}) {
    	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 interface{}) error {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 5.3K bytes
    - Viewed (0)
  4. internal/s3select/simdj/record.go

    }
    
    // Raw - returns the underlying representation.
    func (r *Record) Raw() (sql.SelectObjectFormat, interface{}) {
    	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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 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, interface{})
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 01 21:59:40 UTC 2021
    - 3.4K bytes
    - Viewed (0)
  6. internal/s3select/select.go

    			return err
    		}
    		if buf.Bytes()[buf.Len()-1] == '\n' {
    			buf.Truncate(buf.Len() - 1)
    		}
    		buf.WriteString(s3Select.Output.CSVArgs.RecordDelimiter)
    
    		return nil
    	case jsonFormat:
    		err := record.WriteJSON(buf)
    		if err != nil {
    			return err
    		}
    		// Trim trailing newline from non-simd output
    		if buf.Bytes()[buf.Len()-1] == '\n' {
    			buf.Truncate(buf.Len() - 1)
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 22 00:33:43 UTC 2024
    - 21.2K bytes
    - Viewed (0)
Back to top