Method Init

cpp/examples/arrow/engine_substrait_consumption.cc:35–39

  explicit IgnoringConsumer(size_t tag) : tag_{tag} {}

  arrow::Status Init(const std::shared_ptr<arrow::Schema>& schema,
                     ac::BackpressureControl* backpressure_control,
                     ac::ExecPlan* plan) override {
    return arrow::Status::OK();
  }

  arrow::Status Consume(cp::ExecBatch batch) override {
    // Consume a batch of data