presto-main/src/main/java/io/prestosql/operator/exchange/LocalExchangeSinkOperator.java/LocalExchangeSinkOperatorFactory/localPlannerComplete
class LocalExchangeSinkOperatorFactory:        @Override
        public void localPlannerComplete()
        {
            localExchangeFactory.noMoreSinkFactories();
        }