Uses of Class
org.apache.flink.table.runtime.operators.join.temporal.BaseTwoInputStreamOperatorWithStateRetention
-
Packages that use BaseTwoInputStreamOperatorWithStateRetention Package Description org.apache.flink.table.runtime.operators.join.temporal -
-
Uses of BaseTwoInputStreamOperatorWithStateRetention in org.apache.flink.table.runtime.operators.join.temporal
Subclasses of BaseTwoInputStreamOperatorWithStateRetention in org.apache.flink.table.runtime.operators.join.temporal Modifier and Type Class Description class
TemporalProcessTimeJoinOperator
The operator to temporal join a stream on processing time.class
TemporalRowTimeJoinOperator
The operator for temporal join (FOR SYSTEM_TIME AS OF o.rowtime) on row time, it has no limitation about message types of the left input and right input, this means the operator deals changelog well.
-