| 52 | } |
| 53 | |
| 54 | MultiTableSink::MultiTableSink(TDataSinkId sink_id, |
| 55 | const MultiTableSinkConfig& sink_config, const TDataSink& dsink, |
| 56 | RuntimeState* state) : DataSink(sink_id, sink_config, "MultiTableSink", state) { |
| 57 | for (TableSinkBaseConfig* tbl_sink_config : sink_config.table_sink_configs()) { |
| 58 | TableSinkBase* tsink_base = |
| 59 | DCHECK_NOTNULL(dynamic_cast<TableSinkBase*>(tbl_sink_config->CreateSink(state))); |
| 60 | table_sinks_.push_back(tsink_base); |
| 61 | profile()->AddChild(tsink_base->profile()); |
| 62 | } |
| 63 | } |
| 64 | |
| 65 | Status MultiTableSink::Prepare(RuntimeState* state, MemTracker* parent_mem_tracker) { |
| 66 | RETURN_IF_ERROR(DataSink::Prepare(state, parent_mem_tracker)); |
nothing calls this directly
no test coverage detected