Method Close

be/src/exec/scan-node.cc:197–213

}

void ScanNode::Close(RuntimeState* state) {
  if (is_closed()) return;
  // Compute effective filters by checking if any rows were rejected.
  for (const auto& filter_ctx : filter_ctxs_) {
    if (filter_ctx.stats != nullptr && filter_ctx.stats->HasRejectedRows()) {
      effective_filter_ids_.push_back(filter_ctx.filter->id());
    }
  }
  // Close filter
  for (auto& filter_ctx : filter_ctxs_) {
    if (filter_ctx.expr_eval != nullptr) filter_ctx.expr_eval->Close(state);
  }
  // ScanNode::Prepare() started periodic counters including 'total_throughput_counter_'
  // and 'bytes_read_timeseries_counter_'. Subclasses may also have started counters.
  runtime_profile_->StopPeriodicCounters();
  ExecNode::Close(state);
}

bool ScanNode::WaitForRuntimeFilters() {
  int32_t wait_time_ms = FLAGS_runtime_filter_wait_time_ms;