|
Pull Up Attribute private nullSafe : boolean from class org.apache.flink.table.runtime.join.stream.StreamingJoinOperator to private nullSafe : boolean from class org.apache.flink.table.runtime.join.stream.AbstractStreamingJoinOperator |
From |
To |
|
Pull Up Attribute private stateCleaningEnabled : boolean from class org.apache.flink.table.runtime.join.stream.StreamingJoinOperator to protected stateCleaningEnabled : boolean from class org.apache.flink.table.runtime.join.stream.AbstractStreamingJoinOperator |
From |
To |
|
Pull Up Attribute private filterAllNulls : boolean from class org.apache.flink.table.runtime.join.stream.StreamingJoinOperator to private filterAllNulls : boolean from class org.apache.flink.table.runtime.join.stream.AbstractStreamingJoinOperator |
From |
To |
|
Pull Up Attribute private joinCondition : JoinCondition from class org.apache.flink.table.runtime.join.stream.StreamingJoinOperator to protected joinCondition : JoinCondition from class org.apache.flink.table.runtime.join.stream.AbstractStreamingJoinOperator |
From |
To |
|
Pull Up Attribute private leftType : BaseRowTypeInfo from class org.apache.flink.table.runtime.join.stream.StreamingJoinOperator to protected leftType : BaseRowTypeInfo from class org.apache.flink.table.runtime.join.stream.AbstractStreamingJoinOperator |
From |
To |
|
Pull Up Attribute private rightInputSideSpec : JoinInputSideSpec from class org.apache.flink.table.runtime.join.stream.StreamingJoinOperator to protected rightInputSideSpec : JoinInputSideSpec from class org.apache.flink.table.runtime.join.stream.AbstractStreamingJoinOperator |
From |
To |
|
Pull Up Attribute private generatedJoinCondition : GeneratedJoinCondition from class org.apache.flink.table.runtime.join.stream.StreamingJoinOperator to private generatedJoinCondition : GeneratedJoinCondition from class org.apache.flink.table.runtime.join.stream.AbstractStreamingJoinOperator |
From |
To |
|
Pull Up Attribute private minRetentionTime : long from class org.apache.flink.table.runtime.join.stream.StreamingJoinOperator to protected minRetentionTime : long from class org.apache.flink.table.runtime.join.stream.AbstractStreamingJoinOperator |
From |
To |
|
Pull Up Attribute private leftInputSideSpec : JoinInputSideSpec from class org.apache.flink.table.runtime.join.stream.StreamingJoinOperator to protected leftInputSideSpec : JoinInputSideSpec from class org.apache.flink.table.runtime.join.stream.AbstractStreamingJoinOperator |
From |
To |
|
Pull Up Attribute private nullFilterKeys : int[] from class org.apache.flink.table.runtime.join.stream.StreamingJoinOperator to private nullFilterKeys : int[] from class org.apache.flink.table.runtime.join.stream.AbstractStreamingJoinOperator |
From |
To |
|
Pull Up Attribute private rightType : BaseRowTypeInfo from class org.apache.flink.table.runtime.join.stream.StreamingJoinOperator to protected rightType : BaseRowTypeInfo from class org.apache.flink.table.runtime.join.stream.AbstractStreamingJoinOperator |
From |
To |
|
Pull Up Attribute private collector : TimestampedCollector<BaseRow> from class org.apache.flink.table.runtime.join.stream.StreamingJoinOperator to protected collector : TimestampedCollector<BaseRow> from class org.apache.flink.table.runtime.join.stream.AbstractStreamingJoinOperator |
From |
To |