Package org.apache.flink.datastream.impl.context

Class DefaultPartitionedContext

java.lang.Object

org.apache.flink.datastream.impl.context.DefaultPartitionedContext

All Implemented Interfaces:

PartitionedContext, RuntimeContext

public class DefaultPartitionedContext
extends Object
implements PartitionedContext

The default implementation of PartitionedContext.

Constructor Summary

Constructors

Constructor	Description
DefaultPartitionedContext(RuntimeContext context, Supplier<Object> currentKeySupplier, Consumer<Object> currentKeySetter, ProcessingTimeManager processingTimeManager, StreamingRuntimeContext operatorContext, OperatorStateStore operatorStateStore)

Method Summary

Modifier and Type	Method	Description
JobInfo	getJobInfo()	Get the JobInfo of this process function.
MetricGroup	getMetricGroup()	Get the metric group of this process function.
ProcessingTimeManager	getProcessingTimeManager()	Get the ProcessingTimeManager of this process function.
DefaultStateManager	getStateManager()	Get the StateManager of this process function.
TaskInfo	getTaskInfo()	Get the TaskInfo of this process function.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DefaultPartitionedContext

public DefaultPartitionedContext(RuntimeContext context,
                                 Supplier<Object> currentKeySupplier,
                                 Consumer<Object> currentKeySetter,
                                 ProcessingTimeManager processingTimeManager,
                                 StreamingRuntimeContext operatorContext,
                                 OperatorStateStore operatorStateStore)

Method Detail

getJobInfo

public JobInfo getJobInfo()

Description copied from interface: RuntimeContext

Get the JobInfo of this process function.

Specified by:

getJobInfo in interface RuntimeContext

getTaskInfo

public TaskInfo getTaskInfo()

Description copied from interface: RuntimeContext

Get the TaskInfo of this process function.

Specified by:

getTaskInfo in interface RuntimeContext

getStateManager

public DefaultStateManager getStateManager()

Description copied from interface: PartitionedContext

Get the StateManager of this process function.

Specified by:

getStateManager in interface PartitionedContext

getProcessingTimeManager

public ProcessingTimeManager getProcessingTimeManager()

Description copied from interface: PartitionedContext

Get the ProcessingTimeManager of this process function.

Specified by:

getProcessingTimeManager in interface PartitionedContext

getMetricGroup

public MetricGroup getMetricGroup()

Description copied from interface: RuntimeContext

Get the metric group of this process function.

Specified by:

getMetricGroup in interface RuntimeContext