File tree Expand file tree Collapse file tree 1 file changed +5
-5
lines changed Expand file tree Collapse file tree 1 file changed +5
-5
lines changed Original file line number Diff line number Diff line change @@ -17,11 +17,11 @@ type parquetStreamingRows struct {
1717 stream chdbpurego.ChdbStreamResult // result from clickhouse
1818 curChunk chdbpurego.ChdbResult // current chunk
1919 reader * parquet.GenericReader [any ] // parquet reader
20- curRecord parquet.Row // TODO: delete this?
21- buffer []parquet.Row // record buffer
22- bufferSize int // amount of records to preload into buffer
23- bufferIndex int64 // index in the current buffer
24- curRow int64 // row counter
20+ curRecord parquet.Row
21+ buffer []parquet.Row // record buffer
22+ bufferSize int // amount of records to preload into buffer
23+ bufferIndex int64 // index in the current buffer
24+ curRow int64 // row counter
2525 needNewBuffer bool
2626 useUnsafeStringReader bool
2727}
You can’t perform that action at this time.
0 commit comments