|
Rename Method public flatMap1(value Integer, ctx Context, out Collector<String>) : void renamed to public processElement1(value Integer, ctx Context, out Collector<String>) : void in class org.apache.flink.streaming.api.operators.co.CoProcessOperatorTest.ProcessingTimeQueryingProcessFunction |
From |
To |
|
Rename Method public flatMap2(value String, ctx Context, out Collector<String>) : void renamed to public processElement2(value String, ctx Context, out Collector<String>) : void in class org.apache.flink.streaming.api.operators.co.CoProcessOperatorTest.WatermarkQueryingProcessFunction |
From |
To |
|
Rename Method public flatMap2(value String, ctx Context, out Collector<String>) : void renamed to public processElement2(value String, ctx Context, out Collector<String>) : void in class org.apache.flink.streaming.api.operators.co.CoProcessOperatorTest.EventTimeTriggeringStatefulProcessFunction |
From |
To |
|
Rename Method public flatMap2(value String, ctx Context, out Collector<String>) : void renamed to public processElement2(value String, ctx Context, out Collector<String>) : void in class org.apache.flink.streaming.api.operators.co.CoProcessOperatorTest.ProcessingTimeTriggeringProcessFunction |
From |
To |
|
Rename Method public flatMap1(value Integer, ctx Context, out Collector<String>) : void renamed to public processElement1(value Integer, ctx Context, out Collector<String>) : void in class org.apache.flink.streaming.api.operators.co.CoProcessOperatorTest.EventTimeTriggeringProcessFunction |
From |
To |
|
Rename Method public flatMap1(value Integer, ctx Context, out Collector<String>) : void renamed to public processElement1(value Integer, ctx Context, out Collector<String>) : void in class org.apache.flink.streaming.api.operators.co.CoProcessOperatorTest.ProcessingTimeTriggeringProcessFunction |
From |
To |
|
Rename Method public flatMap2(value String, ctx Context, out Collector<String>) : void renamed to public processElement2(value String, ctx Context, out Collector<String>) : void in class org.apache.flink.streaming.api.operators.co.CoProcessOperatorTest.BothTriggeringProcessFunction |
From |
To |
|
Rename Method public testTimelyFlatMapTranslation() : void renamed to public testProcessTranslation() : void in class org.apache.flink.streaming.api.DataStreamTest |
From |
To |
|
Rename Method public flatMap(coFlatMapper TimelyCoFlatMapFunction<IN1,IN2,R>, outputType TypeInformation<R>) : SingleOutputStreamOperator<R> renamed to public process(coProcessFunction CoProcessFunction<IN1,IN2,R>, outputType TypeInformation<R>) : SingleOutputStreamOperator<R> in class org.apache.flink.streaming.api.datastream.ConnectedStreams |
From |
To |
|
Rename Method public flatMap(value Integer, ctx Context, out Collector<Integer>) : void renamed to public processElement(value Integer, ctx Context, out Collector<Integer>) : void in class org.apache.flink.streaming.api.operators.ProcessOperatorTest.TriggeringFlatMapFunction |
From |
To |
|
Rename Method public flatMap1(value Integer, ctx Context, out Collector<String>) : void renamed to public processElement1(value Integer, ctx Context, out Collector<String>) : void in class org.apache.flink.streaming.api.operators.co.CoProcessOperatorTest.BothTriggeringProcessFunction |
From |
To |
|
Rename Method public flatMap2(value String, ctx Context, out Collector<String>) : void renamed to public processElement2(value String, ctx Context, out Collector<String>) : void in class org.apache.flink.streaming.api.operators.co.CoProcessOperatorTest.EventTimeTriggeringProcessFunction |
From |
To |
|
Rename Method public flatMap(value Integer, ctx Context, out Collector<String>) : void renamed to public processElement(value Integer, ctx Context, out Collector<String>) : void in class org.apache.flink.streaming.api.operators.ProcessOperatorTest.TriggeringStatefulFlatMapFunction |
From |
To |
|
Rename Method public flatMap(value Integer, ctx Context, out Collector<String>) : void renamed to public processElement(value Integer, ctx Context, out Collector<String>) : void in class org.apache.flink.streaming.api.operators.ProcessOperatorTest.BothTriggeringFlatMapFunction |
From |
To |
|
Rename Method public flatMap1(value Integer, ctx Context, out Collector<String>) : void renamed to public processElement1(value Integer, ctx Context, out Collector<String>) : void in class org.apache.flink.streaming.api.operators.co.CoProcessOperatorTest.WatermarkQueryingProcessFunction |
From |
To |
|
Rename Method public flatMap2(value String, ctx Context, out Collector<String>) : void renamed to public processElement2(value String, ctx Context, out Collector<String>) : void in class org.apache.flink.streaming.api.operators.co.CoProcessOperatorTest.ProcessingTimeTriggeringStatefulProcessFunction |
From |
To |
|
Rename Method public flatMap1(value Integer, ctx Context, out Collector<String>) : void renamed to public processElement1(value Integer, ctx Context, out Collector<String>) : void in class org.apache.flink.streaming.api.operators.co.CoProcessOperatorTest.EventTimeTriggeringStatefulProcessFunction |
From |
To |
|
Rename Method public flatMap(flatMapper TimelyFlatMapFunction<T,R>, outputType TypeInformation<R>) : SingleOutputStreamOperator<R> renamed to public process(processFunction ProcessFunction<T,R>, outputType TypeInformation<R>) : SingleOutputStreamOperator<R> in class org.apache.flink.streaming.api.datastream.KeyedStream |
From |
To |
|
Rename Method public flatMap(value Integer, ctx Context, out Collector<String>) : void renamed to public processElement(value Integer, ctx Context, out Collector<String>) : void in class org.apache.flink.streaming.api.operators.ProcessOperatorTest.QueryingFlatMapFunction |
From |
To |
|
Rename Method public flatMap1(value Integer, ctx Context, out Collector<String>) : void renamed to public processElement1(value Integer, ctx Context, out Collector<String>) : void in class org.apache.flink.streaming.api.operators.co.CoProcessOperatorTest.ProcessingTimeTriggeringStatefulProcessFunction |
From |
To |
|
Rename Method public flatMap2(value String, ctx Context, out Collector<String>) : void renamed to public processElement2(value String, ctx Context, out Collector<String>) : void in class org.apache.flink.streaming.api.operators.co.CoProcessOperatorTest.ProcessingTimeQueryingProcessFunction |
From |
To |
|
Change Parameter Type flatMapper : TimelyCoFlatMapFunction<IN1,IN2,OUT> to flatMapper : CoProcessFunction<IN1,IN2,OUT> in method public CoProcessOperator(flatMapper CoProcessFunction<IN1,IN2,OUT>) in class org.apache.flink.streaming.api.operators.co.CoProcessOperator |
From |
To |
|
Change Parameter Type flatMapper : TimelyFlatMapFunction<IN,OUT> to flatMapper : ProcessFunction<IN,OUT> in method public ProcessOperator(flatMapper ProcessFunction<IN,OUT>) in class org.apache.flink.streaming.api.operators.ProcessOperator |
From |
To |
|
Change Parameter Type coFlatMapper : TimelyCoFlatMapFunction<IN1,IN2,R> to coProcessFunction : CoProcessFunction<IN1,IN2,R> in method public process(coProcessFunction CoProcessFunction<IN1,IN2,R>, outputType TypeInformation<R>) : SingleOutputStreamOperator<R> in class org.apache.flink.streaming.api.datastream.ConnectedStreams |
From |
To |
|
Change Parameter Type flatMapper : TimelyFlatMapFunction<T,R> to processFunction : ProcessFunction<T,R> in method public process(processFunction ProcessFunction<T,R>, outputType TypeInformation<R>) : SingleOutputStreamOperator<R> in class org.apache.flink.streaming.api.datastream.KeyedStream |
From |
To |
|
Change Variable Type operator : StreamTimelyFlatMap<KEY,T,R> to operator : ProcessOperator<KEY,T,R> in method public process(processFunction ProcessFunction<T,R>, outputType TypeInformation<R>) : SingleOutputStreamOperator<R> in class org.apache.flink.streaming.api.datastream.KeyedStream |
From |
To |
|
Change Variable Type operator : CoStreamTimelyFlatMap<String,Integer,String,String> to operator : CoProcessOperator<String,Integer,String,String> in method public testProcessingTimeTimerWithState() : void in class org.apache.flink.streaming.api.operators.co.CoProcessOperatorTest |
From |
To |
|
Change Variable Type operator : CoStreamTimelyFlatMap<String,Integer,String,String> to operator : CoProcessOperator<String,Integer,String,String> in method public testProcessingTimeTimers() : void in class org.apache.flink.streaming.api.operators.co.CoProcessOperatorTest |
From |
To |
|
Change Variable Type operator : CoStreamTimelyFlatMap<String,Integer,String,String> to operator : CoProcessOperator<String,Integer,String,String> in method public testEventTimeTimerWithState() : void in class org.apache.flink.streaming.api.operators.co.CoProcessOperatorTest |
From |
To |
|
Change Variable Type operator : CoStreamTimelyFlatMap<String,Integer,String,String> to operator : CoProcessOperator<String,Integer,String,String> in method public testSnapshotAndRestore() : void in class org.apache.flink.streaming.api.operators.co.CoProcessOperatorTest |
From |
To |
|
Change Variable Type operator : CoStreamTimelyFlatMap<String,Integer,String,String> to operator : CoProcessOperator<String,Integer,String,String> in method public testEventTimeTimers() : void in class org.apache.flink.streaming.api.operators.co.CoProcessOperatorTest |
From |
To |
|
Change Variable Type operator : StreamTimelyFlatMap<Integer,Integer,String> to operator : ProcessOperator<Integer,Integer,String> in method public testTimestampAndWatermarkQuerying() : void in class org.apache.flink.streaming.api.operators.ProcessOperatorTest |
From |
To |
|
Change Variable Type operator : StreamTimelyFlatMap<Integer,Integer,String> to operator : ProcessOperator<Integer,Integer,String> in method public testSnapshotAndRestore() : void in class org.apache.flink.streaming.api.operators.ProcessOperatorTest |
From |
To |
|
Change Variable Type operator : CoStreamTimelyFlatMap<String,Integer,String,String> to operator : CoProcessOperator<String,Integer,String,String> in method public testTimestampAndWatermarkQuerying() : void in class org.apache.flink.streaming.api.operators.co.CoProcessOperatorTest |
From |
To |
|
Change Variable Type operator : CoStreamTimelyFlatMap<Object,IN1,IN2,R> to operator : CoProcessOperator<Object,IN1,IN2,R> in method public process(coProcessFunction CoProcessFunction<IN1,IN2,R>, outputType TypeInformation<R>) : SingleOutputStreamOperator<R> in class org.apache.flink.streaming.api.datastream.ConnectedStreams |
From |
To |
|
Change Variable Type operator : StreamTimelyFlatMap<Integer,Integer,Integer> to operator : ProcessOperator<Integer,Integer,Integer> in method public testProcessingTimeTimers() : void in class org.apache.flink.streaming.api.operators.ProcessOperatorTest |
From |
To |
|
Change Variable Type operator : CoStreamTimelyFlatMap<String,Integer,String,String> to operator : CoProcessOperator<String,Integer,String,String> in method public testTimestampAndProcessingTimeQuerying() : void in class org.apache.flink.streaming.api.operators.co.CoProcessOperatorTest |
From |
To |
|
Change Variable Type operator : StreamTimelyFlatMap<Integer,Integer,String> to operator : ProcessOperator<Integer,Integer,String> in method public testProcessingTimeTimerWithState() : void in class org.apache.flink.streaming.api.operators.ProcessOperatorTest |
From |
To |
|
Change Variable Type timelyFlatMapFunction : TimelyFlatMapFunction<Long,Integer> to processFunction : ProcessFunction<Long,Integer> in method public testProcessTranslation() : void in class org.apache.flink.streaming.api.DataStreamTest |
From |
To |
|
Change Variable Type operator : StreamTimelyFlatMap<Integer,Integer,Integer> to operator : ProcessOperator<Integer,Integer,Integer> in method public testEventTimeTimers() : void in class org.apache.flink.streaming.api.operators.ProcessOperatorTest |
From |
To |
|
Change Variable Type operator : StreamTimelyFlatMap<Integer,Integer,String> to operator : ProcessOperator<Integer,Integer,String> in method public testTimestampAndProcessingTimeQuerying() : void in class org.apache.flink.streaming.api.operators.ProcessOperatorTest |
From |
To |
|
Change Variable Type operator : StreamTimelyFlatMap<Integer,Integer,String> to operator : ProcessOperator<Integer,Integer,String> in method public testEventTimeTimerWithState() : void in class org.apache.flink.streaming.api.operators.ProcessOperatorTest |
From |
To |