@Override
    public void process(ComplexEventChunk complexEventChunk) {
        if (complexEventChunk != null) {
            ComplexEvent complexEvent = complexEventChunk.getFirst();
            Object[] outputData = complexEvent.getOutputData();
            if (outputData.length == 3) {
                Date fromTime = new Date((Long) outputData[0]);
                Date toTime = new Date((Long) outputData[1]);
                log.debug("Aggregation executed for duration " + duration + " from " + fromTime + " to " +
                        toTime + " and  " + outputData[2] + " records has been successfully updated ");
            }
        }
    }
Processor implementation to read the results after executing the aggregation query
modules/siddhi-core/src/main/java/io/siddhi/core/aggregation/persistedaggregation/config/PersistedAggregationResultsProcessor.java