|
Change Parameter Type operator : StreamOperator<?,?> to operator : StreamOperator<?> in method public StreamNode(env StreamExecutionEnvironment, ID Integer, operator StreamOperator<?>, operatorName String, outputSelector List<OutputSelector<?>>, jobVertexClass Class<? extends AbstractInvokable>) in class org.apache.flink.streaming.api.graph.StreamNode |
From |
To |
|
Change Parameter Type operator : StreamOperator<?,?> to operator : OneInputStreamOperator<IN,?> in method protected DataStreamSink(environment StreamExecutionEnvironment, operatorType String, outTypeInfo TypeInformation<IN>, operator OneInputStreamOperator<IN,?>) in class org.apache.flink.streaming.api.datastream.DataStreamSink |
From |
To |
|
Change Parameter Type operator : StreamOperator<?,?> to operator : StreamOperator<?> in method public setOperator(operator StreamOperator<?>) : void in class org.apache.flink.streaming.api.graph.StreamNode |
From |
To |
|
Change Parameter Type operatorObject : StreamOperator<IN,OUT> to operatorObject : StreamOperator<OUT> in method public setOperator(vertexID Integer, operatorObject StreamOperator<OUT>) : void in class org.apache.flink.streaming.api.graph.StreamGraph |
From |
To |
|
Change Parameter Type operatorObject : StreamOperator<?,?> to operatorObject : StreamOperator<?> in method protected addNode(vertexID Integer, vertexClass Class<? extends AbstractInvokable>, operatorObject StreamOperator<?>, operatorName String) : StreamNode in class org.apache.flink.streaming.api.graph.StreamGraph |
From |
To |
|
Change Parameter Type operator : StreamOperator<StreamWindow<OUT>,StreamWindow<R>> to operator : OneInputStreamOperator<StreamWindow<OUT>,StreamWindow<R>> in method private transform(transformation WindowTransformation, operatorName String, retType TypeInformation<R>, operator OneInputStreamOperator<StreamWindow<OUT>,StreamWindow<R>>) : DiscretizedStream<R> in class org.apache.flink.streaming.api.datastream.DiscretizedStream |
From |
To |
|
Change Parameter Type operator : StreamOperator<?,OUT> to operator : StreamOperator<OUT> in method public DataStreamSource(environment StreamExecutionEnvironment, operatorType String, outTypeInfo TypeInformation<OUT>, operator StreamOperator<OUT>, isParallel boolean, sourceName String) in class org.apache.flink.streaming.api.datastream.DataStreamSource |
From |
To |
|
Change Parameter Type taskoperatorObject : CoStreamOperator<IN1,IN2,OUT> to taskoperatorObject : TwoInputStreamOperator<IN1,IN2,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 Parameter Type vertex : StreamTask<?,OUT> to vertex : StreamTask<OUT,?> in method public OutputHandler(vertex StreamTask<OUT,?>) in class org.apache.flink.streaming.runtime.tasks.OutputHandler |
From |
To |
|
Change Parameter Type operatorObject : StreamOperator<IN,OUT> to operatorObject : StreamOperator<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 Parameter Type operatorObject : StreamOperator<IN,OUT> to operatorObject : StreamOperator<OUT> in method public addSource(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 Parameter Type operator : CoStreamOperator<IN1,IN2,OUT> to operator : TwoInputStreamOperator<IN1,IN2,OUT> in method public transform(functionName String, outTypeInfo TypeInformation<OUT>, operator TwoInputStreamOperator<IN1,IN2,OUT>) : SingleOutputStreamOperator<OUT,?> in class org.apache.flink.streaming.api.datastream.ConnectedDataStream |
From |
To |
|
Change Parameter Type operator : StreamOperator<IN,R> to operator : OneInputStreamOperator<IN,R> in method public transform(operatorName String, outTypeInfo TypeInformation<R>, operator OneInputStreamOperator<IN,R>) : SingleOutputStreamOperator<R,?> in class org.apache.flink.streaming.api.datastream.IterativeDataStream |
From |
To |
|
Change Parameter Type operator : StreamOperator<?,?> to operator : StreamOperator<?> in method protected SingleOutputStreamOperator(environment StreamExecutionEnvironment, operatorType String, outTypeInfo TypeInformation<OUT>, operator StreamOperator<?>) in class org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator |
From |
To |
|
Change Parameter Type operator : StreamOperator<?,?> to operator : StreamOperator<?> in method public setStreamOperator(operator StreamOperator<?>) : void in class org.apache.flink.streaming.api.graph.StreamConfig |
From |
To |
|
Change Parameter Type operator : StreamOperator<OUT,R> to operator : OneInputStreamOperator<OUT,R> in method public transform(operatorName String, outTypeInfo TypeInformation<R>, operator OneInputStreamOperator<OUT,R>) : SingleOutputStreamOperator<R,?> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Parameter Type operator : StreamOperator<IN,OUT> to operator : OneInputStreamOperator<IN,OUT> in method public createAndExecute(operator OneInputStreamOperator<IN,OUT>, inputs List<IN>) : List<OUT> in class org.apache.flink.streaming.util.MockContext |
From |
To |
|
Pull Up Attribute private serialVersionUID : long from class org.apache.flink.streaming.api.operators.windowing.StreamWindowBuffer to private serialVersionUID : long from class org.apache.flink.streaming.api.operators.AbstractStreamOperator |
From |
To |
|
Pull Up Attribute private serialVersionUID : long from class org.apache.flink.streaming.api.operators.co.CoStreamReduce to private serialVersionUID : long from class org.apache.flink.streaming.api.operators.AbstractStreamOperator |
From |
To |
|
Pull Up Attribute private serialVersionUID : long from class org.apache.flink.streaming.api.operators.StreamMap to private serialVersionUID : long from class org.apache.flink.streaming.api.operators.AbstractStreamOperator |
From |
To |
|
Pull Up Attribute private serialVersionUID : long from class org.apache.flink.streaming.api.operators.StreamSink to private serialVersionUID : long from class org.apache.flink.streaming.api.operators.AbstractStreamOperator |
From |
To |
|
Pull Up Attribute private serialVersionUID : long from class org.apache.flink.streaming.api.operators.windowing.WindowPartitioner to private serialVersionUID : long from class org.apache.flink.streaming.api.operators.AbstractStreamOperator |
From |
To |
|
Pull Up Attribute private serialVersionUID : long from class org.apache.flink.streaming.api.operators.windowing.WindowFlattener to private serialVersionUID : long from class org.apache.flink.streaming.api.operators.AbstractStreamOperator |
From |
To |
|
Pull Up Attribute private serialVersionUID : long from class org.apache.flink.streaming.api.operators.co.CoStreamMap to private serialVersionUID : long from class org.apache.flink.streaming.api.operators.AbstractStreamOperator |
From |
To |
|
Pull Up Attribute private serialVersionUID : long from class org.apache.flink.streaming.api.operators.StreamGroupedReduce to private serialVersionUID : long from class org.apache.flink.streaming.api.operators.AbstractStreamOperator |
From |
To |
|
Pull Up Attribute private serialVersionUID : long from class org.apache.flink.streaming.api.operators.StreamProject to private serialVersionUID : long from class org.apache.flink.streaming.api.operators.AbstractStreamOperator |
From |
To |
|
Pull Up Attribute private serialVersionUID : long from class org.apache.flink.streaming.api.operators.StreamFilter to private serialVersionUID : long from class org.apache.flink.streaming.api.operators.AbstractStreamOperator |
From |
To |
|
Pull Up Attribute private serialVersionUID : long from class org.apache.flink.streaming.api.operators.StreamReduce to private serialVersionUID : long from class org.apache.flink.streaming.api.operators.AbstractStreamOperator |
From |
To |
|
Pull Up Attribute private serialVersionUID : long from class org.apache.flink.streaming.api.operators.StreamFold to private serialVersionUID : long from class org.apache.flink.streaming.api.operators.AbstractStreamOperator |
From |
To |
|
Pull Up Attribute private serialVersionUID : long from class org.apache.flink.streaming.api.operators.StreamFlatMap to private serialVersionUID : long from class org.apache.flink.streaming.api.operators.AbstractStreamOperator |
From |
To |
|
Pull Up Attribute private serialVersionUID : long from class org.apache.flink.streaming.api.operators.co.CoStreamWindow to private serialVersionUID : long from class org.apache.flink.streaming.api.operators.AbstractStreamOperator |
From |
To |
|
Pull Up Attribute private serialVersionUID : long from class org.apache.flink.streaming.api.operators.windowing.WindowMerger to private serialVersionUID : long from class org.apache.flink.streaming.api.operators.AbstractStreamOperator |
From |
To |
|
Pull Up Attribute private serialVersionUID : long from class org.apache.flink.streaming.api.operators.co.CoStreamFlatMap to private serialVersionUID : long from class org.apache.flink.streaming.api.operators.AbstractStreamOperator |
From |
To |
|
Pull Up Attribute private serialVersionUID : long from class org.apache.flink.streaming.api.operators.StreamCounter to private serialVersionUID : long from class org.apache.flink.streaming.api.operators.AbstractStreamOperator |
From |
To |
|
Pull Up Attribute private serialVersionUID : long from class org.apache.flink.streaming.api.operators.StreamSource to private serialVersionUID : long from class org.apache.flink.streaming.api.operators.AbstractStreamOperator |
From |
To |
|
Pull Up Attribute private serialVersionUID : long from class org.apache.flink.streaming.api.operators.StreamGroupedFold to private serialVersionUID : long from class org.apache.flink.streaming.api.operators.AbstractStreamOperator |
From |
To |
|
Change Variable Type sinkOperator : StreamOperator<OUT,OUT> to sinkOperator : OneInputStreamOperator<OUT,Object> in method public addSink(sinkFunction SinkFunction<OUT>) : DataStreamSink<OUT> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Variable Type outputSelectorWrapper : OutputSelectorWrapper<OUT> to outputSelectorWrapper : OutputSelectorWrapper<?> in method private createChainedCollector(chainedTaskConfig StreamConfig) : Output<X> in class org.apache.flink.streaming.runtime.tasks.OutputHandler |
From |
To |
|
Change Variable Type headOperator : StreamOperator<?,?> to headOperator : StreamOperator<?> in method private isChainable(edge StreamEdge) : boolean in class org.apache.flink.streaming.api.graph.StreamingJobGraphGenerator |
From |
To |
|
Change Variable Type flattener : StreamOperator<StreamWindow<Integer>,Integer> to flattener : OneInputStreamOperator<StreamWindow<Integer>,Integer> in method public test() : void in class org.apache.flink.streaming.api.operators.windowing.WindowFlattenerTest |
From |
To |
|
Change Variable Type sourceOperator : StreamOperator<OUT,OUT> to sourceOperator : StreamOperator<OUT> in method private addSource(function SourceFunction<OUT>, sourceName String) : DataStreamSource<OUT> in class org.apache.flink.streaming.api.environment.StreamExecutionEnvironment |
From |
To |
|
Change Variable Type windowReducer : StreamOperator<StreamWindow<Integer>,StreamWindow<Integer>> to windowReducer : OneInputStreamOperator<StreamWindow<Integer>,StreamWindow<Integer>> in method public test() : void in class org.apache.flink.streaming.api.operators.windowing.WindowReducerTest |
From |
To |
|
Change Variable Type splitPartitioner : StreamOperator<StreamWindow<Integer>,StreamWindow<Integer>> to splitPartitioner : OneInputStreamOperator<StreamWindow<Integer>,StreamWindow<Integer>> in method public test() : void in class org.apache.flink.streaming.api.operators.windowing.WindowPartitionerTest |
From |
To |
|
Change Variable Type operators : Set<Tuple2<Integer,StreamOperator<?,?>>> to operators : Set<Tuple2<Integer,StreamOperator<?>>> in method private removeMergeBeforeFlatten(streamGraph StreamGraph) : void in class org.apache.flink.streaming.api.graph.WindowingOptimizer |
From |
To |
|
Change Variable Type chainableOperator : ChainableStreamOperator to chainableOperator : OneInputStreamOperator in method private createChainedCollector(chainedTaskConfig StreamConfig) : Output<X> in class org.apache.flink.streaming.runtime.tasks.OutputHandler |
From |
To |
|
Change Variable Type windowMerger : StreamOperator<StreamWindow<Integer>,StreamWindow<Integer>> to windowMerger : OneInputStreamOperator<StreamWindow<Integer>,StreamWindow<Integer>> in method public test() : void in class org.apache.flink.streaming.api.operators.windowing.WindowMergerTest |
From |
To |
|
Change Variable Type windowReducer : StreamOperator<StreamWindow<Integer>,StreamWindow<String>> to windowReducer : OneInputStreamOperator<StreamWindow<Integer>,StreamWindow<String>> in method public test() : void in class org.apache.flink.streaming.api.operators.windowing.WindowFolderTest |
From |
To |
|
Change Variable Type windowMapper : StreamOperator<StreamWindow<Integer>,StreamWindow<Integer>> to windowMapper : OneInputStreamOperator<StreamWindow<Integer>,StreamWindow<Integer>> in method public test() : void in class org.apache.flink.streaming.api.operators.windowing.WindowMapperTest |
From |
To |
|
Change Variable Type operatorSet : Set<Tuple2<Integer,StreamOperator<?,?>>> to operatorSet : Set<Tuple2<Integer,StreamOperator<?>>> in method public getOperators() : Set<Tuple2<Integer,StreamOperator<?>>> in class org.apache.flink.streaming.api.graph.StreamGraph |
From |
To |
|
Change Variable Type operator : StreamOperator<?,?> to operator : StreamOperator<?> in method private decorateNode(vertexID Integer, node JSONObject) : void in class org.apache.flink.streaming.api.graph.JSONGenerator |
From |
To |
|
Change Variable Type bufferOperator : StreamOperator<WindowEvent<OUT>,StreamWindow<OUT>> to bufferOperator : OneInputStreamOperator<WindowEvent<OUT>,StreamWindow<OUT>> in method private discretize(transformation WindowTransformation, windowBuffer WindowBuffer<OUT>) : DiscretizedStream<OUT> in class org.apache.flink.streaming.api.datastream.WindowedDataStream |
From |
To |
|
Change Variable Type outOperator : StreamOperator<?,?> to outOperator : StreamOperator<?> in method private isChainable(edge StreamEdge) : boolean in class org.apache.flink.streaming.api.graph.StreamingJobGraphGenerator |
From |
To |
|
Change Variable Type gbPartitioner : StreamOperator<StreamWindow<Integer>,StreamWindow<Integer>> to gbPartitioner : OneInputStreamOperator<StreamWindow<Integer>,StreamWindow<Integer>> in method public test() : void in class org.apache.flink.streaming.api.operators.windowing.WindowPartitionerTest |
From |
To |
|
Change Variable Type discretizer : StreamOperator<OUT,WindowEvent<OUT>> to discretizer : OneInputStreamOperator<OUT,WindowEvent<OUT>> in method private discretize(transformation WindowTransformation, windowBuffer WindowBuffer<OUT>) : DiscretizedStream<OUT> in class org.apache.flink.streaming.api.datastream.WindowedDataStream |
From |
To |
|
Change Variable Type entry : Tuple2<Integer,StreamOperator<?,?>> to entry : Tuple2<Integer,StreamOperator<?>> in method private removeMergeBeforeFlatten(streamGraph StreamGraph) : void in class org.apache.flink.streaming.api.graph.WindowingOptimizer |
From |
To |
|
Change Variable Type chainedOperator : StreamOperator<?,?> to chainedOperator : OneInputStreamOperator<?,?> in method public triggerCheckpoint(checkpointId long, timestamp long) : void in class org.apache.flink.streaming.runtime.tasks.StreamTask |
From |
To |
|
Change Variable Type wrapper : CollectorWrapper<OUT> to wrapper : CollectorWrapper in method private createChainedCollector(chainedTaskConfig StreamConfig) : Output<X> in class org.apache.flink.streaming.runtime.tasks.OutputHandler |
From |
To |
|
Rename Method private getTrainingData() : Integer renamed to public next() : Integer in class org.apache.flink.streaming.examples.ml.IncrementalLearningSkeleton.TrainingDataSource |
From |
To |
|
Rename Method protected callUserFunction1() : void renamed to public processElement1(element IN1) : void in class org.apache.flink.streaming.api.operators.co.CoStreamReduce |
From |
To |
|
Rename Method protected callUserFunction() : void renamed to public processElement(nextWindow StreamWindow<T>) : void in class org.apache.flink.streaming.api.operators.windowing.WindowMerger |
From |
To |
|
Rename Method public handleStream1() : void renamed to public processElement1(element IN1) : void in class org.apache.flink.streaming.api.operators.co.CoStreamGroupedReduce |
From |
To |
|
Rename Method protected handleStream2() : void renamed to public processElement2(element IN2) : void in class org.apache.flink.streaming.api.operators.co.CoStreamWindow |
From |
To |
|
Rename Method public handleStream2() : void renamed to public processElement2(element IN2) : void in class org.apache.flink.streaming.api.operators.co.CoStreamGroupedReduce |
From |
To |
|
Rename Method protected callUserFunction() : void renamed to public processElement(element IN) : void in class org.apache.flink.streaming.api.operators.StreamMap |
From |
To |
|
Rename Method protected callUserFunction() : void renamed to public processElement(element IN) : void in class org.apache.flink.streaming.api.operators.StreamProject |
From |
To |
|
Rename Method protected callUserFunction() : void renamed to public processElement(event WindowEvent<T>) : void in class org.apache.flink.streaming.api.operators.windowing.GroupedWindowBuffer |
From |
To |
|
Rename Method public setInputsOutputs() : void renamed to public registerInputOutput() : void in class org.apache.flink.streaming.runtime.tasks.StreamIterationHead |
From |
To |
|
Rename Method protected callUserFunction() : void renamed to public processElement(element IN) : void in class org.apache.flink.streaming.api.operators.StreamFilter |
From |
To |
|
Rename Method public getCollector() : Collector<OUT> renamed to public getOutput() : Collector<OUT> in class org.apache.flink.streaming.util.MockContext |
From |
To |
|
Rename Method protected callUserFunction1() : void renamed to public processElement1(element IN1) : void in class org.apache.flink.streaming.api.operators.co.CoStreamMap |
From |
To |
|
Rename Method public run() : void renamed to public processElement(element IN) : void in class org.apache.flink.streaming.api.operators.windowing.GroupedActiveDiscretizer |
From |
To |
|
Rename Method public cancel() : void renamed to public close() : void in class org.apache.flink.streaming.connectors.kafka.api.KafkaSource |
From |
To |
|
Rename Method protected handleStream1() : void renamed to public processElement1(element IN1) : void in class org.apache.flink.streaming.api.operators.co.CoStreamWindow |
From |
To |
|
Rename Method protected callUserFunction() : void renamed to public processElement(currentWindow StreamWindow<T>) : void in class org.apache.flink.streaming.api.operators.windowing.WindowPartitioner |
From |
To |
|
Rename Method protected callUserFunction() : void renamed to public processElement(window StreamWindow<T>) : void in class org.apache.flink.streaming.api.operators.windowing.WindowFlattener |
From |
To |
|
Rename Method protected callUserFunction() : void renamed to public processElement(element IN) : void in class org.apache.flink.streaming.api.operators.StreamReduce |
From |
To |
|
Rename Method private getNewData() : Integer renamed to public next() : Integer in class org.apache.flink.streaming.examples.ml.IncrementalLearningSkeleton.NewDataSource |
From |
To |
|
Rename Method protected callUserFunction() : void renamed to public processElement(element IN) : void in class org.apache.flink.streaming.api.operators.StreamGroupedReduce |
From |
To |
|
Rename Method public run() : void renamed to public processElement(element IN) : void in class org.apache.flink.streaming.api.operators.windowing.GroupedStreamDiscretizer |
From |
To |
|
Rename Method public cancel() : void renamed to public close() : void in class org.apache.flink.streaming.api.functions.source.SocketTextStreamFunction |
From |
To |
|
Rename Method protected callUserFunction() : void renamed to public processElement(element IN) : void in class org.apache.flink.streaming.api.operators.StreamFold |
From |
To |
|
Rename Method public cancel() : void renamed to public close() : void in class org.apache.flink.streaming.connectors.rabbitmq.RMQSource |
From |
To |
|
Rename Method protected callUserFunction() : void renamed to public processElement(windowEvent WindowEvent<T>) : void in class org.apache.flink.streaming.api.operators.windowing.StreamWindowBuffer |
From |
To |
|
Rename Method protected callUserFunction2() : void renamed to public processElement2(element IN2) : void in class org.apache.flink.streaming.api.operators.co.CoStreamMap |
From |
To |
|
Rename Method protected callUserFunction2() : void renamed to public processElement2(element IN2) : void in class org.apache.flink.streaming.api.operators.co.CoStreamReduce |
From |
To |
|
Rename Method public setInputsOutputs() : void renamed to public registerInputOutput() : void in class org.apache.flink.streaming.runtime.tasks.StreamIterationTail |
From |
To |
|
Rename Method protected callUserFunction() : void renamed to public processElement(element IN) : void in class org.apache.flink.streaming.api.operators.StreamGroupedFold |
From |
To |
|
Change Return Type List<ChainableStreamOperator<?,?>> to List<OneInputStreamOperator<?,?>> in method public getChainedOperators() : List<OneInputStreamOperator<?,?>> in class org.apache.flink.streaming.runtime.tasks.OutputHandler |
From |
To |
|
Change Return Type Collector<OUT> to Output<X> in method private createChainedCollector(chainedTaskConfig StreamConfig) : Output<X> in class org.apache.flink.streaming.runtime.tasks.OutputHandler |
From |
To |
|
Change Return Type StreamOperator<WindowEvent<OUT>,StreamWindow<OUT>> to OneInputStreamOperator<WindowEvent<OUT>,StreamWindow<OUT>> in method private getBufferOperator(windowBuffer WindowBuffer<OUT>) : OneInputStreamOperator<WindowEvent<OUT>,StreamWindow<OUT>> in class org.apache.flink.streaming.api.datastream.WindowedDataStream |
From |
To |
|
Change Return Type Collector<OUT> to Output<OUT> in method public getCollector() : Output<OUT> in class org.apache.flink.streaming.util.MockCoContext |
From |
To |
|
Change Return Type StreamOperator<?,?> to StreamOperator<?> in method public getOperator() : StreamOperator<?> in class org.apache.flink.streaming.api.graph.StreamNode |
From |
To |
|
Change Return Type Set<Tuple2<Integer,StreamOperator<?,?>>> to Set<Tuple2<Integer,StreamOperator<?>>> in method public getOperators() : Set<Tuple2<Integer,StreamOperator<?>>> in class org.apache.flink.streaming.api.graph.StreamGraph |
From |
To |
|
Change Return Type StreamOperator<OUT,WindowEvent<OUT>> to OneInputStreamOperator<OUT,WindowEvent<OUT>> in method private getDiscretizer() : OneInputStreamOperator<OUT,WindowEvent<OUT>> in class org.apache.flink.streaming.api.datastream.WindowedDataStream |
From |
To |
|
Change Return Type CoStreamOperator<IN1,IN2,OUT> to TwoInputStreamOperator<IN1,IN2,OUT> in method protected getReduceOperator(coReducer CoReduceFunction<IN1,IN2,OUT>) : TwoInputStreamOperator<IN1,IN2,OUT> in class org.apache.flink.streaming.api.datastream.ConnectedDataStream |
From |
To |
|
Change Attribute Type operator : StreamOperator<?,?> to operator : StreamOperator<?> in class org.apache.flink.streaming.api.graph.StreamNode |
From |
To |
|
Change Attribute Type operator : StreamOperator<?,?> to operator : StreamOperator<?> in class org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator |
From |
To |
|
Change Attribute Type chainedOperators : List<ChainableStreamOperator<?,?>> to chainedOperators : List<OneInputStreamOperator<?,?>> in class org.apache.flink.streaming.runtime.tasks.OutputHandler |
From |
To |
|
Change Attribute Type streamOperator : StreamOperator<IN,OUT> to streamOperator : O in class org.apache.flink.streaming.runtime.tasks.StreamTask |
From |
To |
|
Change Attribute Type collector : Collector<OUT> to collector : Output<OUT> in class org.apache.flink.streaming.util.MockCoContext |
From |
To |
|
Change Attribute Type collector : Collector<OUT> to output : MockOutput<OUT> in class org.apache.flink.streaming.util.MockContext |
From |
To |
|
Change Attribute Type vertex : StreamTask<?,OUT> to vertex : StreamTask<OUT,?> in class org.apache.flink.streaming.runtime.tasks.OutputHandler |
From |
To |
|
Change Attribute Type outerCollector : Collector<OUT> to outerOutput : Output<OUT> in class org.apache.flink.streaming.runtime.tasks.OutputHandler |
From |
To |