@Override
    public void receive(Event event) {
        StreamEvent newEvent = streamEventFactory.newInstance();
        streamEventConverter.convertEvent(event, newEvent);
        for (PartitionExecutor partitionExecutor : partitionExecutors) {
            String key = partitionExecutor.execute(newEvent);
            send(key, newEvent);
        }
        if (partitionExecutors.size() == 0) {
            send(newEvent);
        }
    }
Specific {@link StreamJunction.Receiver} implementation to pump events into partitions. This will send the event
to the matching partition.
modules/siddhi-core/src/main/java/io/siddhi/core/partition/PartitionStreamReceiver.java