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

Method Filter

cpp/src/arrow/dataset/scanner.cc:937–944  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

935}
936
937Status ScannerBuilder::Filter(const compute::Expression& filter) {
938 for (const auto& ref : FieldsInExpression(filter)) {
939 RETURN_NOT_OK(ref.FindOne(*scan_options_->dataset_schema));
940 }
941 ARROW_ASSIGN_OR_RAISE(scan_options_->filter,
942 filter.Bind(*scan_options_->dataset_schema));
943 return Status::OK();
944}
945
946Status ScannerBuilder::UseThreads(bool use_threads) {
947 scan_options_->use_threads = use_threads;

Callers 7

TEST_FFunction · 0.45
TEST_PFunction · 0.45
TEST_PFunction · 0.45
TEST_FFunction · 0.45
TEST_FFunction · 0.45
TEST_FMethod · 0.45
TESTMethod · 0.45

Calls 4

FieldsInExpressionFunction · 0.85
ARROW_ASSIGN_OR_RAISEFunction · 0.50
OKFunction · 0.50
BindMethod · 0.45

Tested by 7

TEST_FFunction · 0.36
TEST_PFunction · 0.36
TEST_PFunction · 0.36
TEST_FFunction · 0.36
TEST_FFunction · 0.36
TEST_FMethod · 0.36
TESTMethod · 0.36