|
Change Parameter Type otherBuffer : MapState<Long,List<BufferEntry<OTHER>>> to otherBuffer : MapState<Long,List<IntervalJoinOperator.BufferEntry<OTHER>>> in method private processElement(record StreamRecord<THIS>, ourBuffer MapState<Long,List<IntervalJoinOperator.BufferEntry<THIS>>>, otherBuffer MapState<Long,List<IntervalJoinOperator.BufferEntry<OTHER>>>, relativeLowerBound long, relativeUpperBound long, isLeft boolean) : void in class org.apache.flink.streaming.api.operators.co.IntervalJoinOperator |
From |
To |
|
Change Parameter Type record : StreamRecord<OUR> to record : StreamRecord<THIS> in method private processElement(record StreamRecord<THIS>, ourBuffer MapState<Long,List<IntervalJoinOperator.BufferEntry<THIS>>>, otherBuffer MapState<Long,List<IntervalJoinOperator.BufferEntry<OTHER>>>, relativeLowerBound long, relativeUpperBound long, isLeft boolean) : void in class org.apache.flink.streaming.api.operators.co.IntervalJoinOperator |
From |
To |
|
Change Parameter Type ourBuffer : MapState<Long,List<BufferEntry<OUR>>> to ourBuffer : MapState<Long,List<IntervalJoinOperator.BufferEntry<THIS>>> in method private processElement(record StreamRecord<THIS>, ourBuffer MapState<Long,List<IntervalJoinOperator.BufferEntry<THIS>>>, otherBuffer MapState<Long,List<IntervalJoinOperator.BufferEntry<OTHER>>>, relativeLowerBound long, relativeUpperBound long, isLeft boolean) : void in class org.apache.flink.streaming.api.operators.co.IntervalJoinOperator |
From |
To |
|
Change Parameter Type buffer : MapState<Long,List<BufferEntry<T>>> to buffer : MapState<Long,List<IntervalJoinOperator.BufferEntry<T>>> in method private addToBuffer(buffer MapState<Long,List<IntervalJoinOperator.BufferEntry<T>>>, value T, timestamp long) : void in class org.apache.flink.streaming.api.operators.co.IntervalJoinOperator |
From |
To |