presto-main/src/main/java/io/prestosql/operator/exchange/LocalExchange.java/LocalExchangeSinkFactory/createSink
class LocalExchangeSinkFactory:        public LocalExchangeSink createSink()
        {
            return exchange.createSink(this);
        }