Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for WriteJSON (0.08 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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