|
Change Parameter Type operator : TimeBoundedStreamJoinOperator<String,TestElem,TestElem,Tuple2<TestElem,TestElem>> to operator : IntervalJoinOperator<String,TestElem,TestElem,Tuple2<TestElem,TestElem>> in method public JoinTestBuilder(t TestHarness, operator IntervalJoinOperator<String,TestElem,TestElem,Tuple2<TestElem,TestElem>>) in class org.apache.flink.streaming.api.operators.co.IntervalJoinOperatorTest.JoinTestBuilder |
From |
To |
|
Change Parameter Type func : TimeBoundedJoinFunction<T1,T2,OUT> to func : ProcessJoinFunction<T1,T2,OUT> in method private ContextImpl(func ProcessJoinFunction<T1,T2,OUT>) in class org.apache.flink.streaming.api.operators.co.IntervalJoinOperator.ContextImpl |
From |
To |
|
Change Parameter Type udf : TimeBoundedJoinFunction<T1,T2,OUT> to udf : ProcessJoinFunction<T1,T2,OUT> in method public IntervalJoinOperator(lowerBound long, upperBound long, lowerBoundInclusive boolean, upperBoundInclusive boolean, leftTypeSerializer TypeSerializer<T1>, rightTypeSerializer TypeSerializer<T2>, udf ProcessJoinFunction<T1,T2,OUT>) in class org.apache.flink.streaming.api.operators.co.IntervalJoinOperator |
From |
To |
|
Change Variable Type op : TimeBoundedStreamJoinOperator<String,TestElem,TestElem,Tuple2<TestElem,TestElem>> to op : IntervalJoinOperator<String,TestElem,TestElem,Tuple2<TestElem,TestElem>> in method public testContextCorrectRightTimestamp() : void in class org.apache.flink.streaming.api.operators.co.IntervalJoinOperatorTest |
From |
To |
|
Change Variable Type operator : TimeBoundedStreamJoinOperator<String,TestElem,TestElem,Tuple2<TestElem,TestElem>> to operator : IntervalJoinOperator<String,TestElem,TestElem,Tuple2<TestElem,TestElem>> in method private setupHarness(lowerBound long, lowerBoundInclusive boolean, upperBound long, upperBoundInclusive boolean) : JoinTestBuilder in class org.apache.flink.streaming.api.operators.co.IntervalJoinOperatorTest |
From |
To |
|
Change Variable Type op : TimeBoundedStreamJoinOperator<String,TestElem,TestElem,Tuple2<TestElem,TestElem>> to op : IntervalJoinOperator<String,TestElem,TestElem,Tuple2<TestElem,TestElem>> in method public testReturnsCorrectTimestamp() : void in class org.apache.flink.streaming.api.operators.co.IntervalJoinOperatorTest |
From |
To |
|
Change Variable Type op : TimeBoundedStreamJoinOperator<String,TestElem,TestElem,Tuple2<TestElem,TestElem>> to op : IntervalJoinOperator<String,TestElem,TestElem,Tuple2<TestElem,TestElem>> in method public testContextCorrectLeftTimestamp() : void in class org.apache.flink.streaming.api.operators.co.IntervalJoinOperatorTest |
From |
To |
|
Change Variable Type operator : TimeBoundedStreamJoinOperator<String,TestElem,TestElem,Tuple2<TestElem,TestElem>> to operator : IntervalJoinOperator<String,TestElem,TestElem,Tuple2<TestElem,TestElem>> in method private createTestHarness(lowerBound long, lowerBoundInclusive boolean, upperBound long, upperBoundInclusive boolean) : TestHarness in class org.apache.flink.streaming.api.operators.co.IntervalJoinOperatorTest |
From |
To |