| 27 | namespace impala { |
| 28 | |
| 29 | HdfsTableWriter::HdfsTableWriter(TableSinkBase* parent, |
| 30 | RuntimeState* state, OutputPartition* output, |
| 31 | const HdfsPartitionDescriptor* partition_desc, const HdfsTableDescriptor* table_desc) |
| 32 | : parent_(parent), |
| 33 | state_(state), |
| 34 | output_(output), |
| 35 | table_desc_(table_desc), |
| 36 | output_expr_evals_(parent->output_expr_evals()) { |
| 37 | int num_non_partition_cols = |
| 38 | table_desc_->num_cols() - table_desc_->num_clustering_cols(); |
| 39 | if (!table_desc_->IsIcebergTable() || table_desc_->IcebergFormatVersion() < 3) { |
| 40 | DCHECK_GE(output_expr_evals_.size(), num_non_partition_cols) |
| 41 | << parent_->DebugString(); |
| 42 | } |
| 43 | } |
| 44 | |
| 45 | Status HdfsTableWriter::Write(const uint8_t* data, int32_t len) { |
| 46 | DCHECK_GE(len, 0); |
nothing calls this directly
no test coverage detected