File tree Expand file tree Collapse file tree 1 file changed +3
-1
lines changed
src/query/pipeline/sources/src/processors/sources/input_formats/impls Expand file tree Collapse file tree 1 file changed +3
-1
lines changed Original file line number Diff line number Diff line change @@ -37,6 +37,7 @@ pub struct InputFormatTSV {}
37
37
impl InputFormatTSV {
38
38
#[ allow( clippy:: too_many_arguments) ]
39
39
fn read_row (
40
+ field_delimiter : u8 ,
40
41
field_decoder : & FieldDecoderTSV ,
41
42
buf : & [ u8 ] ,
42
43
deserializers : & mut Vec < common_datavalues:: TypeDeserializerImpl > ,
@@ -53,7 +54,7 @@ impl InputFormatTSV {
53
54
let mut err_msg = None ;
54
55
let buf_len = buf. len ( ) ;
55
56
while pos <= buf_len {
56
- if pos == buf_len || buf[ pos] == b'\t' {
57
+ if pos == buf_len || buf[ pos] == field_delimiter {
57
58
let col_data = & buf[ field_start..pos] ;
58
59
if col_data. is_empty ( ) {
59
60
deserializers[ column_index] . de_default ( ) ;
@@ -156,6 +157,7 @@ impl InputFormatTextBase for InputFormatTSV {
156
157
for ( i, end) in batch. row_ends . iter ( ) . enumerate ( ) {
157
158
let buf = & batch. data [ start..* end] ; // include \n
158
159
Self :: read_row (
160
+ builder. ctx . field_delimiter ,
159
161
field_decoder,
160
162
buf,
161
163
columns,
You can’t perform that action at this time.
0 commit comments