Clang format

This commit is contained in:
Krisztián Szűcs committed 2019-12-12 12:27:38 +01:00
1 parent a1d82546ff
commit 7553caa96b
2 files changed
+11 -4

No files matched your search

+1 -1
View File
@@ -129,7 +129,7 @@ class ARROW_DS_EXPORT SimpleDataSource : public DataSource {
//
/// \param[in] record_batches one or more input record batches
static Result<DataSourcePtr> Make(
std::vector<std::shared_ptr<RecordBatch>> record_batches);
std::vector<std::shared_ptr<RecordBatch>> record_batches);
explicit SimpleDataSource();
+10 -3
View File
@@ -177,13 +177,20 @@ def test_scanner_builder(dataset):
builder = ds.ScannerBuilder(dataset, memory_pool=pa.default_memory_pool())
scanner = builder.finish()
assert isinstance(scanner, ds.Scanner)
scanner.scan()
assert len(list(scanner.scan())) == 3
with pytest.raises(pa.ArrowInvalid):
dataset.new_scan().project(['unknown'])
builder = dataset.new_scan(memory_pool=pa.default_memory_pool())
builder.project(['i64'])
scanner = builder.finish()
scanner = builder.project(['i64', 'i64', 'i64']).finish()
assert isinstance(scanner, ds.Scanner)
assert len(list(scanner.scan())) == 3
for task in scanner.scan():
for batch in task.scan():
assert isinstance(batch, pa.RecordBatch)
# FIXME(kszucs)
# assert batch.num_columns == 1
def test_abstract_classes():