Method init

fe/src/main/java/org/apache/impala/planner/JoinNode.java:273–298

(Analyzer analyzer)

  abstract public boolean isBlockingJoinNode();

  @Override
  public void init(Analyzer analyzer) throws ImpalaException {
    // Do not call super.init() to defer computeStats() until all conjuncts
    // have been collected.
    assignConjuncts(analyzer);
    createDefaultSmap(analyzer);
    // Mark slots used by 'conjuncts_' as materialized after substitution. Recompute
    // memory layout for affected tuples. Note: only tuples of the masked tables could
    // be affected if they are referenced by multi-tuple predicates.
    for (TupleDescriptor tuple : analyzer.materializeSlots(conjuncts_)) {
      if (LOG.isTraceEnabled()) {
        LOG.trace("Recompute mem layout for " + tuple.debugString());
      }
      Preconditions.checkNotNull(tuple.getMaskedByTuple());
      tuple.recomputeMemLayout();
    }
    assignedConjuncts_ = analyzer.getAssignedConjuncts();
    otherJoinConjuncts_ = Expr.substituteList(otherJoinConjuncts_,
        getCombinedChildSmap(), analyzer, false);

    List<SlotRef> slotRefs = new ArrayList<>();
    for (Expr e : getConjuncts()) { e.collect(SlotRef.class, slotRefs); }
    for (Expr e : getOtherJoinConjuncts()) { e.collect(SlotRef.class, slotRefs); }
    for (Expr e : getEqJoinConjuncts()) { e.collect(SlotRef.class, slotRefs); }
    analyzer.addJoinColumns(slotRefs);
  }

  /**
   * Returns the estimated cardinality of an inner or outer join.