org.apache.flink.streaming.runtime.tasks

Interface ProcessingTimeServiceAware

All Known Implementing Classes:

AbstractStreamOperatorFactory, AsyncWaitOperatorFactory, BatchMultipleInputStreamOperatorFactory, CodeGenOperatorFactory, CollectSinkOperatorFactory, CommitterOperatorFactory, CompactCoordinatorFactory, CompactCoordinatorStateHandlerFactory, CompactorOperatorFactory, CompactorOperatorStateHandlerFactory, ContinuousFileReaderOperatorFactory, DynamicFilteringDataCollectorOperatorFactory, OperatorFusionCodegenFactory, SimpleInputFormatOperatorFactory, SimpleOperatorFactory, SimpleOutputFormatOperatorFactory, SimpleUdfStreamOperatorFactory, SinkWriterOperatorFactory, SourceOperatorFactory, WatermarkAssignerOperatorFactory

@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

Modifier and Type	Method and Description
void	setProcessingTimeService(ProcessingTimeService processingTimeService)

Method Detail

setProcessingTimeService

void setProcessingTimeService(ProcessingTimeService processingTimeService)