public void init(SiddhiAppContext siddhiAppContext, StreamDefinition streamDefinition, int duration) {
        this.siddhiAppContext = siddhiAppContext;
        this.streamDefinition = streamDefinition;
        this.duration = duration;
        this.loggerExecutionInterval = Expression.Time.minute(duration).value();
    }
Log number of events received by each receiver
modules/siddhi-core/src/main/java/io/siddhi/core/util/statistics/ReceivedEventCounter.java