|
Change Parameter Type timeStamp : TimeStamp<DATA> to timestampWrapper : TimestampWrapper<DATA> in method private Time(length long, timeUnit TimeUnit, timestampWrapper TimestampWrapper<DATA>) in class org.apache.flink.streaming.api.windowing.helper.Time |
From |
To |
|
Change Parameter Type timestamp2 : TimeStamp<IN2> to timestamp2 : TimestampWrapper<IN2> in method public addGeneralWindowCombine(coWindowFunction CoWindowFunction<IN1,IN2,OUT>, outTypeInfo TypeInformation<OUT>, windowSize long, slideInterval long, timestamp1 TimestampWrapper<IN1>, timestamp2 TimestampWrapper<IN2>) : SingleOutputStreamOperator<OUT,?> in class org.apache.flink.streaming.api.datastream.ConnectedDataStream |
From |
To |
|
Change Parameter Type timestamp1 : TimeStamp<IN1> to timestamp1 : TimestampWrapper<IN1> in method public addGeneralWindowCombine(coWindowFunction CoWindowFunction<IN1,IN2,OUT>, outTypeInfo TypeInformation<OUT>, windowSize long, slideInterval long, timestamp1 TimestampWrapper<IN1>, timestamp2 TimestampWrapper<IN2>) : SingleOutputStreamOperator<OUT,?> in class org.apache.flink.streaming.api.datastream.ConnectedDataStream |
From |
To |
|
Change Parameter Type timestamp2 : TimeStamp<IN2> to timestamp2 : TimestampWrapper<IN2> in method public CoGroupedWindowReduceInvokable(coReducer CoReduceFunction<IN1,IN2,OUT>, windowSize1 long, windowSize2 long, slideInterval1 long, slideInterval2 long, keySelector1 KeySelector<IN1,?>, keySelector2 KeySelector<IN2,?>, timestamp1 TimestampWrapper<IN1>, timestamp2 TimestampWrapper<IN2>) in class org.apache.flink.streaming.api.invokable.operator.co.CoGroupedWindowReduceInvokable |
From |
To |
|
Change Parameter Type timestamp1 : TimeStamp<IN1> to timestamp1 : TimestampWrapper<IN1> in method public CoGroupedWindowReduceInvokable(coReducer CoReduceFunction<IN1,IN2,OUT>, windowSize1 long, windowSize2 long, slideInterval1 long, slideInterval2 long, keySelector1 KeySelector<IN1,?>, keySelector2 KeySelector<IN2,?>, timestamp1 TimestampWrapper<IN1>, timestamp2 TimestampWrapper<IN2>) in class org.apache.flink.streaming.api.invokable.operator.co.CoGroupedWindowReduceInvokable |
From |
To |
|
Change Parameter Type timeStamp2 : TimeStamp<I2> to timeStamp2 : TimestampWrapper<I2> in method public onWindow(windowSize long, slideInterval long, timeStamp1 TimestampWrapper<I1>, timeStamp2 TimestampWrapper<I2>) : OP in class org.apache.flink.streaming.api.datastream.TemporalOperator |
From |
To |
|
Change Parameter Type timestamp1 : TimeStamp<IN1> to timestamp1 : TimestampWrapper<IN1> in method public CoWindowReduceInvokable(coReducer CoReduceFunction<IN1,IN2,OUT>, windowSize1 long, windowSize2 long, slideInterval1 long, slideInterval2 long, timestamp1 TimestampWrapper<IN1>, timestamp2 TimestampWrapper<IN2>) in class org.apache.flink.streaming.api.invokable.operator.co.CoWindowReduceInvokable |
From |
To |
|
Change Parameter Type timestamp2 : TimeStamp<IN2> to timestamp2 : TimestampWrapper<IN2> in method public CoWindowReduceInvokable(coReducer CoReduceFunction<IN1,IN2,OUT>, windowSize1 long, windowSize2 long, slideInterval1 long, slideInterval2 long, timestamp1 TimestampWrapper<IN1>, timestamp2 TimestampWrapper<IN2>) in class org.apache.flink.streaming.api.invokable.operator.co.CoWindowReduceInvokable |
From |
To |
|
Change Parameter Type timestamp : TimeStamp<DATA> to timestampWrapper : TimestampWrapper<DATA> in method public TimeTriggerPolicy(granularity long, timestampWrapper TimestampWrapper<DATA>) in class org.apache.flink.streaming.api.windowing.policy.TimeTriggerPolicy |
From |
To |
|
Change Parameter Type timeStamp2 : TimeStamp<IN2> to timeStamp2 : TimestampWrapper<IN2> in method public CoWindowInvokable(coWindowFunction CoWindowFunction<IN1,IN2,OUT>, windowSize long, slideInterval long, timeStamp1 TimestampWrapper<IN1>, timeStamp2 TimestampWrapper<IN2>) in class org.apache.flink.streaming.api.invokable.operator.co.CoWindowInvokable |
From |
To |
|
Change Parameter Type timeStamp1 : TimeStamp<IN1> to timeStamp1 : TimestampWrapper<IN1> in method public CoWindowInvokable(coWindowFunction CoWindowFunction<IN1,IN2,OUT>, windowSize long, slideInterval long, timeStamp1 TimestampWrapper<IN1>, timeStamp2 TimestampWrapper<IN2>) in class org.apache.flink.streaming.api.invokable.operator.co.CoWindowInvokable |
From |
To |
|
Change Parameter Type timeStamp1 : TimeStamp<IN1> to timeStamp1 : TimestampWrapper<IN1> in method protected CoWindowDataStream(dataStream1 DataStream<IN1>, dataStream2 DataStream<IN2>, windowSize1 long, windowSize2 long, slideInterval1 long, slideInterval2 long, timeStamp1 TimestampWrapper<IN1>, timeStamp2 TimestampWrapper<IN2>) in class org.apache.flink.streaming.api.datastream.CoWindowDataStream |
From |
To |
|
Change Parameter Type timeStamp2 : TimeStamp<IN2> to timeStamp2 : TimestampWrapper<IN2> in method protected CoWindowDataStream(dataStream1 DataStream<IN1>, dataStream2 DataStream<IN2>, windowSize1 long, windowSize2 long, slideInterval1 long, slideInterval2 long, timeStamp1 TimestampWrapper<IN1>, timeStamp2 TimestampWrapper<IN2>) in class org.apache.flink.streaming.api.datastream.CoWindowDataStream |
From |
To |
|
Change Parameter Type timestamp : TimeStamp<DATA> to timestampWrapper : TimestampWrapper<DATA> in method public TimeEvictionPolicy(granularity long, timestampWrapper TimestampWrapper<DATA>) in class org.apache.flink.streaming.api.windowing.policy.TimeEvictionPolicy |
From |
To |
|
Change Parameter Type timestamp : TimeStamp<DATA> to timestampWrapper : TimestampWrapper<DATA> in method public TimeTriggerPolicy(granularity long, timestampWrapper TimestampWrapper<DATA>, delay long) in class org.apache.flink.streaming.api.windowing.policy.TimeTriggerPolicy |
From |
To |
|
Change Parameter Type timeStamp1 : TimeStamp<I1> to timeStamp1 : TimestampWrapper<I1> in method public onWindow(windowSize long, slideInterval long, timeStamp1 TimestampWrapper<I1>, timeStamp2 TimestampWrapper<I2>) : OP in class org.apache.flink.streaming.api.datastream.TemporalOperator |
From |
To |
|
Change Parameter Type timeStamp2 : TimeStamp<IN2> to timeStamp2 : TimestampWrapper<IN2> in method public window(windowSize1 long, windowSize2 long, slideInterval1 long, slideInterval2 long, timeStamp1 TimestampWrapper<IN1>, timeStamp2 TimestampWrapper<IN2>) : CoWindowDataStream<IN1,IN2> in class org.apache.flink.streaming.api.datastream.ConnectedDataStream |
From |
To |
|
Change Parameter Type timeStamp1 : TimeStamp<IN1> to timeStamp1 : TimestampWrapper<IN1> in method public window(windowSize1 long, windowSize2 long, slideInterval1 long, slideInterval2 long, timeStamp1 TimestampWrapper<IN1>, timeStamp2 TimestampWrapper<IN2>) : CoWindowDataStream<IN1,IN2> in class org.apache.flink.streaming.api.datastream.ConnectedDataStream |
From |
To |
|
Change Parameter Type timestamp1 : TimeStamp<IN1> to timestamp1 : TimestampWrapper<IN1> in method public windowReduce(coWindowFunction CoWindowFunction<IN1,IN2,OUT>, windowSize long, slideInterval long, timestamp1 TimestampWrapper<IN1>, timestamp2 TimestampWrapper<IN2>) : SingleOutputStreamOperator<OUT,?> in class org.apache.flink.streaming.api.datastream.ConnectedDataStream |
From |
To |
|
Change Parameter Type timestamp2 : TimeStamp<IN2> to timestamp2 : TimestampWrapper<IN2> in method public windowReduce(coWindowFunction CoWindowFunction<IN1,IN2,OUT>, windowSize long, slideInterval long, timestamp1 TimestampWrapper<IN1>, timestamp2 TimestampWrapper<IN2>) : SingleOutputStreamOperator<OUT,?> in class org.apache.flink.streaming.api.datastream.ConnectedDataStream |
From |
To |
|
Change Parameter Type timeStamp1 : TimeStamp<IN1> to timeStamp1 : TimestampWrapper<IN1> in method protected CoWindowDataStream(coDataStream ConnectedDataStream<IN1,IN2>, windowSize1 long, windowSize2 long, slideInterval1 long, slideInterval2 long, timeStamp1 TimestampWrapper<IN1>, timeStamp2 TimestampWrapper<IN2>) in class org.apache.flink.streaming.api.datastream.CoWindowDataStream |
From |
To |
|
Change Parameter Type timeStamp1 : TimeStamp<IN1> to timeStamp1 : TimestampWrapper<IN1> in method public window(windowSize1 long, windowSize2 long, timeStamp1 TimestampWrapper<IN1>, timeStamp2 TimestampWrapper<IN2>) : CoWindowDataStream<IN1,IN2> in class org.apache.flink.streaming.api.datastream.ConnectedDataStream |
From |
To |
|
Change Parameter Type timeStamp2 : TimeStamp<IN2> to timeStamp2 : TimestampWrapper<IN2> in method protected CoWindowDataStream(coDataStream ConnectedDataStream<IN1,IN2>, windowSize1 long, windowSize2 long, slideInterval1 long, slideInterval2 long, timeStamp1 TimestampWrapper<IN1>, timeStamp2 TimestampWrapper<IN2>) in class org.apache.flink.streaming.api.datastream.CoWindowDataStream |
From |
To |
|
Change Parameter Type timeStamp2 : TimeStamp<IN2> to timeStamp2 : TimestampWrapper<IN2> in method public window(windowSize1 long, windowSize2 long, timeStamp1 TimestampWrapper<IN1>, timeStamp2 TimestampWrapper<IN2>) : CoWindowDataStream<IN1,IN2> in class org.apache.flink.streaming.api.datastream.ConnectedDataStream |
From |
To |