public void start() {
        int statBackTimes = configuration.get(KEY_SUMMARY_REALTIME_STAT_BACK_TIMES,
                DEFAULT_SUMMARY_REALTIME_STAT_BACK_TIMES);

        startDataFlow(AuditCycle.MINUTE_10, statBackTimes, TenMinutesCache.getInstance().getCache());
        startDataFlow(AuditCycle.MINUTE_30, statBackTimes, HalfHourCache.getInstance().getCache());
        startDataFlow(AuditCycle.HOUR, statBackTimes, HourCache.getInstance().getCache());

        if (configuration.get(KEY_ENABLE_STAT_AUDIT_DAY, DEFAULT_ENABLE_STAT_AUDIT_DAY)) {
            statBackTimes = configuration.get(KEY_SUMMARY_DAILY_STAT_BACK_TIMES, DEFAULT_SUMMARY_DAILY_STAT_BACK_TIMES);
            startDataFlow(AuditCycle.DAY, statBackTimes, null);
        }
    }
Etl service aggregate the data from the data source and store the aggregated data to the target storage.
inlong-audit/audit-service/src/main/java/org/apache/inlong/audit/service/node/EtlService.java