ProcessingTimeServiceAware (Flink : 2.0-SNAPSHOT API)

All Known Implementing Classes:

AbstractStreamOperatorFactory, AsyncWaitOperatorFactory, BatchMultipleInputStreamOperatorFactory, CodeGenOperatorFactory, CollectSinkOperatorFactory, CommitterOperatorFactory, CompactCoordinatorFactory, CompactCoordinatorStateHandlerFactory, CompactorOperatorFactory, CompactorOperatorStateHandlerFactory, ContinuousFileReaderOperatorFactory, DynamicFilteringDataCollectorOperatorFactory, EvictingWindowOperatorFactory, OperatorFusionCodegenFactory, SimpleInputFormatOperatorFactory, SimpleOperatorFactory, SimpleOutputFormatOperatorFactory, SimpleUdfStreamOperatorFactory, SinkWriterOperatorFactory, SourceOperatorFactory, StateBootstrapWrapperOperatorFactory, TimestampsAndWatermarksOperatorFactory, WatermarkAssignerOperatorFactory, WindowOperatorFactory
```
@PublicEvolving
public interface ProcessingTimeServiceAware
```
Interface for StreamOperatorFactory, which enables stream operators to access ProcessingTimeService.
For an stream operator, if it needs to access the ProcessingTimeService, it must be created through a operator factory that implements ProcessingTimeServiceAware, and the operator factory should set the ProcessingTimeService instance into the stream operator.

- Method Summary
  
  All Methods Instance Methods Abstract Methods
  Modifier and Type Method Description
  
  void setProcessingTimeService(ProcessingTimeService processingTimeService)

Method Detail

setProcessingTimeService

void setProcessingTimeService(ProcessingTimeService processingTimeService)