components/global/core/io.cellery.observability.model.generator/src/main/java/io/cellery/observability/model/generator/TraceGroupWindowProcessor.java
private void addLateEvent(ComplexEventChunk<StreamEvent> streamEventChunk,
                              long eventTimestamp, StreamEvent streamEvent, TraceGroup traceGroup) {
        //check the late event belongs to the same trace
        if (eventTimestamp >= (traceGroup.getStartTimestamp() - idleTimeGap)) {
            traceGroup.add(streamEvent);
            traceGroup.setStartTimestamp(eventTimestamp);
        } else {
            streamEventChunk.remove();
            log.info("The event, " + streamEvent + " is late and it's tracegroup window has been timeout");
        }
    }
/**
     * Handles when the late event arrives to the system.
     */
Handles when the late event arrives to the system.
Handles when the late event arrives to the system .
private void addLateEvent(ComplexEventChunk<StreamEvent> streamEventChunk,
                              long eventTimestamp, StreamEvent streamEvent, TraceGroup traceGroup) {
        if (eventTimestamp >= (traceGroup.getStartTimestamp() - idleTimeGap)) {
            traceGroup.add(streamEvent);
            traceGroup.setStartTimestamp(eventTimestamp);
        } else {
            streamEventChunk.remove();
            log.info("The event, " + streamEvent + " is late and it's tracegroup window has been timeout");
        }
    }
private void addLateEvent ( ComplexEventChunk < StreamEvent > streamEventChunk , long eventTimestamp , StreamEvent streamEvent , TraceGroup traceGroup ) { if ( eventTimestamp >= ( traceGroup . getStartTimestamp ( ) - idleTimeGap ) ) { traceGroup . add ( streamEvent ) ; traceGroup . setStartTimestamp ( eventTimestamp ) ; } else { streamEventChunk . remove ( ) ; log . info ( "The event, " + streamEvent + " is late and it's tracegroup window has been timeout" ) ; } }
Handles when the late event arrives to the system.
Handles when the late event arrives to the system .
//check the late event belongs to the same trace