Package org.apache.flink.table.runtime.operators.join.stream.utils
-
Class Summary Class Description AssociatedRecords TheAssociatedRecordsis the records associated to the input row.JoinHelper<STATE_VIEW,OUTER_STATE_VIEW extends STATE_VIEW> A helper to do the logic of streaming join.JoinInputSideSpec TheJoinInputSideSpecis ap specification which describes input side information of a Join.OuterRecord AnOuterRecordis a composite of record andnumOfAssociations.