MCPcopy Create free account
hub / github.com/apache/arrow / Finish

Method Finish

cpp/src/arrow/dataset/scanner_test.cc:1999–2004  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

1997
1998 template <typename T>
1999 void Finish(AsyncGenerator<T> gen) {
2000 for (const auto& controlled_fragment : controlled_fragments_) {
2001 controlled_fragment->Finish();
2002 }
2003 ASSERT_FINISHES_OK(VisitAsyncGenerator(gen, [](T batch) { return Status::OK(); }));
2004 }
2005
2006 std::shared_ptr<Schema> schema_ = schema({field("values", int32())});
2007 std::vector<std::shared_ptr<ControlledFragment>> controlled_fragments_;

Callers 7

ArrayFromRangeFunction · 0.45
MakeTestDatasetFunction · 0.45
TESTFunction · 0.45
MakePartitionSkipDatasetFunction · 0.45
TEST_PFunction · 0.45
FinishFragmentMethod · 0.45

Calls 2

VisitAsyncGeneratorFunction · 0.85
OKFunction · 0.50

Tested by

no test coverage detected