|
Change Parameter Type in1 : StreamRecordSerializer<?> to in1 : TypeSerializer<?> in method private setSerializers(vertexID Integer, in1 TypeSerializer<?>, in2 TypeSerializer<?>, out TypeSerializer<?>) : void in class org.apache.flink.streaming.api.graph.StreamGraph |
From |
To |
|
Change Parameter Type record : T to record : StreamRecord<T> in method public collect(record StreamRecord<T>) : void in class org.apache.flink.streaming.api.windowing.windowbuffer.BasicWindowBufferTest.TestOutput |
From |
To |
|
Change Parameter Type outputList : List<T> to outputList : Queue<Object> in method public addOutput(outputList Queue<Object>, serializer TypeSerializer<T>) : void in class org.apache.flink.streaming.runtime.tasks.StreamMockEnvironment |
From |
To |
|
Change Parameter Type record : T to record : StreamRecord<T> in method public collect(record StreamRecord<T>) : void in class org.apache.flink.streaming.util.MockOutput |
From |
To |
|
Change Parameter Type input : IN to input : StreamRecord<IN> in method protected processRealElement(input StreamRecord<IN>) : void in class org.apache.flink.streaming.api.operators.windowing.StreamDiscretizer |
From |
To |
|
Change Parameter Type inputGates : Collection<InputGate> to inputGates : InputGate[] in method public createInputGate(inputGates InputGate[]) : InputGate in class org.apache.flink.streaming.runtime.io.InputGateUtil |
From |
To |
|
Change Parameter Type element : IN1 to element : StreamRecord<IN1> in method public processElement1(element StreamRecord<IN1>) : void in class org.apache.flink.streaming.api.operators.co.CoStreamReduce |
From |
To |
|
Change Parameter Type collector : Collector<StreamWindow<T>> to collector : Collector<StreamRecord<StreamWindow<T>>> in method public emitWindow(collector Collector<StreamRecord<StreamWindow<T>>>) : void in class org.apache.flink.streaming.api.windowing.windowbuffer.JumpingCountGroupedPreReducer |
From |
To |
|
Change Parameter Type element : IN to element : StreamRecord<IN> in method public processElement(element StreamRecord<IN>) : void in class org.apache.flink.streaming.api.operators.StreamSink |
From |
To |
|
Change Parameter Type record : OUT to record : StreamRecord<OUT> in method public collect(record StreamRecord<OUT>) : void in class org.apache.flink.streaming.runtime.io.CollectorWrapper |
From |
To |
|
Change Parameter Type output : Collector<?> to output : Collector<StreamRecord<?>> in method public addCollector(output Collector<StreamRecord<?>>, edge StreamEdge) : void in class org.apache.flink.streaming.api.collector.selector.BroadcastOutputSelectorWrapper |
From |
To |
|
Change Parameter Type operator : OneInputStreamOperator<Object,T> to operator : OneInputStreamOperator<?,T> in method public ChainingOutput(operator OneInputStreamOperator<?,T>) in class org.apache.flink.streaming.runtime.tasks.OutputHandler.ChainingOutput |
From |
To |
|
Change Parameter Type value : Tuple3<String,String,String> to value : String in method public map(value String) : String in class org.apache.flink.streaming.runtime.tasks.OneInputStreamTaskTest.IdentityMap |
From |
To |
|
Change Parameter Type element : IN2 to element : StreamRecord<IN2> in method public processElement2(element StreamRecord<IN2>) : void in class org.apache.flink.streaming.api.operators.co.CoStreamReduce |
From |
To |
|
Change Parameter Type collector : Collector<StreamWindow<T>> to collector : Collector<StreamRecord<StreamWindow<T>>> in method public emitWindow(collector Collector<StreamRecord<StreamWindow<T>>>) : void in class org.apache.flink.streaming.api.windowing.windowbuffer.JumpingTimeGroupedPreReducer |
From |
To |
|
Change Parameter Type element : IN to element : StreamRecord<IN> in method public processElement(element StreamRecord<IN>) : void in class org.apache.flink.streaming.api.operators.OneInputStreamOperator |
From |
To |
|
Change Parameter Type element : IN1 to elementRecord : StreamRecord<IN1> in method public processElement1(elementRecord StreamRecord<IN1>) : void in class org.apache.flink.streaming.api.operators.co.CoStreamGroupedReduce |
From |
To |
|
Change Parameter Type value : StreamRecord<T> to value : Object in method public serialize(value Object, target DataOutputView) : void in class org.apache.flink.streaming.runtime.streamrecord.StreamRecordSerializer |
From |
To |
|
Change Parameter Type output : Output<OUT> to output : Output<StreamRecord<OUT>> in method public setup(output Output<StreamRecord<OUT>>, runtimeContext StreamingRuntimeContext) : void in class org.apache.flink.streaming.api.operators.AbstractStreamOperator |
From |
To |
|
Change Parameter Type element : IN to element : StreamRecord<IN> in method public processElement(element StreamRecord<IN>) : void in class org.apache.flink.streaming.api.operators.StreamMap |
From |
To |
|
Change Parameter Type collector : Collector<StreamWindow<T>> to collector : Collector<StreamRecord<StreamWindow<T>>> in method public emitWindow(collector Collector<StreamRecord<StreamWindow<T>>>) : void in class org.apache.flink.streaming.api.windowing.windowbuffer.BasicWindowBuffer |
From |
To |
|
Change Parameter Type windowEvent : WindowEvent<T> to windowEvent : StreamRecord<WindowEvent<T>> in method public processElement(windowEvent StreamRecord<WindowEvent<T>>) : void in class org.apache.flink.streaming.api.operators.windowing.StreamWindowBuffer |
From |
To |
|
Change Parameter Type serializer : StreamRecordSerializer<?> to serializer : TypeSerializer<?> in method public setTypeSerializerOut1(serializer TypeSerializer<?>) : void in class org.apache.flink.streaming.api.graph.StreamConfig |
From |
To |
|
Change Parameter Type element : IN to element : StreamRecord<IN> in method public processElement(element StreamRecord<IN>) : void in class org.apache.flink.streaming.api.operators.StreamFilter |
From |
To |
|
Change Parameter Type element : IN2 to elementRecord : StreamRecord<IN2> in method public processElement2(elementRecord StreamRecord<IN2>) : void in class org.apache.flink.streaming.api.operators.co.CoStreamGroupedReduce |
From |
To |
|
Change Parameter Type serializer : StreamRecordSerializer<?> to serializer : TypeSerializer<?> in method public setTypeSerializerOut2(serializer TypeSerializer<?>) : void in class org.apache.flink.streaming.api.graph.StreamConfig |
From |
To |
|
Change Parameter Type record : OUT to record : StreamRecord<OUT> in method public collect(record StreamRecord<OUT>) : void in class org.apache.flink.streaming.runtime.io.RecordWriterOutput |
From |
To |
|
Change Parameter Type nextWindow : StreamWindow<T> to nextWindowRecord : StreamRecord<StreamWindow<T>> in method public processElement(nextWindowRecord StreamRecord<StreamWindow<T>>) : void in class org.apache.flink.streaming.api.operators.windowing.WindowMerger |
From |
To |
|
Change Parameter Type output : Output<OUT> to output : Output<StreamRecord<OUT>> in method public setup(output Output<StreamRecord<OUT>>, runtimeContext StreamingRuntimeContext) : void in class org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator |
From |
To |
|
Change Parameter Type out : StreamRecordSerializer<?> to out : TypeSerializer<?> in method private setSerializers(vertexID Integer, in1 TypeSerializer<?>, in2 TypeSerializer<?>, out TypeSerializer<?>) : void in class org.apache.flink.streaming.api.graph.StreamGraph |
From |
To |
|
Change Parameter Type serializer : TypeSerializer<T> to serializer : TypeSerializer<StreamRecord<T>> in method public CopyingChainingOutput(operator OneInputStreamOperator<?,T>, serializer TypeSerializer<StreamRecord<T>>) in class org.apache.flink.streaming.runtime.tasks.OutputHandler.CopyingChainingOutput |
From |
To |
|
Change Parameter Type flinkOutput : Output<OUT> to flinkOutput : Collector<OUT> in method public StormBoltCollector(numberOfAttributes int, flinkOutput Collector<OUT>) in class org.apache.flink.stormcompatibility.wrappers.StormBoltCollector |
From |
To |
|
Change Parameter Type collector : Collector<StreamWindow<T>> to collector : Collector<StreamRecord<StreamWindow<T>>> in method public emitWindow(collector Collector<StreamRecord<StreamWindow<T>>>) : void in class org.apache.flink.streaming.api.windowing.windowbuffer.TumblingGroupedPreReducer |
From |
To |
|
Change Parameter Type element : IN to element : StreamRecord<IN> in method public processElement(element StreamRecord<IN>) : void in class org.apache.flink.stormcompatibility.wrappers.StormBoltWrapper |
From |
To |
|
Change Parameter Type output : Output<OUT> to output : Output<StreamRecord<OUT>> in method public setup(output Output<StreamRecord<OUT>>, runtimeContext StreamingRuntimeContext) : void in class org.apache.flink.streaming.api.operators.StreamOperator |
From |
To |
|
Change Parameter Type output : Collector<?> to output : Collector<StreamRecord<?>> in method public addCollector(output Collector<StreamRecord<?>>, edge StreamEdge) : void in class org.apache.flink.streaming.runtime.io.CollectorWrapper |
From |
To |
|
Change Parameter Type element : IN to element : StreamRecord<IN> in method public processElement(element StreamRecord<IN>) : void in class org.apache.flink.streaming.api.operators.StreamFold |
From |
To |
|
Change Parameter Type collector : Collector<StreamWindow<T>> to collector : Collector<StreamRecord<StreamWindow<T>>> in method public abstract emitWindow(collector Collector<StreamRecord<StreamWindow<T>>>) : void in class org.apache.flink.streaming.api.windowing.windowbuffer.WindowBuffer |
From |
To |
|
Change Parameter Type sourceFunction : SourceFunction<OUT> to sourceFunction : SourceFunction<T> in method public StreamSource(sourceFunction SourceFunction<T>) in class org.apache.flink.streaming.api.operators.StreamSource |
From |
To |
|
Change Parameter Type element : IN1 to element : StreamRecord<IN1> in method public processElement1(element StreamRecord<IN1>) : void in class org.apache.flink.streaming.api.operators.co.CoStreamMap |
From |
To |
|
Change Parameter Type element : IN1 to element : StreamRecord<IN1> in method public processElement1(element StreamRecord<IN1>) : void in class org.apache.flink.streaming.api.operators.TwoInputStreamOperator |
From |
To |
|
Change Parameter Type nextRecord : Object to nextRecord : StreamRecord<?> in method public setNextInput(nextRecord StreamRecord<?>) : void in class org.apache.flink.streaming.runtime.tasks.StreamingRuntimeContext |
From |
To |
|
Change Parameter Type element : IN to element : StreamRecord<IN> in method public processElement(element StreamRecord<IN>) : void in class org.apache.flink.streaming.api.operators.windowing.GroupedActiveDiscretizer |
From |
To |
|
Change Parameter Type collector : Collector<StreamWindow<T>> to collector : Collector<StreamRecord<StreamWindow<T>>> in method public emitWindow(collector Collector<StreamRecord<StreamWindow<T>>>) : void in class org.apache.flink.streaming.api.windowing.windowbuffer.JumpingTimePreReducer |
From |
To |
|
Change Parameter Type typeSerializerIn2 : StreamRecordSerializer<?> to typeSerializerIn2 : TypeSerializer<?> in method public setSerializerIn2(typeSerializerIn2 TypeSerializer<?>) : void in class org.apache.flink.streaming.api.graph.StreamNode |
From |
To |
|
Change Parameter Type element : IN to element : StreamRecord<IN> in method public processElement(element StreamRecord<IN>) : void in class org.apache.flink.streaming.api.operators.StreamGroupedFold |
From |
To |
|
Change Parameter Type in2 : StreamRecordSerializer<?> to in2 : TypeSerializer<?> in method private setSerializers(vertexID Integer, in1 TypeSerializer<?>, in2 TypeSerializer<?>, out TypeSerializer<?>) : void in class org.apache.flink.streaming.api.graph.StreamGraph |
From |
To |
|
Change Parameter Type element : IN to element : StreamRecord<IN> in method public processElement(element StreamRecord<IN>) : void in class org.apache.flink.streaming.api.operators.windowing.GroupedStreamDiscretizer |
From |
To |
|
Change Parameter Type collector : Collector<StreamWindow<T>> to collector : Collector<StreamRecord<StreamWindow<T>>> in method public emitWindow(collector Collector<StreamRecord<StreamWindow<T>>>) : void in class org.apache.flink.streaming.api.windowing.windowbuffer.JumpingCountPreReducer |
From |
To |
|
Change Parameter Type currentWindow : StreamWindow<T> to currentWindow : StreamRecord<StreamWindow<T>> in method public processElement(currentWindow StreamRecord<StreamWindow<T>>) : void in class org.apache.flink.streaming.api.operators.windowing.WindowPartitioner |
From |
To |
|
Change Parameter Type serializer : StreamRecordSerializer<?> to serializer : TypeSerializer<?> in method public setTypeSerializerIn1(serializer TypeSerializer<?>) : void in class org.apache.flink.streaming.api.graph.StreamConfig |
From |
To |
|
Change Parameter Type serializer : StreamRecordSerializer<?> to serializer : TypeSerializer<?> in method public setTypeSerializerIn2(serializer TypeSerializer<?>) : void in class org.apache.flink.streaming.api.graph.StreamConfig |
From |
To |
|
Change Parameter Type operator : OneInputStreamOperator to operator : OneInputStreamOperator<?,T> in method public CopyingChainingOutput(operator OneInputStreamOperator<?,T>, serializer TypeSerializer<StreamRecord<T>>) in class org.apache.flink.streaming.runtime.tasks.OutputHandler.CopyingChainingOutput |
From |
To |
|
Change Parameter Type element : IN to element : StreamRecord<IN> in method public processElement(element StreamRecord<IN>) : void in class org.apache.flink.streaming.api.operators.windowing.StreamDiscretizer |
From |
To |
|
Change Parameter Type output : Collector<?> to output : Collector<StreamRecord<?>> in method public addCollector(output Collector<StreamRecord<?>>, edge StreamEdge) : void in class org.apache.flink.streaming.api.collector.selector.DirectedOutputSelectorWrapper |
From |
To |
|
Change Parameter Type element : IN to element : StreamRecord<IN> in method public processElement(element StreamRecord<IN>) : void in class org.apache.flink.streaming.api.operators.StreamProject |
From |
To |
|
Change Parameter Type element : IN1 to element : StreamRecord<IN1> in method public processElement1(element StreamRecord<IN1>) : void in class org.apache.flink.streaming.api.operators.co.CoStreamWindow |
From |
To |
|
Change Parameter Type element : IN to element : StreamRecord<IN> in method public processElement(element StreamRecord<IN>) : void in class org.apache.flink.streaming.api.operators.StreamCounter |
From |
To |
|
Change Parameter Type element : IN2 to element : StreamRecord<IN2> in method public processElement2(element StreamRecord<IN2>) : void in class org.apache.flink.streaming.api.operators.co.CoStreamMap |
From |
To |
|
Change Parameter Type element : IN2 to element : StreamRecord<IN2> in method public processElement2(element StreamRecord<IN2>) : void in class org.apache.flink.streaming.api.operators.TwoInputStreamOperator |
From |
To |
|
Change Parameter Type element : IN2 to element : StreamRecord<IN2> in method public processElement2(element StreamRecord<IN2>) : void in class org.apache.flink.streaming.api.operators.co.CoStreamWindow |
From |
To |
|
Change Parameter Type record : T to record : StreamRecord<T> in method public collect(record StreamRecord<T>) : void in class org.apache.flink.streaming.runtime.tasks.OutputHandler.ChainingOutput |
From |
To |
|
Change Parameter Type typeSerializerIn1 : StreamRecordSerializer<?> to typeSerializerIn1 : TypeSerializer<?> in method public setSerializerIn1(typeSerializerIn1 TypeSerializer<?>) : void in class org.apache.flink.streaming.api.graph.StreamNode |
From |
To |
|
Change Parameter Type typeSerializerOut : StreamRecordSerializer<?> to typeSerializerOut : TypeSerializer<?> in method public setSerializerOut(typeSerializerOut TypeSerializer<?>) : void in class org.apache.flink.streaming.api.graph.StreamNode |
From |
To |
|
Change Parameter Type output : Collector<?> to output : Collector<StreamRecord<?>> in method public addCollector(output Collector<StreamRecord<?>>, edge StreamEdge) : void in class org.apache.flink.streaming.api.collector.selector.OutputSelectorWrapper |
From |
To |
|
Change Parameter Type element : IN to element : StreamRecord<IN> in method public processElement(element StreamRecord<IN>) : void in class org.apache.flink.streaming.api.operators.StreamReduce |
From |
To |
|
Change Parameter Type record : T to record : StreamRecord<T> in method public collect(record StreamRecord<T>) : void in class org.apache.flink.streaming.runtime.tasks.OutputHandler.CopyingChainingOutput |
From |
To |
|
Change Parameter Type event : WindowEvent<T> to event : StreamRecord<WindowEvent<T>> in method public processElement(event StreamRecord<WindowEvent<T>>) : void in class org.apache.flink.streaming.api.operators.windowing.GroupedWindowBuffer |
From |
To |
|
Change Parameter Type collector : Collector<StreamWindow<T>> to collector : Collector<StreamRecord<StreamWindow<T>>> in method public emitWindow(collector Collector<StreamRecord<StreamWindow<T>>>) : void in class org.apache.flink.streaming.api.windowing.windowbuffer.TumblingPreReducer |
From |
To |
|
Change Parameter Type collector : Collector<StreamWindow<T>> to collector : Collector<StreamRecord<StreamWindow<T>>> in method public emitWindow(collector Collector<StreamRecord<StreamWindow<T>>>) : void in class org.apache.flink.streaming.api.windowing.windowbuffer.SlidingPreReducer |
From |
To |
|
Change Parameter Type typeWrapper : StreamRecordSerializer<?> to typeWrapper : TypeSerializer<?> in method private setTypeSerializer(key String, typeWrapper TypeSerializer<?>) : void in class org.apache.flink.streaming.api.graph.StreamConfig |
From |
To |
|
Move Attribute private serialVersionUID : long from class org.apache.flink.streaming.api.operators.ProjectTest to private serialVersionUID : long from class org.apache.flink.api.common.ExecutionConfig.GlobalJobParameters |
From |
To |
|
Move Attribute private serialVersionUID : long from class org.apache.flink.streaming.runtime.streamrecord.StreamRecord to private serialVersionUID : long from class org.apache.flink.streaming.api.operators.co.CoStreamMapTest |
From |
To |
|
Move Attribute private serialVersionUID : long from class org.apache.flink.streaming.runtime.streamrecord.StreamRecord to private serialVersionUID : long from class org.apache.flink.streaming.runtime.tasks.OneInputStreamTaskTest.TestOpenCloseMapFunction |
From |
To |
|
Move Attribute private serialVersionUID : long from class org.apache.flink.streaming.runtime.streamrecord.StreamRecord to private serialVersionUID : long from class org.apache.flink.streaming.api.operators.co.CoStreamFlatMapTest.TestOpenCloseCoFlatMapFunction |
From |
To |
|
Move Attribute private serialVersionUID : long from class org.apache.flink.streaming.runtime.streamrecord.StreamRecord to private serialVersionUID : long from class org.apache.flink.streaming.runtime.streamrecord.MultiplexingStreamRecordSerializer |
From |
To |
|
Move Attribute private serialVersionUID : long from class org.apache.flink.streaming.runtime.streamrecord.StreamRecord to private serialVersionUID : long from class org.apache.flink.streaming.api.operators.StreamMapTest.TestOpenCloseMapFunction |
From |
To |
|
Move Attribute private serialVersionUID : long from class org.apache.flink.streaming.runtime.streamrecord.StreamRecord to private serialVersionUID : long from class org.apache.flink.streaming.api.operators.StreamFilterTest.TestOpenCloseFilterFunction |
From |
To |
|
Move Attribute private serialVersionUID : long from class org.apache.flink.streaming.runtime.streamrecord.StreamRecord to private serialVersionUID : long from class org.apache.flink.streaming.api.operators.StreamGroupedFoldTest.TestOpenCloseFoldFunction |
From |
To |
|
Move Attribute private serialVersionUID : long from class org.apache.flink.streaming.runtime.streamrecord.StreamRecord to private serialVersionUID : long from class org.apache.flink.streaming.runtime.tasks.TwoInputStreamTaskTest.IdentityMap |
From |
To |
|
Move Attribute private serialVersionUID : long from class org.apache.flink.streaming.runtime.streamrecord.StreamRecord to private serialVersionUID : long from class org.apache.flink.streaming.api.operators.co.CoStreamMapTest.TestOpenCloseCoMapFunction |
From |
To |
|
Move Attribute private serialVersionUID : long from class org.apache.flink.streaming.runtime.streamrecord.StreamRecord to private serialVersionUID : long from class org.apache.flink.streaming.runtime.tasks.StreamIterationTail.RecordPusher |
From |
To |
|
Move Attribute private serialVersionUID : long from class org.apache.flink.streaming.runtime.streamrecord.StreamRecord to private serialVersionUID : long from class org.apache.flink.streaming.api.operators.StreamFlatMapTest.TestOpenCloseFlatMapFunction |
From |
To |
|
Move Attribute private serialVersionUID : long from class org.apache.flink.streaming.runtime.streamrecord.StreamRecord to private serialVersionUID : long from class org.apache.flink.streaming.api.operators.StreamGroupedReduceTest.TestOpenCloseReduceFunction |
From |
To |
|
Move Attribute private serialVersionUID : long from class org.apache.flink.streaming.runtime.streamrecord.StreamRecord to private serialVersionUID : long from class org.apache.flink.streaming.runtime.tasks.TwoInputStreamTaskTest.TestOpenCloseMapFunction |
From |
To |
|
Move Attribute private serialVersionUID : long from class org.apache.flink.streaming.runtime.streamrecord.StreamRecord to private serialVersionUID : long from class org.apache.flink.streaming.api.operators.co.CoStreamFlatMapTest |
From |
To |
|
Move Attribute private serialVersionUID : long from class org.apache.flink.streaming.runtime.streamrecord.StreamRecord to private serialVersionUID : long from class org.apache.flink.streaming.api.operators.StreamProjectTest |
From |
To |
|
Change Variable Type selectedOutputs : Set<Collector<OUT>> to selectedOutputs : Set<Collector<StreamRecord<OUT>>> in method public getSelectedOutputs(record OUT) : Iterable<Collector<StreamRecord<OUT>>> in class org.apache.flink.streaming.api.collector.selector.DirectedOutputSelectorWrapper |
From |
To |
|
Change Variable Type collector : TestCollector<StreamWindow<Integer>> to collector : TestOutput<StreamWindow<Integer>> in method public testPreReduce1() : void in class org.apache.flink.streaming.api.windowing.windowbuffer.SlidingCountPreReducerTest |
From |
To |
|
Change Variable Type collector : TestCollector<StreamWindow<Integer>> to collector : TestOutput<StreamWindow<Integer>> in method public testPreReduce4() : void in class org.apache.flink.streaming.api.windowing.windowbuffer.SlidingCountGroupedPreReducerTest |
From |
To |
|
Change Variable Type output : StreamOutput<?> to output : RecordWriterOutput<?> in method public invoke() : void in class org.apache.flink.streaming.runtime.tasks.StreamIterationHead |
From |
To |
|
Change Variable Type collector : TestCollector<StreamWindow<Integer>> to collector : TestOutput<StreamWindow<Integer>> in method public testPreReduce3() : void in class org.apache.flink.streaming.api.windowing.windowbuffer.SlidingTimePreReducerTest |
From |
To |
|
Change Variable Type output : Collector<OUT> to output : Collector<StreamRecord<OUT>> in method public collect(record StreamRecord<OUT>) : void in class org.apache.flink.streaming.runtime.io.CollectorWrapper |
From |
To |
|
Change Variable Type outputList : List<Collector<OUT>> to outputList : List<Collector<StreamRecord<OUT>>> in method public getSelectedOutputs(record OUT) : Iterable<Collector<StreamRecord<OUT>>> in class org.apache.flink.streaming.api.collector.selector.DirectedOutputSelectorWrapper |
From |
To |
|
Change Variable Type collector : TestCollector<StreamWindow<Integer>> to collector : TestOutput<StreamWindow<Integer>> in method public testPreReduce3() : void in class org.apache.flink.streaming.api.windowing.windowbuffer.SlidingCountGroupedPreReducerTest |
From |
To |
|
Change Variable Type collector : TestCollector<StreamWindow<Tuple2<Integer,Integer>>> to collector : TestOutput<StreamWindow<Tuple2<Integer,Integer>>> in method public testPreReduce1() : void in class org.apache.flink.streaming.api.windowing.windowbuffer.SlidingTimeGroupedPreReducerTest |
From |
To |
|
Change Variable Type collector : TestCollector<StreamWindow<Integer>> to collector : TestOutput<StreamWindow<Integer>> in method public testPreReduce3() : void in class org.apache.flink.streaming.api.windowing.windowbuffer.SlidingTimeGroupedPreReducerTest |
From |
To |
|
Change Variable Type collector : TestCollector<StreamWindow<Tuple2<Integer,Integer>>> to collector : TestOutput<StreamWindow<Tuple2<Integer,Integer>>> in method public testEmitWindow() : void in class org.apache.flink.streaming.api.windowing.windowbuffer.TumblingPreReducerTest |
From |
To |
|
Change Variable Type collector : TestCollector<StreamWindow<Integer>> to collector : TestOutput<StreamWindow<Integer>> in method public testEmitWindow() : void in class org.apache.flink.streaming.api.windowing.windowbuffer.BasicWindowBufferTest |
From |
To |
|
Change Variable Type collector : TestCollector<StreamWindow<Tuple2<Integer,Integer>>> to collector : TestOutput<StreamWindow<Tuple2<Integer,Integer>>> in method public testEmitWindow2() : void in class org.apache.flink.streaming.api.windowing.windowbuffer.JumpingCountGroupedPreReducerTest |
From |
To |
|
Change Variable Type barrier : StreamingSuperstep to barrier : CheckpointBarrier in method public broadcastBarrier(id long, timestamp long) : void in class org.apache.flink.streaming.runtime.tasks.OutputHandler |
From |
To |
|
Change Variable Type collector : TestCollector<StreamWindow<Integer>> to collector : TestOutput<StreamWindow<Integer>> in method public testPreReduce2() : void in class org.apache.flink.streaming.api.windowing.windowbuffer.SlidingCountGroupedPreReducerTest |
From |
To |
|
Change Variable Type output : StreamOutput<?> to output : RecordWriterOutput<?> in method public clearWriters() : void in class org.apache.flink.streaming.runtime.tasks.OutputHandler |
From |
To |
|
Change Variable Type collector : TestCollector<StreamWindow<Tuple2<Integer,Integer>>> to collector : TestOutput<StreamWindow<Tuple2<Integer,Integer>>> in method public testEmitWindow2() : void in class org.apache.flink.streaming.api.windowing.windowbuffer.TumblingGroupedPreReducerTest |
From |
To |
|
Change Variable Type sStep : StreamingSuperstep to sStep : CheckpointBarrier in method public onEvent(event TaskEvent) : void in class org.apache.flink.streaming.runtime.tasks.StreamTask.CheckpointBarrierListener |
From |
To |
|
Change Variable Type collector : TestCollector<StreamWindow<Integer>> to collector : TestOutput<StreamWindow<Integer>> in method public testPreReduce1() : void in class org.apache.flink.streaming.api.windowing.windowbuffer.SlidingCountGroupedPreReducerTest |
From |
To |
|
Change Variable Type collector : TestCollector<StreamWindow<Tuple2<Integer,Integer>>> to collector : TestOutput<StreamWindow<Tuple2<Integer,Integer>>> in method public testEmitWindow() : void in class org.apache.flink.streaming.api.windowing.windowbuffer.TumblingGroupedPreReducerTest |
From |
To |
|
Change Variable Type collector : Collector<T> to collector : Output<StreamRecord<T>> in method public runSourceFunction(sourceFunction SourceFunction<T>) : List<T> in class org.apache.flink.streaming.util.SourceFunctionUtil |
From |
To |
|
Change Variable Type outSerializer : StreamRecordSerializer<OUT> to outSerializer : TypeSerializer<OUT> in method public addOperator(vertexID Integer, operatorObject StreamOperator<OUT>, inTypeInfo TypeInformation<IN>, outTypeInfo TypeInformation<OUT>, operatorName String) : void in class org.apache.flink.streaming.api.graph.StreamGraph |
From |
To |
|
Change Variable Type collector : TestCollector<StreamWindow<Integer>> to collector : TestOutput<StreamWindow<Integer>> in method public testPreReduce4() : void in class org.apache.flink.streaming.api.windowing.windowbuffer.SlidingTimePreReducerTest |
From |
To |
|
Change Variable Type outSerializer : StreamRecordSerializer<T> to outSerializer : TypeSerializer<T> in method private createStreamOutput(edge StreamEdge, outputVertex Integer, upStreamConfig StreamConfig, outputIndex int, reporter AccumulatorRegistry.Reporter) : RecordWriterOutput<T> in class org.apache.flink.streaming.runtime.tasks.OutputHandler |
From |
To |
|
Change Variable Type that : StreamingSuperstep to that : CheckpointBarrier in method public equals(other Object) : boolean in class org.apache.flink.streaming.runtime.tasks.CheckpointBarrier |
From |
To |
|
Change Variable Type streamOutput : StreamOutput<?> to streamOutput : RecordWriterOutput<?> in method public OutputHandler(vertex StreamTask<OUT,?>, accumulatorMap Map<String,Accumulator<?,?>>, reporter AccumulatorRegistry.Reporter) in class org.apache.flink.streaming.runtime.tasks.OutputHandler |
From |
To |
|
Change Variable Type outSerializer : StreamRecordSerializer<OUT> to outSerializer : TypeSerializer<OUT> in method public addCoOperator(vertexID Integer, taskoperatorObject TwoInputStreamOperator<IN1,IN2,OUT>, in1TypeInfo TypeInformation<IN1>, in2TypeInfo TypeInformation<IN2>, outTypeInfo TypeInformation<OUT>, operatorName String) : void in class org.apache.flink.streaming.api.graph.StreamGraph |
From |
To |
|
Change Variable Type streamOutput : StreamOutput<?> to streamOutput : RecordWriterOutput<?> in method public flushOutputs() : void in class org.apache.flink.streaming.runtime.tasks.OutputHandler |
From |
To |
|
Change Variable Type streamOutput : StreamOutput<?> to streamOutput : RecordWriterOutput<?> in method public broadcastBarrier(id long, timestamp long) : void in class org.apache.flink.streaming.runtime.tasks.OutputHandler |
From |
To |
|
Change Variable Type collector : TestCollector<StreamWindow<Integer>> to collector : TestOutput<StreamWindow<Integer>> in method public testPreReduce2() : void in class org.apache.flink.streaming.api.windowing.windowbuffer.SlidingTimeGroupedPreReducerTest |
From |
To |
|
Change Variable Type collector : TestCollector<StreamWindow<Integer>> to collector : TestOutput<StreamWindow<Integer>> in method public testEmitWindow() : void in class org.apache.flink.streaming.api.windowing.windowbuffer.JumpingTimePreReducerTest |
From |
To |
|
Change Variable Type collector : TestCollector<StreamWindow<Tuple2<Integer,Integer>>> to collector : TestOutput<StreamWindow<Tuple2<Integer,Integer>>> in method public testEmitWindow() : void in class org.apache.flink.streaming.api.windowing.windowbuffer.JumpingCountPreReducerTest |
From |
To |
|
Change Variable Type inSerializer : StreamRecordSerializer<IN> to inSerializer : TypeSerializer<IN> in method public addOperator(vertexID Integer, operatorObject StreamOperator<OUT>, inTypeInfo TypeInformation<IN>, outTypeInfo TypeInformation<OUT>, operatorName String) : void in class org.apache.flink.streaming.api.graph.StreamGraph |
From |
To |
|
Change Variable Type collector : TestCollector<StreamWindow<Integer>> to collector : TestOutput<StreamWindow<Integer>> in method public testPreReduce2() : void in class org.apache.flink.streaming.api.windowing.windowbuffer.SlidingTimePreReducerTest |
From |
To |
|
Change Variable Type collector : TestCollector<StreamWindow<Integer>> to collector : TestOutput<StreamWindow<Integer>> in method public testPreReduce4() : void in class org.apache.flink.streaming.api.windowing.windowbuffer.SlidingTimeGroupedPreReducerTest |
From |
To |
|
Change Variable Type collector : TestCollector<StreamWindow<Tuple2<Integer,Integer>>> to collector : TestOutput<StreamWindow<Tuple2<Integer,Integer>>> in method public testEmitWindow() : void in class org.apache.flink.streaming.api.windowing.windowbuffer.JumpingCountGroupedPreReducerTest |
From |
To |
|
Change Variable Type collector : TestCollector<StreamWindow<Integer>> to collector : TestOutput<StreamWindow<Integer>> in method public testPreReduce4() : void in class org.apache.flink.streaming.api.windowing.windowbuffer.SlidingCountPreReducerTest |
From |
To |
|
Change Variable Type outputs : Collection<StreamOutput<?>> to outputs : Collection<RecordWriterOutput<?>> in method public invoke() : void in class org.apache.flink.streaming.runtime.tasks.StreamIterationHead |
From |
To |
|
Change Variable Type collector : TestCollector<StreamWindow<Integer>> to collector : TestOutput<StreamWindow<Integer>> in method public testPreReduce3() : void in class org.apache.flink.streaming.api.windowing.windowbuffer.SlidingCountPreReducerTest |
From |
To |
|
Change Variable Type collector : TestCollector<StreamWindow<Tuple2<Integer,Integer>>> to collector : TestOutput<StreamWindow<Tuple2<Integer,Integer>>> in method public testPreReduce1() : void in class org.apache.flink.streaming.api.windowing.windowbuffer.SlidingTimePreReducerTest |
From |
To |
|
Change Variable Type value : Tuple to value : Tuple2<String,Integer> in method public setPartitioner() : void in class org.apache.flink.streaming.runtime.partitioner.FieldsPartitionerTest |
From |
To |
|
Change Variable Type record : String to record : StreamRecord<String> in method private createOperatorWithContext(output List<String>, partitioner KeySelector<Integer,Serializable>, serializedState byte[]) : StreamMap<Integer,String> in class org.apache.flink.streaming.api.state.StatefulOperatorTest |
From |
To |
|
Change Variable Type collector : TestCollector<StreamWindow<Integer>> to collector : TestOutput<StreamWindow<Integer>> in method public testPreReduce2() : void in class org.apache.flink.streaming.api.windowing.windowbuffer.SlidingCountPreReducerTest |
From |
To |
|
Change Return Type boolean to void in method public processElement(record StreamRecord<IN>) : void in class org.apache.flink.streaming.runtime.tasks.StreamIterationTail.RecordPusher |
From |
To |
|
Change Return Type Iterable<Collector<OUT>> to Iterable<Collector<StreamRecord<OUT>>> in method public getSelectedOutputs(record OUT) : Iterable<Collector<StreamRecord<OUT>>> in class org.apache.flink.streaming.api.collector.selector.DirectedOutputSelectorWrapper |
From |
To |
|
Change Return Type StreamRecordSerializer<T> to TypeSerializer<T> in method public getTypeSerializerOut2(cl ClassLoader) : TypeSerializer<T> in class org.apache.flink.streaming.api.graph.StreamConfig |
From |
To |
|
Change Return Type Integer to Serializable in method public snapshotState(checkpointId long, checkpointTimestamp long) : Serializable in class org.apache.flink.streaming.runtime.tasks.SourceStreamTaskTest.MockSource |
From |
To |
|
Change Return Type StreamRecord<T> to Object in method public deserialize(source DataInputView) : Object in class org.apache.flink.streaming.runtime.streamrecord.StreamRecordSerializer |
From |
To |
|
Change Return Type Collector<OUT> to Output<StreamRecord<OUT>> in method public getOutput() : Output<StreamRecord<OUT>> in class org.apache.flink.streaming.util.MockContext |
From |
To |
|
Change Return Type Output<OUT> to Output<StreamRecord<OUT>> in method public getOutput() : Output<StreamRecord<OUT>> in class org.apache.flink.streaming.runtime.tasks.OutputHandler |
From |
To |
|
Change Return Type StreamRecordSerializer<T> to TypeSerializer<T> in method public getTypeSerializerIn2(cl ClassLoader) : TypeSerializer<T> in class org.apache.flink.streaming.api.graph.StreamConfig |
From |
To |
|
Change Return Type Output<X> to Output<StreamRecord<X>> in method private createChainedCollector(chainedTaskConfig StreamConfig, accumulatorMap Map<String,Accumulator<?,?>>) : Output<StreamRecord<X>> in class org.apache.flink.streaming.runtime.tasks.OutputHandler |
From |
To |
|
Change Return Type StreamRecordSerializer<?> to TypeSerializer<?> in method public getTypeSerializerIn1() : TypeSerializer<?> in class org.apache.flink.streaming.api.graph.StreamNode |
From |
To |
|
Change Return Type Collection<StreamOutput<?>> to Collection<RecordWriterOutput<?>> in method public getOutputs() : Collection<RecordWriterOutput<?>> in class org.apache.flink.streaming.runtime.tasks.OutputHandler |
From |
To |
|
Change Return Type StreamRecordSerializer<T> to TypeSerializer in method public duplicate() : TypeSerializer in class org.apache.flink.streaming.runtime.streamrecord.StreamRecordSerializer |
From |
To |
|
Change Return Type StreamRecordSerializer<T> to TypeSerializer<T> in method public getTypeSerializerOut1(cl ClassLoader) : TypeSerializer<T> in class org.apache.flink.streaming.api.graph.StreamConfig |
From |
To |
|
Change Return Type Iterable<Collector<OUT>> to Iterable<Collector<StreamRecord<OUT>>> in method public getSelectedOutputs(record OUT) : Iterable<Collector<StreamRecord<OUT>>> in class org.apache.flink.streaming.api.collector.selector.OutputSelectorWrapper |
From |
To |
|
Change Return Type StreamOutput<T> to RecordWriterOutput<T> in method private createStreamOutput(edge StreamEdge, outputVertex Integer, upStreamConfig StreamConfig, outputIndex int, reporter AccumulatorRegistry.Reporter) : RecordWriterOutput<T> in class org.apache.flink.streaming.runtime.tasks.OutputHandler |
From |
To |
|
Change Return Type Iterable<Collector<OUT>> to Iterable<Collector<StreamRecord<OUT>>> in method public getSelectedOutputs(record OUT) : Iterable<Collector<StreamRecord<OUT>>> in class org.apache.flink.streaming.api.collector.selector.BroadcastOutputSelectorWrapper |
From |
To |
|
Change Return Type StreamRecordSerializer<?> to TypeSerializer<?> in method public getTypeSerializerOut() : TypeSerializer<?> in class org.apache.flink.streaming.api.graph.StreamNode |
From |
To |
|
Change Return Type StreamRecordSerializer<?> to TypeSerializer<?> in method public getTypeSerializerIn2() : TypeSerializer<?> in class org.apache.flink.streaming.api.graph.StreamNode |
From |
To |
|
Change Return Type StreamRecord<T> to Object in method public createInstance() : Object in class org.apache.flink.streaming.runtime.streamrecord.StreamRecordSerializer |
From |
To |
|
Change Return Type StreamRecordSerializer<T> to TypeSerializer<T> in method public getTypeSerializerIn1(cl ClassLoader) : TypeSerializer<T> in class org.apache.flink.streaming.api.graph.StreamConfig |
From |
To |
|
Change Attribute Type currentSuperstep : StreamingSuperstep to currentBarrier : CheckpointBarrier in class org.apache.flink.streaming.runtime.io.BarrierBuffer |
From |
To |
|
Change Attribute Type sd1 : SerializationDelegate<StreamRecord<Tuple>> to sd1 : SerializationDelegate<StreamRecord<Tuple2<String,Integer>>> in class org.apache.flink.streaming.runtime.partitioner.FieldsPartitionerTest |
From |
To |
|
Change Attribute Type coReader : CoRecordReader<DeserializationDelegate<StreamRecord<IN1>>,DeserializationDelegate<StreamRecord<IN2>>> to inputProcessor : StreamTwoInputProcessor<IN1,IN2> in class org.apache.flink.streaming.runtime.tasks.TwoInputStreamTask |
From |
To |
|
Change Attribute Type operator : OneInputStreamOperator<Object,T> to operator : OneInputStreamOperator in class org.apache.flink.streaming.runtime.tasks.OutputHandler.ChainingOutput |
From |
To |
|
Change Attribute Type outerOutput : Output<OUT> to outerOutput : Output<StreamRecord<OUT>> in class org.apache.flink.streaming.runtime.tasks.OutputHandler |
From |
To |
|
Change Attribute Type outputMap : Map<StreamEdge,StreamOutput<?>> to outputMap : Map<StreamEdge,RecordWriterOutput<?>> in class org.apache.flink.streaming.runtime.tasks.OutputHandler |
From |
To |
|
Change Attribute Type streamRecord1 : StreamRecord<Tuple> to streamRecord1 : StreamRecord<Tuple2<String,Integer>> in class org.apache.flink.streaming.runtime.partitioner.FieldsPartitionerTest |
From |
To |
|
Change Attribute Type selectAllOutputs : Set<Collector<OUT>> to selectAllOutputs : Set<Collector<StreamRecord<OUT>>> in class org.apache.flink.streaming.api.collector.selector.DirectedOutputSelectorWrapper |
From |
To |
|
Change Attribute Type typeSerializerIn2 : StreamRecordSerializer<?> to typeSerializerIn2 : TypeSerializer<?> in class org.apache.flink.streaming.api.graph.StreamNode |
From |
To |
|
Change Attribute Type inputs : IndexedMutableReader<DeserializationDelegate<StreamRecord<IN>>> to inputProcessor : StreamInputProcessor<IN> in class org.apache.flink.streaming.runtime.tasks.OneInputStreamTask |
From |
To |
|
Change Attribute Type serializationDelegate : SerializationDelegate<StreamRecord<OUT>> to serializationDelegate : SerializationDelegate in class org.apache.flink.streaming.runtime.io.RecordWriterOutput |
From |
To |
|
Change Attribute Type typeSerializerIn1 : StreamRecordSerializer<?> to typeSerializerIn1 : TypeSerializer<?> in class org.apache.flink.streaming.api.graph.StreamNode |
From |
To |
|
Change Attribute Type streamObject : T to value : Object in class org.apache.flink.streaming.runtime.streamrecord.StreamRecord |
From |
To |
|
Change Attribute Type streamRecord2 : StreamRecord<Tuple> to streamRecord2 : StreamRecord<Tuple2<String,Integer>> in class org.apache.flink.streaming.runtime.partitioner.FieldsPartitionerTest |
From |
To |
|
Change Attribute Type flinkOutput : Output<OUT> to flinkOutput : Collector<OUT> in class org.apache.flink.stormcompatibility.wrappers.StormBoltCollector |
From |
To |
|
Change Attribute Type sd2 : SerializationDelegate<StreamRecord<Tuple>> to sd2 : SerializationDelegate<StreamRecord<Tuple2<String,Integer>>> in class org.apache.flink.streaming.runtime.partitioner.FieldsPartitionerTest |
From |
To |
|
Change Attribute Type typeSerializerOut : StreamRecordSerializer<?> to typeSerializerOut : TypeSerializer<?> in class org.apache.flink.streaming.api.graph.StreamNode |
From |
To |
|
Change Attribute Type output : Output<OUT> to output : Output<StreamRecord<OUT>> in class org.apache.flink.streaming.api.operators.AbstractStreamOperator |
From |
To |
|
Change Attribute Type outputMap : Map<String,List<Collector<OUT>>> to outputMap : Map<String,List<Collector<StreamRecord<OUT>>>> in class org.apache.flink.streaming.api.collector.selector.DirectedOutputSelectorWrapper |
From |
To |
|
Change Attribute Type serializer : TypeSerializer<T> to serializer : TypeSerializer<StreamRecord<T>> in class org.apache.flink.streaming.runtime.tasks.OutputHandler.CopyingChainingOutput |
From |
To |
|
Change Attribute Type fieldsPartitioner : FieldsPartitioner<Tuple> to fieldsPartitioner : FieldsPartitioner<Tuple2<String,Integer>> in class org.apache.flink.streaming.runtime.partitioner.FieldsPartitionerTest |
From |
To |
|
Change Attribute Type outputs : List<Collector<OUT>> to outputs : List<Collector<StreamRecord<OUT>>> in class org.apache.flink.streaming.api.collector.selector.BroadcastOutputSelectorWrapper |
From |
To |
|
Change Attribute Type output : RecordWriter<SerializationDelegate<StreamRecord<OUT>>> to recordWriter : RecordWriter<SerializationDelegate> in class org.apache.flink.streaming.runtime.io.RecordWriterOutput |
From |
To |