hub / github.com/apache/arrow / finished

Method finished

cpp/src/arrow/acero/exec_plan.cc:444–444 · view source on GitHub ↗

Source from the content-addressed store, hash-verified

442	void ExecPlan::StopProducing() { ToDerived(this)->StopProducing(); }
443
444	Future<> ExecPlan::finished() { return ToDerived(this)->finished_; }
445
446	bool ExecPlan::HasMetadata() const { return !!(ToDerived(this)->metadata_); }
447

Callers 15

garrow_execute_plan_waitFunction · 0.80

ScanBatchesUnorderedAsyncMethod · 0.80

StartAndFinishFunction · 0.80

StartAndCollectFunction · 0.80

Expression>& guarantees) { // If guarantees are provided we must have one for each batch if (!guarantees.empty()) { EXPECT_EQ(fragment_batch_strs.size(), guarantees.size())Method · 0.80

TESTFunction · 0.80

ARROW_ASSIGN_OR_RAISEFunction · 0.80

CheckValidTestCasesFunction · 0.80

CheckErrorTestCasesFunction · 0.80

CheckWholeAggregateCaseFunction · 0.80

CheckGroupedAggregateCaseFunction · 0.80

Calls 1

ToDerivedFunction · 0.85

Tested by 15

StartAndFinishFunction · 0.64

StartAndCollectFunction · 0.64

Expression>& guarantees) { // If guarantees are provided we must have one for each batch if (!guarantees.empty()) { EXPECT_EQ(fragment_batch_strs.size(), guarantees.size())Method · 0.64

TESTFunction · 0.64

ARROW_ASSIGN_OR_RAISEFunction · 0.64

CheckValidTestCasesFunction · 0.64

CheckErrorTestCasesFunction · 0.64

CheckWholeAggregateCaseFunction · 0.64

CheckGroupedAggregateCaseFunction · 0.64

TESTFunction · 0.64

RunGroupByFunction · 0.64