@Override
    public Event intercept(Event event) {
        long logTime;
        ProfileEvent profile;
        if (event instanceof ProfileEvent) {
            profile = (ProfileEvent) event;
            logTime = profile.getRawLogTime();
        } else {
            return event;
        }

        if (logTime > stopTime || logTime < startTime) {
            profile.ack();
            return null;
        }
        return event;
    }
Interceptor that filters events selectively based on a configured time interval.
Usually, it's used to roll back data in a certain time interval.
It supports config either one of start, stop time or both of them.
Multiple TimeBasedFilterInterceptor can be chained together to create more complex time intervals.
inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/rollback/TimeBasedFilterInterceptor.java