mirror of
https://github.com/apache/arrow.git
synced 2026-10-29 09:05:47 +08:00
Clang format
This commit is contained in:
2 files changed
+11
-4
No files matched your search
@@ -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();
|
||||
|
||||
|
||||
@@ -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():
|
||||
|
||||
Reference in new issue
Block a user