| 60 | } |
| 61 | |
| 62 | Status DataSinkConfig::Init( |
| 63 | const TDataSink& tsink, const RowDescriptor* input_row_desc, FragmentState* state) { |
| 64 | tsink_ = &tsink; |
| 65 | input_row_desc_ = input_row_desc; |
| 66 | return ScalarExpr::Create(tsink.output_exprs, *input_row_desc_, state, &output_exprs_); |
| 67 | } |
| 68 | |
| 69 | void DataSinkConfig::AddCodegenStatus( |
| 70 | const Status& codegen_status, const std::string& extra_label) { |