@Override
    protected void mapAndProcess(Object eventObject, InputEventHandler inputEventHandler)
            throws MappingFailedException, InterruptedException {
        if (eventObject != null) {
            if (eventObject instanceof Event[]) {
                inputEventHandler.sendEvents((Event[]) eventObject);
            } else if (eventObject instanceof Event) {
                inputEventHandler.sendEvent((Event) eventObject);
            } else if (eventObject instanceof Object[]) {
                Event event = new Event(-1, (Object[]) eventObject);
                inputEventHandler.sendEvent(event);
            } else {
                throw new MappingFailedException(Collections.singletonList(
                        new ErroneousEvent(eventObject, "Event object must be either Event[], Event or Object[] " +
                                "but found " + eventObject.getClass().getCanonicalName())));
            }
        }
    }
Event Mapper implementation to handle pass-through scenario where user does not need to do any mapping.
modules/siddhi-core/src/main/java/io/siddhi/core/stream/input/source/PassThroughSourceMapper.java