| 45 | const char* BlockingJoinNode::LLVM_CLASS_NAME = "class.impala::BlockingJoinNode"; |
| 46 | |
| 47 | Status BlockingJoinPlanNode::Init(const TPlanNode& tnode, FragmentState* state) { |
| 48 | DCHECK(tnode.__isset.join_node); |
| 49 | RETURN_IF_ERROR(PlanNode::Init(tnode, state)); |
| 50 | join_op_ = tnode_->join_node.join_op; |
| 51 | build_row_desc_ = state->obj_pool()->Add( |
| 52 | new RowDescriptor(state->desc_tbl(), tnode.join_node.build_tuples, |
| 53 | tnode.join_node.nullable_build_tuples)); |
| 54 | DCHECK(!IsSemiJoin(tnode.join_node.join_op) || conjuncts_.size() == 0); |
| 55 | return Status::OK(); |
| 56 | } |
| 57 | |
| 58 | BlockingJoinNode::BlockingJoinNode(const string& node_name, ObjectPool* pool, |
| 59 | const BlockingJoinPlanNode& pnode, const DescriptorTbl& descs) |
nothing calls this directly
no test coverage detected