Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for NewRecord (0.16 sec)

  1. internal/s3select/json/record.go

    	v, ok := k.(jstream.KVS)
    	if !ok {
    		return fmt.Errorf("cannot replace internal data in json record with type %T", k)
    	}
    	r.KVS = v
    	return nil
    }
    
    // NewRecord - creates new empty JSON record.
    func NewRecord(f sql.SelectObjectFormat) *Record {
    	return &Record{
    		KVS:          jstream.KVS{},
    		SelectFormat: f,
    	}
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 5.3K bytes
    - Viewed (0)
  2. internal/s3select/simdj/record.go

    	v, ok := k.(simdjson.Object)
    	if !ok {
    		return fmt.Errorf("cannot replace internal data in simd json record with type %T", k)
    	}
    	r.object = v
    	return nil
    }
    
    // NewRecord - creates new empty JSON record.
    func NewRecord(f sql.SelectObjectFormat, obj simdjson.Object) *Record {
    	return &Record{
    		object: obj,
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 5.4K bytes
    - Viewed (0)
  3. internal/s3select/csv/record.go

    	return sql.SelectFmtCSV, r
    }
    
    // Replace - is not supported for CSV
    func (r *Record) Replace(_ interface{}) error {
    	return errors.New("Replace is not supported for CSV")
    }
    
    // NewRecord - creates new CSV record.
    func NewRecord() *Record {
    	return &Record{}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 4.1K bytes
    - Viewed (0)
  4. internal/s3select/select.go

    	*s3Select = S3Select(parsedS3Select)
    	return nil
    }
    
    func (s3Select *S3Select) outputRecord() sql.Record {
    	switch s3Select.Output.format {
    	case csvFormat:
    		return csv.NewRecord()
    	case jsonFormat:
    		return json.NewRecord(sql.SelectFmtJSON)
    	}
    
    	panic(fmt.Errorf("unknown output format '%v'", s3Select.Output.format))
    }
    
    func (s3Select *S3Select) getProgress() (bytesScanned, bytesProcessed int64) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 22 00:33:43 UTC 2024
    - 21.2K bytes
    - Viewed (0)
  5. api/go1.21.txt

    pkg log/slog, func New(Handler) *Logger #56345
    pkg log/slog, func NewJSONHandler(io.Writer, *HandlerOptions) *JSONHandler #59339
    pkg log/slog, func NewLogLogger(Handler, Level) *log.Logger #56345
    pkg log/slog, func NewRecord(time.Time, Level, string, uintptr) Record #56345
    pkg log/slog, func NewTextHandler(io.Writer, *HandlerOptions) *TextHandler #59339
    pkg log/slog, func SetDefault(*Logger) #56345
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Aug 07 09:39:17 UTC 2023
    - 25.6K bytes
    - Viewed (0)
Back to top