Skip to content

reader: implement parallel CSV reading

Codecov / codecov/patch succeeded Sep 28, 2023 in 1s

84.37% of diff hit (target 80.00%)

View this Pull Request on Codecov

84.37% of diff hit (target 80.00%)

Annotations

Check warning on line 73 in src/binder/bind/bind_file_scan.cpp

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/binder/bind/bind_file_scan.cpp#L72-L73 

Added lines #L72 - L73 were not covered by tests

Check warning on line 122 in src/binder/bind/bind_file_scan.cpp

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/binder/bind/bind_file_scan.cpp#L122 

Added line #L122 was not covered by tests

Check warning on line 130 in src/binder/bind/bind_file_scan.cpp

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/binder/bind/bind_file_scan.cpp#L130 

Added line #L130 was not covered by tests

Check warning on line 19 in src/include/processor/operator/persistent/reader/csv/serial_csv_reader.h

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/include/processor/operator/persistent/reader/csv/serial_csv_reader.h#L18-L19 

Added lines #L18 - L19 were not covered by tests

Check warning on line 29 in src/processor/operator/persistent/reader/csv/base_csv_reader.cpp

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/processor/operator/persistent/reader/csv/base_csv_reader.cpp#L28-L29 

Added lines #L28 - L29 were not covered by tests

Check warning on line 76 in src/processor/operator/persistent/reader/csv/base_csv_reader.cpp

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/processor/operator/persistent/reader/csv/base_csv_reader.cpp#L75-L76 

Added lines #L75 - L76 were not covered by tests

Check warning on line 107 in src/processor/operator/persistent/reader/csv/base_csv_reader.cpp

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/processor/operator/persistent/reader/csv/base_csv_reader.cpp#L107 

Added line #L107 was not covered by tests

Check warning on line 117 in src/processor/operator/persistent/reader/csv/base_csv_reader.cpp

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/processor/operator/persistent/reader/csv/base_csv_reader.cpp#L117 

Added line #L117 was not covered by tests

Check warning on line 135 in src/processor/operator/persistent/reader/csv/base_csv_reader.cpp

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/processor/operator/persistent/reader/csv/base_csv_reader.cpp#L135 

Added line #L135 was not covered by tests

Check warning on line 163 in src/processor/operator/persistent/reader/csv/base_csv_reader.cpp

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/processor/operator/persistent/reader/csv/base_csv_reader.cpp#L163 

Added line #L163 was not covered by tests

Check warning on line 201 in src/processor/operator/persistent/reader/csv/base_csv_reader.cpp

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/processor/operator/persistent/reader/csv/base_csv_reader.cpp#L201 

Added line #L201 was not covered by tests

Check warning on line 341 in src/processor/operator/persistent/reader/csv/base_csv_reader.cpp

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/processor/operator/persistent/reader/csv/base_csv_reader.cpp#L341 

Added line #L341 was not covered by tests

Check warning on line 453 in src/processor/operator/persistent/reader/csv/base_csv_reader.cpp

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/processor/operator/persistent/reader/csv/base_csv_reader.cpp#L453 

Added line #L453 was not covered by tests

Check warning on line 499 in src/processor/operator/persistent/reader/csv/base_csv_reader.cpp

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/processor/operator/persistent/reader/csv/base_csv_reader.cpp#L499 

Added line #L499 was not covered by tests

Check warning on line 503 in src/processor/operator/persistent/reader/csv/base_csv_reader.cpp

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/processor/operator/persistent/reader/csv/base_csv_reader.cpp#L502-L503 

Added lines #L502 - L503 were not covered by tests

Check warning on line 506 in src/processor/operator/persistent/reader/csv/base_csv_reader.cpp

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/processor/operator/persistent/reader/csv/base_csv_reader.cpp#L506 

Added line #L506 was not covered by tests

Check warning on line 530 in src/processor/operator/persistent/reader/csv/base_csv_reader.cpp

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/processor/operator/persistent/reader/csv/base_csv_reader.cpp#L529-L530 

Added lines #L529 - L530 were not covered by tests

Check warning on line 533 in src/processor/operator/persistent/reader/csv/base_csv_reader.cpp

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/processor/operator/persistent/reader/csv/base_csv_reader.cpp#L533 

Added line #L533 was not covered by tests

Check warning on line 541 in src/processor/operator/persistent/reader/csv/base_csv_reader.cpp

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/processor/operator/persistent/reader/csv/base_csv_reader.cpp#L540-L541 

Added lines #L540 - L541 were not covered by tests

Check warning on line 545 in src/processor/operator/persistent/reader/csv/base_csv_reader.cpp

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/processor/operator/persistent/reader/csv/base_csv_reader.cpp#L545 

Added line #L545 was not covered by tests

Check warning on line 547 in src/processor/operator/persistent/reader/csv/base_csv_reader.cpp

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/processor/operator/persistent/reader/csv/base_csv_reader.cpp#L547 

Added line #L547 was not covered by tests

Check warning on line 19 in src/processor/operator/persistent/reader/csv/serial_csv_reader.cpp

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/processor/operator/persistent/reader/csv/serial_csv_reader.cpp#L19 

Added line #L19 was not covered by tests

Check warning on line 21 in src/processor/operator/persistent/reader/csv/serial_csv_reader.cpp

See this annotation in the file changed.

@codecov codecov / codecov/patch

src/processor/operator/persistent/reader/csv/serial_csv_reader.cpp#L21 

Added line #L21 was not covered by tests
View more details on Codecov