presto-main/src/main/java/io/prestosql/operator/LookupJoinOperator.java/LookupJoinOperator/LookupJoinOperator
class LookupJoinOperator:    public LookupJoinOperator(List<Type> probeTypes,
            List<Type> buildOutputTypes,
            JoinType joinType,
            LookupSourceFactory lookupSourceFactory,
            JoinProbeFactory joinProbeFactory,
            Runnable afterClose,
            OptionalInt lookupJoinsCount,
            HashGenerator hashGenerator,
            PartitioningSpillerFactory partitioningSpillerFactory,
            ProcessorContext processorContext,
            Optional<WorkProcessor<Page>> sourcePages)
    {
        this.statisticsCounter = new JoinStatisticsCounter(joinType);
        this.joinProcessor = new JoinProcessor(probeTypes,
                buildOutputTypes,
                joinType,
                lookupSourceFactory,
                joinProbeFactory,
                afterClose,
                lookupJoinsCount,
                hashGenerator,
                partitioningSpillerFactory,
                statisticsCounter,
                processorContext.getDriverYieldSignal(),
                processorContext.getSpillContext(),
                processorContext.getMemoryTrackingContext());
        pageBuffer = new PageBuffer(joinProcessor.lookupSourceProviderFuture);
        pages = sourcePages.orElse(pageBuffer.pages()).transform(joinProcessor);
    }