presto-main/src/main/java/io/prestosql/operator/exchange/LocalMergeSourceOperator.java/LocalMergeSourceOperator/close
class LocalMergeSourceOperator:    @Override
    public void close()
            throws IOException
    {
        sources.forEach(LocalExchangeSource::close);
    }