private StreamJunction createStreamJunction() {
        return new StreamJunction(streamDefinition, siddhiAppContext.getExecutorService(),
                siddhiAppContext.getBufferSize(), null, siddhiAppContext);
    }
create local streamJunctions through which events received by partitionStreamReceiver, are sent to
queryStreamReceivers

@param queryRuntimeList queryRuntime list of the partition
modules/siddhi-core/src/main/java/io/siddhi/core/partition/PartitionStreamReceiver.java