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.operators.co
org.apache.flink.streaming.api.transformations
org.apache.flink.streaming.runtime.io
org.apache.flink.table.runtime.operators.join
org.apache.flink.table.runtime.operators.join.stream
org.apache.flink.table.runtime.operators.join.temporal

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, TypeInformation<R> outTypeInfo, TwoInputStreamOperator<IN1,IN2,R> operator)

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 KeyedCoProcessFunction.
class	LegacyKeyedCoProcessOperator<K,IN1,IN2,OUT> Deprecated. Replaced by KeyedCoProcessOperator which takes KeyedCoProcessFunction

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()

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

Constructor and Description
TwoInputTransformation(Transformation<IN1> input1, Transformation<IN2> input2, String name, TwoInputStreamOperator<IN1,IN2,OUT> operator, 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<InputGate> inputGates1, Collection<InputGate> inputGates2, TypeSerializer<IN1> inputSerializer1, TypeSerializer<IN2> inputSerializer2, TwoInputStreamTask<IN1,IN2,?> checkpointedTask, CheckpointingMode checkpointMode, Object lock, IOManager ioManager, Configuration taskManagerConfig, StreamStatusMaintainer streamStatusMaintainer, TwoInputStreamOperator<IN1,IN2,?> streamOperator, TaskIOMetricGroup metrics, WatermarkGauge input1WatermarkGauge, WatermarkGauge input2WatermarkGauge, String taskName, OperatorChain<?,?> operatorChain)
StreamTwoInputSelectableProcessor(Collection<InputGate> inputGates1, Collection<InputGate> inputGates2, TypeSerializer<IN1> inputSerializer1, TypeSerializer<IN2> inputSerializer2, StreamTask<?,?> streamTask, CheckpointingMode checkpointingMode, Object lock, IOManager ioManager, Configuration taskManagerConfig, StreamStatusMaintainer streamStatusMaintainer, TwoInputStreamOperator<IN1,IN2,?> streamOperator, WatermarkGauge input1WatermarkGauge, WatermarkGauge input2WatermarkGauge, String taskName, OperatorChain<?,?> operatorChain)

Uses of TwoInputStreamOperator in org.apache.flink.table.runtime.operators.join

Classes in org.apache.flink.table.runtime.operators.join that implement TwoInputStreamOperator

Modifier and Type	Class and Description
class	HashJoinOperator Hash join base operator.
class	KeyedCoProcessOperatorWithWatermarkDelay<K,IN1,IN2,OUT> A KeyedCoProcessOperator that supports holding back watermarks with a static delay.
class	SortMergeJoinOperator An implementation that realizes the joining through a sort-merge join strategy.

Uses of TwoInputStreamOperator in org.apache.flink.table.runtime.operators.join.stream

Classes in org.apache.flink.table.runtime.operators.join.stream that implement TwoInputStreamOperator

Modifier and Type	Class and Description
class	AbstractStreamingJoinOperator Abstract implementation for streaming unbounded Join operator which defines some member fields can be shared between different implementations.
class	StreamingJoinOperator Streaming unbounded Join operator which supports INNER/LEFT/RIGHT/FULL JOIN.
class	StreamingSemiAntiJoinOperator Streaming unbounded Join operator which supports SEMI/ANTI JOIN.

Uses of TwoInputStreamOperator in org.apache.flink.table.runtime.operators.join.temporal

Classes in org.apache.flink.table.runtime.operators.join.temporal that implement TwoInputStreamOperator

Modifier and Type	Class and Description
class	BaseTwoInputStreamOperatorWithStateRetention An abstract TwoInputStreamOperator that allows its subclasses to clean up their state based on a TTL.
class	TemporalProcessTimeJoinOperator The operator to temporal join a stream on processing time.
class	TemporalRowTimeJoinOperator This operator works by keeping on the state collection of probe and build records to process on next watermark.