Toggle navigation
Home
java.lang.Object to org.apache.flink.streaming.runtime.tasks.ProcessingTimeService
No. of Instances - 3
No. of Commits - 2
No. of Projects - {'flink'}
Hierarchy/Composition: -
Primitive Info: -
NameSpace: Jdk -> Internal
Mapping:
Rename Variable
lock
to
timerService
lock
to
timerService
lockingObject
to
processingTimeService
Add or Remove Method invocation
System.currentTimeMillis()
to
timestamp
scheduleExecutor.scheduleAtFixedRate(new ProcessingTimeCallback(){ @Override public void run(){ try { synchronized (lockingObject) { output.emitLatencyMarker(new LatencyMarker(timestamp,vertexID,subtaskIndex)); } } catch ( Throwable t) { LOG.warn("Error while emitting latency marker",t); } } } ,0,latencyTrackingInterval,TimeUnit.MILLISECONDS)
to
processingTimeService.scheduleAtFixedRate(new ProcessingTimeCallback(){ @Override public void onProcessingTime( long timestamp) throws Exception { try { output.emitLatencyMarker(new LatencyMarker(timestamp,vertexID,subtaskIndex)); } catch ( Throwable t) { LOG.warn("Error while emitting latency marker.",t); } } } ,0L,latencyTrackingInterval)
Cascading Type Change (Different)
Runnable
to
ProcessingTimeCallback