public class DefaultNonPartitionedContext<OUT> extends Object implements NonPartitionedContext<OUT>
NonPartitionedContext
.Constructor and Description |
---|
DefaultNonPartitionedContext(DefaultRuntimeContext context,
DefaultPartitionedContext partitionedContext,
Collector<OUT> collector,
boolean isKeyed,
Set<Object> keySet) |
Modifier and Type | Method and Description |
---|---|
void |
applyToAllPartitions(ApplyPartitionFunction<OUT> applyPartitionFunction)
Apply a function to all partitions.
|
JobInfo |
getJobInfo()
Get the
JobInfo of this process function. |
MetricGroup |
getMetricGroup()
Get the metric group of this process function.
|
TaskInfo |
getTaskInfo()
Get the
TaskInfo of this process function. |
public DefaultNonPartitionedContext(DefaultRuntimeContext context, DefaultPartitionedContext partitionedContext, Collector<OUT> collector, boolean isKeyed, Set<Object> keySet)
public void applyToAllPartitions(ApplyPartitionFunction<OUT> applyPartitionFunction) throws Exception
NonPartitionedContext
applyToAllPartitions
in interface NonPartitionedContext<OUT>
Exception
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 MetricGroup getMetricGroup()
RuntimeContext
getMetricGroup
in interface RuntimeContext
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.