Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for FieldDelimiter (0.06 sec)

  1. internal/s3select/csv/args.go

    type ReaderArgs struct {
    	FileHeaderInfo             string `xml:"FileHeaderInfo"`
    	RecordDelimiter            string `xml:"RecordDelimiter"`
    	FieldDelimiter             string `xml:"FieldDelimiter"`
    	QuoteCharacter             string `xml:"QuoteCharacter"`
    	QuoteEscapeCharacter       string `xml:"QuoteEscapeCharacter"`
    	CommentCharacter           string `xml:"Comments"`
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Aug 20 18:31:45 UTC 2024
    - 5.7K bytes
    - Viewed (0)
  2. internal/s3select/simdj/reader_amd64_test.go

    				if err != nil {
    					t.Error(err)
    				}
    				want, err := refDec.Read(nil)
    				if err != nil {
    					t.Error(err)
    				}
    				var gotB, wantB bytes.Buffer
    				opts := sql.WriteCSVOpts{
    					FieldDelimiter: ',',
    					Quote:          '"',
    					QuoteEscape:    '"',
    					AlwaysQuote:    false,
    				}
    				err = rec.WriteCSV(&gotB, opts)
    				if err != nil {
    					t.Error(err)
    				}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 3.9K bytes
    - Viewed (0)
  3. internal/s3select/sql/record.go

    	// SelectFmtSIMDJSON - SIMD JSON format
    	SelectFmtSIMDJSON
    	// SelectFmtParquet - Parquet format
    	SelectFmtParquet
    )
    
    // WriteCSVOpts - encapsulates options for Select CSV output
    type WriteCSVOpts struct {
    	FieldDelimiter rune
    	Quote          rune
    	QuoteEscape    rune
    	AlwaysQuote    bool
    }
    
    // Record - is a type containing columns and their values.
    type Record interface {
    	Get(name string) (*Value, error)
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 3.4K bytes
    - Viewed (0)
  4. internal/s3select/json/record.go

    			columnValue = string(b)
    		default:
    			return fmt.Errorf("Cannot marshal unhandled type: %T", kv.Value)
    		}
    		csvRecord = append(csvRecord, columnValue)
    	}
    
    	w := csv.NewWriter(writer)
    	w.Comma = opts.FieldDelimiter
    	w.Quote = opts.Quote
    	w.AlwaysQuote = opts.AlwaysQuote
    	w.QuoteEscape = opts.QuoteEscape
    	if err := w.Write(csvRecord); err != nil {
    		return err
    	}
    	w.Flush()
    	return w.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)
  5. internal/s3select/simdj/record.go

    			break allElems
    		default:
    			return fmt.Errorf("cannot marshal unhandled type: %s", typ.String())
    		}
    		csvRecord = append(csvRecord, columnValue)
    	}
    	w := csv.NewWriter(writer)
    	w.Comma = opts.FieldDelimiter
    	w.Quote = opts.Quote
    	w.QuoteEscape = opts.QuoteEscape
    	w.AlwaysQuote = opts.AlwaysQuote
    	if err := w.Write(csvRecord); err != nil {
    		return err
    	}
    	w.Flush()
    	return w.Error()
    }
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 5.4K bytes
    - Viewed (0)
  6. internal/s3select/csv/record.go

    	return other
    }
    
    // WriteCSV - encodes to CSV data.
    func (r *Record) WriteCSV(writer io.Writer, opts sql.WriteCSVOpts) error {
    	w := csv.NewWriter(writer)
    	w.Comma = opts.FieldDelimiter
    	w.AlwaysQuote = opts.AlwaysQuote
    	w.Quote = opts.Quote
    	w.QuoteEscape = opts.QuoteEscape
    	if err := w.Write(r.csvRecord); err != nil {
    		return err
    	}
    	w.Flush()
    	return w.Error()
    }
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 4.1K bytes
    - Viewed (0)
  7. internal/s3select/csv/reader.go

    		close:      make(chan struct{}),
    	}
    
    	// Assume args are validated by ReaderArgs.UnmarshalXML()
    	newCsvReader := func(r io.Reader) *csv.Reader {
    		ret := csv.NewReader(r)
    		ret.Comma = []rune(args.FieldDelimiter)[0]
    		ret.Comment = []rune(args.CommentCharacter)[0]
    		ret.Quote = []rune{}
    		if len([]rune(args.QuoteCharacter)) > 0 {
    			// Add the first rune of args.QuoteCharacter
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue May 27 15:19:03 UTC 2025
    - 8.8K bytes
    - Viewed (0)
Back to top