Uses of Interface
org.apache.flink.streaming.api.operators.TwoInputStreamOperator

Packages that use TwoInputStreamOperator

Package	Description
org.apache.flink.streaming.api.datastream
org.apache.flink.streaming.api.graph
org.apache.flink.streaming.api.operators.co
org.apache.flink.streaming.api.transformations
org.apache.flink.streaming.runtime.io

Uses of TwoInputStreamOperator in org.apache.flink.streaming.api.datastream

Methods in org.apache.flink.streaming.api.datastream with parameters of type TwoInputStreamOperator

Modifier and Type	Method and Description
<R> SingleOutputStreamOperator<R>	ConnectedStreams.transform(String functionName, org.apache.flink.api.common.typeinfo.TypeInformation<R> outTypeInfo, TwoInputStreamOperator<IN1,IN2,R> operator)

Uses of TwoInputStreamOperator in org.apache.flink.streaming.api.graph

Methods in org.apache.flink.streaming.api.graph with parameters of type TwoInputStreamOperator

Modifier and Type	Method and Description
<IN1,IN2,OUT> void	StreamGraph.addCoOperator(Integer vertexID, String slotSharingGroup, String coLocationGroup, TwoInputStreamOperator<IN1,IN2,OUT> taskOperatorObject, org.apache.flink.api.common.typeinfo.TypeInformation<IN1> in1TypeInfo, org.apache.flink.api.common.typeinfo.TypeInformation<IN2> in2TypeInfo, org.apache.flink.api.common.typeinfo.TypeInformation<OUT> outTypeInfo, String operatorName)

Uses of TwoInputStreamOperator in org.apache.flink.streaming.api.operators.co

Classes in org.apache.flink.streaming.api.operators.co that implement TwoInputStreamOperator

Modifier and Type	Class and Description
class	CoBroadcastWithKeyedOperator<KS,IN1,IN2,OUT> A TwoInputStreamOperator for executing KeyedBroadcastProcessFunctions.
class	CoBroadcastWithNonKeyedOperator<IN1,IN2,OUT> A TwoInputStreamOperator for executing BroadcastProcessFunctions.
class	CoProcessOperator<IN1,IN2,OUT> A StreamOperator for executing CoProcessFunctions.
class	CoStreamFlatMap<IN1,IN2,OUT> StreamOperator for processing CoFlatMapFunctions.
class	CoStreamMap<IN1,IN2,OUT> StreamOperator for processing CoMapFunctions.
class	IntervalJoinOperator<K,T1,T2,OUT> An operator to execute time-bounded stream inner joins.
class	KeyedCoProcessOperator<K,IN1,IN2,OUT> A StreamOperator for executing keyed CoProcessFunctions.

Uses of TwoInputStreamOperator in org.apache.flink.streaming.api.transformations

Methods in org.apache.flink.streaming.api.transformations that return TwoInputStreamOperator

Modifier and Type	Method and Description
TwoInputStreamOperator<IN1,IN2,OUT>	TwoInputTransformation.getOperator() Returns the TwoInputStreamOperator of this Transformation.

Constructors in org.apache.flink.streaming.api.transformations with parameters of type TwoInputStreamOperator

Constructor and Description
TwoInputTransformation(StreamTransformation<IN1> input1, StreamTransformation<IN2> input2, String name, TwoInputStreamOperator<IN1,IN2,OUT> operator, org.apache.flink.api.common.typeinfo.TypeInformation<OUT> outputType, int parallelism) Creates a new TwoInputTransformation from the given inputs and operator.

Uses of TwoInputStreamOperator in org.apache.flink.streaming.runtime.io

Constructors in org.apache.flink.streaming.runtime.io with parameters of type TwoInputStreamOperator

Constructor and Description

StreamTwoInputProcessor(Collection<org.apache.flink.runtime.io.network.partition.consumer.InputGate> inputGates1, Collection<org.apache.flink.runtime.io.network.partition.consumer.InputGate> inputGates2, org.apache.flink.api.common.typeutils.TypeSerializer<IN1> inputSerializer1, org.apache.flink.api.common.typeutils.TypeSerializer<IN2> inputSerializer2, TwoInputStreamTask<IN1,IN2,?> checkpointedTask, CheckpointingMode checkpointMode, Object lock, org.apache.flink.runtime.io.disk.iomanager.IOManager ioManager, org.apache.flink.configuration.Configuration taskManagerConfig, StreamStatusMaintainer streamStatusMaintainer, TwoInputStreamOperator<IN1,IN2,?> streamOperator, org.apache.flink.runtime.metrics.groups.TaskIOMetricGroup metrics, WatermarkGauge input1WatermarkGauge, WatermarkGauge input2WatermarkGauge)