Package org.apache.flink.streaming.api.operators

Interface InternalTimeServiceManager.Provider

All Superinterfaces:

Serializable

Enclosing interface:

InternalTimeServiceManager<K>

Functional Interface:

This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.

@FunctionalInterface
public static interface InternalTimeServiceManager.Provider
extends Serializable

A provider pattern for creating an instance of a InternalTimeServiceManager. Allows substituting the manager that will be used at the runtime.

Method Summary

Modifier and Type	Method	Description
<K> InternalTimeServiceManager<K>	create(TaskIOMetricGroup taskIOMetricGroup, CheckpointableKeyedStateBackend<K> keyedStatedBackend, ClassLoader userClassloader, KeyContext keyContext, ProcessingTimeService processingTimeService, Iterable<KeyGroupStatePartitionStreamProvider> rawKeyedStates, StreamTaskCancellationContext cancellationContext)

Method Detail

create

<K> InternalTimeServiceManager<K> create(TaskIOMetricGroup taskIOMetricGroup,
                                         CheckpointableKeyedStateBackend<K> keyedStatedBackend,
                                         ClassLoader userClassloader,
                                         KeyContext keyContext,
                                         ProcessingTimeService processingTimeService,
                                         Iterable<KeyGroupStatePartitionStreamProvider> rawKeyedStates,
                                         StreamTaskCancellationContext cancellationContext)
                                  throws Exception

Throws:

Exception