Method IndexLookupJoin

bolt/exec/IndexLookupJoin.cpp:49–83

namespace

}
} // namespace
IndexLookupJoin::IndexLookupJoin(
    int32_t operatorId,
    DriverCtx* driverCtx,
    const std::shared_ptr<const core::IndexLookupJoinNode>& joinNode)
    : Operator(
          driverCtx,
          joinNode->outputType(),
          operatorId,
          joinNode->id(),
          "IndexLookupJoin"),
      // TODO: support to update output batch size with output size stats during
      // the lookup processing.
      outputBatchSize_{static_cast<vector_size_t>(outputBatchRows())},
      joinType_{joinNode->joinType()},
      numKeys_{joinNode->leftKeys().size()},
      probeType_{joinNode->sources()[0]->outputType()},
      lookupType_{joinNode->lookupSource()->outputType()},
      lookupTableHandle_{joinNode->lookupSource()->tableHandle()},
      lookupColumnHandles_(joinNode->lookupSource()->assignments()),
      connectorQueryCtx_{operatorCtx_->createConnectorQueryCtx(
          lookupTableHandle_->connectorId(),
          planNodeId(),
          driverCtx->task->addConnectorPoolLocked(
              planNodeId(),
              driverCtx->pipelineId,
              driverCtx->driverId,
              operatorType(),
              lookupTableHandle_->connectorId()),
          spillConfig_.has_value() ? &(spillConfig_.value()) : nullptr)},
      expressionEvaluator_(connectorQueryCtx_->expressionEvaluator()),
      connector_(connector::getConnector(lookupTableHandle_->connectorId())),
      joinNode_{joinNode} {
  duplicateJoinKeyCheck(joinNode_->leftKeys());
  duplicateJoinKeyCheck(joinNode_->rightKeys());
}

void IndexLookupJoin::initialize() {
  Operator::initialize();