presto-main/src/main/java/io/prestosql/operator/exchange/LocalExchangeSinkOperator.java/LocalExchangeSinkOperator/LocalExchangeSinkOperator
class LocalExchangeSinkOperator:    LocalExchangeSinkOperator(OperatorContext operatorContext, LocalExchangeSink sink, Function<Page, Page> pagePreprocessor)
    {
        this.operatorContext = requireNonNull(operatorContext, "operatorContext is null");
        this.sink = requireNonNull(sink, "sink is null");
        this.pagePreprocessor = requireNonNull(pagePreprocessor, "pagePreprocessor is null");
    }