public class DefaultPartitionedContext extends Object implements PartitionedContext
PartitionedContext
.Constructor and Description |
---|
DefaultPartitionedContext(RuntimeContext context,
java.util.function.Supplier<Object> currentKeySupplier,
java.util.function.Consumer<Object> currentKeySetter,
ProcessingTimeManager processingTimeManager,
StreamingRuntimeContext operatorContext,
OperatorStateStore operatorStateStore) |
Modifier and Type | Method and 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. |
public DefaultPartitionedContext(RuntimeContext context, java.util.function.Supplier<Object> currentKeySupplier, java.util.function.Consumer<Object> currentKeySetter, ProcessingTimeManager processingTimeManager, StreamingRuntimeContext operatorContext, OperatorStateStore operatorStateStore)
public JobInfo getJobInfo()
RuntimeContext
JobInfo
of this process function.getJobInfo
in interface RuntimeContext
public TaskInfo getTaskInfo()
RuntimeContext
TaskInfo
of this process function.getTaskInfo
in interface RuntimeContext
public DefaultStateManager getStateManager()
PartitionedContext
StateManager
of this process function.getStateManager
in interface PartitionedContext
public ProcessingTimeManager getProcessingTimeManager()
PartitionedContext
ProcessingTimeManager
of this process function.getProcessingTimeManager
in interface PartitionedContext
public MetricGroup getMetricGroup()
RuntimeContext
getMetricGroup
in interface RuntimeContext
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.