@Override
    public void send(Event event, int streamIndex) {
        inputProcessors.get(streamIndex).send(event, streamIndex);
    }
Implementation of {@link InputProcessor} which inject the event to a set of Input Processors.
modules/siddhi-core/src/main/java/io/siddhi/core/stream/input/InputDistributor.java