@Override
    public void mapAndSend(Event[] events, OptionHolder optionHolder,
                           Map<String, TemplateBuilder> payloadTemplateBuilderMap, SinkListener sinkListener) {
        for (Event event : events) {
            String topic = topicOption.getValue(event);
            if (mapType) {
                for (TemplateBuilder templateBuilder : payloadTemplateBuilderMap.values()) {
                    sinkListener.publish(new Event(System.currentTimeMillis(), new Object[]{sinkType, topic,
                            templateBuilder.isObjectMessage() + "-" + templateBuilder.getType().toString()}));
                }
            } else {
                //to change the topic as topic is picked from the original event
                event.getData()[0] = sinkType;
                sinkListener.publish(new Event(System.currentTimeMillis(), new Object[]{sinkType, topic, prefix}));
            }
        }
    }
Implementation of {@link SinkMapper} representing pass-through scenario where no mapping is done and
{@link Event}s are send directly to transports.
modules/siddhi-core/src/test/java/io/siddhi/core/transport/TestSinkOptionSinkMapper.java