Function AddTableAndSinkToPlan

cpp/src/arrow/acero/tpch_node_test.cc:53–60

constexpr double kDefaultScaleFactor = 0.1;

Status AddTableAndSinkToPlan(ExecPlan& plan, TpchGen& gen,
                             AsyncGenerator<std::optional<ExecBatch>>& sink_gen,
                             TableNodeFn table) {
  ARROW_ASSIGN_OR_RAISE(ExecNode * table_node, ((gen.*table)({})));
  Declaration sink("sink", {Declaration::Input(table_node)}, SinkNodeOptions{&sink_gen});
  ARROW_RETURN_NOT_OK(sink.AddToPlan(&plan));
  return Status::OK();
}

Result<std::vector<ExecBatch>> GenerateTable(TableNodeFn table,
                                             double scale_factor = kDefaultScaleFactor) {