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