Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for FieldDelimiter (0.17 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 20 18:31:45 UTC 2024
    - 5.7K bytes
    - Viewed (0)
  2. internal/s3select/csv/reader_contrib_test.go

    		r, _ := NewReader(io.NopCloser(strings.NewReader(c.content)), &ReaderArgs{
    			FileHeaderInfo:             none,
    			RecordDelimiter:            c.recordDelimiter,
    			FieldDelimiter:             c.fieldDelimiter,
    			QuoteCharacter:             defaultQuoteCharacter,
    			QuoteEscapeCharacter:       defaultQuoteEscapeCharacter,
    			CommentCharacter:           defaultCommentCharacter,
    			AllowQuotedRecordDelimiter: false,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 19 18:05:16 UTC 2022
    - 38.5K 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 01 21:59:40 UTC 2021
    - 3.4K bytes
    - Viewed (0)
  4. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 19 18:05:16 UTC 2022
    - 3.9K bytes
    - Viewed (0)
  5. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 5.3K bytes
    - Viewed (0)
  6. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 5.4K bytes
    - Viewed (0)
  7. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 4.1K bytes
    - Viewed (0)
  8. internal/s3select/select.go

    		defer func() {
    			bufioWriter.Reset(xioutil.Discard)
    			bufioWriterPool.Put(bufioWriter)
    		}()
    
    		bufioWriter.Reset(buf)
    		opts := sql.WriteCSVOpts{
    			FieldDelimiter: []rune(s3Select.Output.CSVArgs.FieldDelimiter)[0],
    			Quote:          []rune(s3Select.Output.CSVArgs.QuoteCharacter)[0],
    			QuoteEscape:    []rune(s3Select.Output.CSVArgs.QuoteEscapeCharacter)[0],
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 22 00:33:43 UTC 2024
    - 21.2K bytes
    - Viewed (0)
  9. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Feb 22 06:26:06 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  10. internal/s3select/select_test.go

    <SelectObjectContentRequest>
        <Expression>%s</Expression>
        <ExpressionType>SQL</ExpressionType>
        <InputSerialization>
            <CompressionType>NONE</CompressionType>
            <CSV>
            	<FieldDelimiter>,</FieldDelimiter>
            	<FileHeaderInfo>USE</FileHeaderInfo>
            	<QuoteCharacter>"</QuoteCharacter>
            	<QuoteEscapeCharacter>"</QuoteEscapeCharacter>
            	<RecordDelimiter>\n</RecordDelimiter>
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Dec 23 07:19:11 UTC 2023
    - 76.2K bytes
    - Viewed (0)
Back to top