org.apache.flink.datastream.impl.context

Class DefaultTwoOutputNonPartitionedContext<OUT1,OUT2>

java.lang.Object

org.apache.flink.datastream.impl.context.DefaultTwoOutputNonPartitionedContext<OUT1,OUT2>

All Implemented Interfaces:

RuntimeContext, TwoOutputNonPartitionedContext<OUT1,OUT2>

public class DefaultTwoOutputNonPartitionedContext<OUT1,OUT2>
extends Object
implements TwoOutputNonPartitionedContext<OUT1,OUT2>

The default implementation of TwoOutputNonPartitionedContext.

Field Summary

Fields

Modifier and Type	Field and Description
protected DefaultRuntimeContext	context
protected Collector<OUT1>	firstCollector
protected Collector<OUT2>	secondCollector

Constructor Summary

Constructors

Constructor and Description
DefaultTwoOutputNonPartitionedContext(DefaultRuntimeContext context, DefaultPartitionedContext partitionedContext, Collector<OUT1> firstCollector, Collector<OUT2> secondCollector, boolean isKeyed, Set<Object> keySet)

Method Summary

Modifier and Type	Method and Description
void	applyToAllPartitions(TwoOutputApplyPartitionFunction<OUT1,OUT2> 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.

Methods inherited from class java.lang.Object

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

Field Detail

context

protected final DefaultRuntimeContext context

firstCollector

protected final Collector<OUT1> firstCollector

secondCollector

protected final Collector<OUT2> secondCollector

Constructor Detail

DefaultTwoOutputNonPartitionedContext

public DefaultTwoOutputNonPartitionedContext(DefaultRuntimeContext context,
                                             DefaultPartitionedContext partitionedContext,
                                             Collector<OUT1> firstCollector,
                                             Collector<OUT2> secondCollector,
                                             boolean isKeyed,
                                             Set<Object> keySet)

Method Detail

applyToAllPartitions

public void applyToAllPartitions(TwoOutputApplyPartitionFunction<OUT1,OUT2> applyPartitionFunction)
                          throws Exception

Description copied from interface: TwoOutputNonPartitionedContext

Apply a function to all partitions. For keyed stream, it will apply to all keys. For non-keyed stream, it will apply to single partition.

Specified by:

applyToAllPartitions in interface TwoOutputNonPartitionedContext<OUT1,OUT2>

Throws:

Exception

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

getMetricGroup

public MetricGroup getMetricGroup()

Description copied from interface: RuntimeContext

Get the metric group of this process function.

Specified by:

getMetricGroup in interface RuntimeContext