|
Rename Method public abstract invoke() : void renamed to public abstract run() : void in class org.apache.flink.streaming.api.operators.StreamOperator |
From |
To |
|
Rename Method public setInvokable(vertexID Integer, invokableObject StreamInvokable<IN,OUT>) : void renamed to public setOperator(vertexID Integer, operatorObject StreamOperator<IN,OUT>) : void in class org.apache.flink.streaming.api.graph.StreamGraph |
From |
To |
|
Rename Method protected setInvokable() : void renamed to protected setOperator() : void in class org.apache.flink.streaming.runtime.tasks.StreamTask |
From |
To |
|
Rename Method public setUserInvokable(invokableObject StreamInvokable<?,?>) : void renamed to public setStreamOperator(operator StreamOperator<?,?>) : void in class org.apache.flink.streaming.api.graph.StreamConfig |
From |
To |
|
Rename Method public invoke() : void renamed to public run() : void in class org.apache.flink.streaming.api.operators.StreamSink |
From |
To |
|
Rename Method private getBufferInvokable(windowBuffer WindowBuffer<OUT>) : StreamInvokable<WindowEvent<OUT>,StreamWindow<OUT>> renamed to private getBufferOperator(windowBuffer WindowBuffer<OUT>) : StreamOperator<WindowEvent<OUT>,StreamWindow<OUT>> in class org.apache.flink.streaming.api.datastream.WindowedDataStream |
From |
To |
|
Rename Method public invoke() : void renamed to public run() : void in class org.apache.flink.streaming.api.operators.StreamProject |
From |
To |
|
Rename Method public invoke() : void renamed to public run() : void in class org.apache.flink.streaming.api.operators.windowing.GroupedWindowBuffer |
From |
To |
|
Rename Method public getUserInvokable(cl ClassLoader) : T renamed to public getStreamOperator(cl ClassLoader) : T in class org.apache.flink.streaming.api.graph.StreamConfig |
From |
To |
|
Rename Method public getInvokables() : Set<Tuple2<Integer,StreamInvokable<?,?>>> renamed to public getOperators() : Set<Tuple2<Integer,StreamOperator<?,?>>> in class org.apache.flink.streaming.api.graph.StreamGraph |
From |
To |
|
Rename Method public setInvokable(invokable StreamInvokable<?,?>) : void renamed to public setOperator(operator StreamOperator<?,?>) : void in class org.apache.flink.streaming.api.graph.StreamNode |
From |
To |
|
Rename Method public invoke() : void renamed to public run() : void in class org.apache.flink.streaming.api.operators.windowing.StreamWindowBuffer |
From |
To |
|
Rename Method public invoke() : void renamed to public run() : void in class org.apache.flink.streaming.api.operators.StreamSource |
From |
To |
|
Rename Method public invoke() : void renamed to public run() : void in class org.apache.flink.streaming.api.operators.co.CoStreamOperator |
From |
To |
|
Rename Method protected getReduceInvokable(coReducer CoReduceFunction<IN1,IN2,OUT>) : CoInvokable<IN1,IN2,OUT> renamed to protected getReduceOperator(coReducer CoReduceFunction<IN1,IN2,OUT>) : CoStreamOperator<IN1,IN2,OUT> in class org.apache.flink.streaming.api.datastream.ConnectedDataStream |
From |
To |
|
Rename Method public invoke() : void renamed to public run() : void in class org.apache.flink.streaming.api.operators.windowing.StreamDiscretizer |
From |
To |
|
Rename Method public invoke() : void renamed to public run() : void in class org.apache.flink.streaming.api.operators.windowing.GroupedActiveDiscretizer |
From |
To |
|
Rename Method public invoke() : void renamed to public run() : void in class org.apache.flink.streaming.api.operators.windowing.WindowMerger |
From |
To |
|
Rename Method public invoke() : void renamed to public run() : void in class org.apache.flink.streaming.api.operators.StreamFilter |
From |
To |
|
Rename Method protected newVertex() : int renamed to protected newTask() : int in class org.apache.flink.streaming.runtime.tasks.StreamTask |
From |
To |
|
Rename Method public invoke() : void renamed to public run() : void in class org.apache.flink.streaming.api.operators.windowing.GroupedStreamDiscretizer |
From |
To |
|
Rename Method public testWindowInvokableWithCountPolicy() : void renamed to public testDiscretizer2() : void in class org.apache.flink.streaming.api.operators.windowing.StreamDiscretizerTest |
From |
To |
|
Rename Method public invoke() : void renamed to public run() : void in class org.apache.flink.streaming.api.operators.StreamReduce |
From |
To |
|
Rename Method public testWindowInvokableWithTimePolicy() : void renamed to public testDiscretizer() : void in class org.apache.flink.streaming.api.operators.windowing.StreamDiscretizerTest |
From |
To |
|
Rename Method public invoke() : void renamed to public run() : void in class org.apache.flink.streaming.api.operators.StreamFold |
From |
To |
|
Rename Method public mapInvokableTest() : void renamed to public mapTest() : void in class org.apache.flink.streaming.api.operators.MapTest |
From |
To |
|
Rename Method public invoke() : void renamed to public run() : void in class org.apache.flink.streaming.api.operators.StreamMap |
From |
To |
|
Rename Method public invoke() : void renamed to public run() : void in class org.apache.flink.streaming.api.operators.windowing.WindowPartitioner |
From |
To |
|
Change Parameter Type invokable : StreamInvokable<OUT,R> to operator : StreamOperator<OUT,R> in method public transform(operatorName String, outTypeInfo TypeInformation<R>, operator StreamOperator<OUT,R>) : SingleOutputStreamOperator<R,?> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Parameter Type invokable : CoInvokable<IN1,IN2,OUT> to operator : CoStreamOperator<IN1,IN2,OUT> in method public createAndExecute(operator CoStreamOperator<IN1,IN2,OUT>, input1 List<IN1>, input2 List<IN2>) : List<OUT> in class org.apache.flink.streaming.util.MockCoContext |
From |
To |
|
Change Parameter Type invokable : StreamInvokable<?,?> 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 invokable : StreamInvokable<IN,R> to operator : StreamOperator<IN,R> in method public transform(operatorName String, outTypeInfo TypeInformation<R>, operator StreamOperator<IN,R>) : SingleOutputStreamOperator<R,?> in class org.apache.flink.streaming.api.datastream.IterativeDataStream |
From |
To |
|
Change Parameter Type invokableObject : StreamInvokable<?,?> to operator : StreamOperator<?,?> in method public setStreamOperator(operator StreamOperator<?,?>) : void in class org.apache.flink.streaming.api.graph.StreamConfig |
From |
To |
|
Change Parameter Type invokable : StreamInvokable<StreamWindow<OUT>,StreamWindow<R>> to operator : StreamOperator<StreamWindow<OUT>,StreamWindow<R>> in method private transform(transformation WindowTransformation, operatorName String, retType TypeInformation<R>, operator StreamOperator<StreamWindow<OUT>,StreamWindow<R>>) : DiscretizedStream<R> in class org.apache.flink.streaming.api.datastream.DiscretizedStream |
From |
To |
|
Change Parameter Type taskInvokableObject : CoInvokable<IN1,IN2,OUT> to taskoperatorObject : CoStreamOperator<IN1,IN2,OUT> in method public addCoOperator(vertexID Integer, taskoperatorObject CoStreamOperator<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 invokableObject : StreamInvokable<?,?> 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 streamComponent : StreamVertex<IN,?> to streamComponent : StreamTask<IN,?> in method public InputHandler(streamComponent StreamTask<IN,?>) in class org.apache.flink.streaming.runtime.tasks.InputHandler |
From |
To |
|
Change Parameter Type invokable : StreamInvokable<?,?> to operator : StreamOperator<?,?> in method public setOperator(operator StreamOperator<?,?>) : void in class org.apache.flink.streaming.api.graph.StreamNode |
From |
To |
|
Change Parameter Type vertex : StreamVertex<?,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 invokable : StreamInvokable<IN,OUT> to operator : StreamOperator<IN,OUT> in method public createAndExecute(operator StreamOperator<IN,OUT>, inputs List<IN>) : List<OUT> in class org.apache.flink.streaming.util.MockContext |
From |
To |
|
Change Parameter Type invokable : StreamInvokable<?,?> 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 invokableObject : StreamInvokable<IN,OUT> to operatorObject : StreamOperator<IN,OUT> in method public setOperator(vertexID Integer, operatorObject StreamOperator<IN,OUT>) : void in class org.apache.flink.streaming.api.graph.StreamGraph |
From |
To |
|
Change Parameter Type invokable : StreamInvokable<?,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 invokableObject : StreamInvokable<IN,OUT> to operatorObject : StreamOperator<IN,OUT> in method public addOperator(vertexID Integer, operatorObject StreamOperator<IN,OUT>, inTypeInfo TypeInformation<IN>, outTypeInfo TypeInformation<OUT>, operatorName String) : void in class org.apache.flink.streaming.api.graph.StreamGraph |
From |
To |
|
Change Parameter Type functionInvokable : CoInvokable<IN1,IN2,OUT> to operator : CoStreamOperator<IN1,IN2,OUT> in method public addCoFunction(functionName String, outTypeInfo TypeInformation<OUT>, operator CoStreamOperator<IN1,IN2,OUT>) : SingleOutputStreamOperator<OUT,?> in class org.apache.flink.streaming.api.datastream.ConnectedDataStream |
From |
To |
|
Change Parameter Type invokable : StreamInvokable<?,?> to operator : StreamOperator<?,?> in method protected DataStreamSink(environment StreamExecutionEnvironment, operatorType String, outTypeInfo TypeInformation<IN>, operator StreamOperator<?,?>) in class org.apache.flink.streaming.api.datastream.DataStreamSink |
From |
To |
|
Change Parameter Type invokableObject : StreamInvokable<IN,OUT> to operatorObject : StreamOperator<IN,OUT> in method public addSource(vertexID Integer, operatorObject StreamOperator<IN,OUT>, inTypeInfo TypeInformation<IN>, outTypeInfo TypeInformation<OUT>, operatorName String) : void in class org.apache.flink.streaming.api.graph.StreamGraph |
From |
To |
|
Rename Variable invokable : CoWindowInvokable<I1,I2,R> to operator : CoStreamWindow<I1,I2,R> in method public with(function CrossFunction<I1,I2,R>) : SingleOutputStreamOperator<R,?> in class org.apache.flink.streaming.api.datastream.temporal.StreamCrossOperator.CrossWindow |
From |
To |
|
Rename Variable chainableInvokable : ChainableInvokable to chainableOperator : ChainableStreamOperator in method private createChainedCollector(chainedTaskConfig StreamConfig) : Collector<OUT> in class org.apache.flink.streaming.runtime.tasks.OutputHandler |
From |
To |
|
Rename Variable invokable1 : StreamReduceInvokable<Integer> to operator1 : StreamReduce<Integer> in method public test() : void in class org.apache.flink.streaming.api.operators.StreamReduceTest |
From |
To |
|
Rename Variable invokable : CounterInvokable<String> to operator : StreamCounter<String> in method public counterTest() : void in class org.apache.flink.streaming.api.operators.CounterTest |
From |
To |
|
Rename Variable invokable : ProjectInvokable<Tuple5<Integer,String,Integer,String,Integer>,Tuple3<Integer,Integer,String>> to operator : StreamProject<Tuple5<Integer,String,Integer,String,Integer>,Tuple3<Integer,Integer,String>> in method public test() : void in class org.apache.flink.streaming.api.operators.ProjectTest |
From |
To |
|
Rename Variable sinkInvokable : StreamInvokable<OUT,OUT> to sinkOperator : StreamOperator<OUT,OUT> in method public addSink(sinkFunction SinkFunction<OUT>) : DataStreamSink<OUT> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Rename Variable invokable : FlatMapInvokable<Integer,Integer> to operator : StreamFlatMap<Integer,Integer> in method public flatMapTest() : void in class org.apache.flink.streaming.api.operators.FlatMapTest |
From |
To |
|
Rename Variable invokableSet : Set<Tuple2<Integer,StreamInvokable<?,?>>> 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 |
|
Rename Variable invokable : GroupedReduceInvokable<OUT> to operator : StreamGroupedReduce<OUT> in method protected aggregate(aggregate AggregationFunction<OUT>) : SingleOutputStreamOperator<OUT,?> in class org.apache.flink.streaming.api.datastream.GroupedDataStream |
From |
To |
|
Rename Variable sourceInvokable : StreamInvokable<OUT,OUT> to sourceOperator : StreamOperator<OUT,OUT> in method private addSource(function SourceFunction<OUT>, outTypeInfo TypeInformation<OUT>, sourceName String) : DataStreamSource<OUT> in class org.apache.flink.streaming.api.environment.StreamExecutionEnvironment |
From |
To |
|
Rename Variable invokable : FilterInvokable<Integer> to operator : StreamFilter<Integer> in method public test() : void in class org.apache.flink.streaming.api.operators.FilterTest |
From |
To |
|
Rename Variable invokables : Set<Tuple2<Integer,StreamInvokable<?,?>>> to operators : Set<Tuple2<Integer,StreamOperator<?,?>>> in method private removeMergeBeforeFlatten(streamGraph StreamGraph) : void in class org.apache.flink.streaming.api.graph.WindowingOptimizer |
From |
To |
|
Rename Variable invokable1 : GroupedFoldInvokable<Integer,String> to operator1 : StreamGroupedFold<Integer,String> in method public test() : void in class org.apache.flink.streaming.api.operators.GroupedFoldTest |
From |
To |
|
Rename Variable bufferInvokable : StreamInvokable<WindowEvent<OUT>,StreamWindow<OUT>> to bufferOperator : StreamOperator<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 |
|
Rename Variable invokable : CoWindowInvokable<I1,I2,OUT> to operator : CoStreamWindow<I1,I2,OUT> in method public with(joinFunction JoinFunction<I1,I2,OUT>) : SingleOutputStreamOperator<OUT,?> in class org.apache.flink.streaming.api.datastream.temporal.StreamJoinOperator.JoinedStream |
From |
To |
|
Rename Variable outInvokable : StreamInvokable<?,?> to outOperator : StreamOperator<?,?> in method private isChainable(edge StreamEdge) : boolean in class org.apache.flink.streaming.api.graph.StreamingJobGraphGenerator |
From |
To |
|
Rename Variable invokable : StreamInvokable<?,?> to operator : StreamOperator<?,?> in method private decorateNode(vertexID Integer, node JSONObject) : void in class org.apache.flink.streaming.api.graph.JSONGenerator |
From |
To |
|
Rename Variable invokable : StreamReduceInvokable<OUT> to operator : StreamReduce<OUT> in method protected aggregate(aggregate AggregationFunction<OUT>) : SingleOutputStreamOperator<OUT,?> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Rename Variable invokable1 : GroupedReduceInvokable<Integer> to operator1 : StreamGroupedReduce<Integer> in method public test() : void in class org.apache.flink.streaming.api.operators.GroupedReduceTest |
From |
To |
|
Rename Variable invokable : MapInvokable<Integer,String> to operator : StreamMap<Integer,String> in method public mapTest() : void in class org.apache.flink.streaming.api.operators.MapTest |
From |
To |
|
Rename Variable invokables : Set<Tuple2<Integer,StreamInvokable<?,?>>> to operators : Set<Tuple2<Integer,StreamOperator<?,?>>> in method private setDiscretizerReuse(streamGraph StreamGraph) : void in class org.apache.flink.streaming.api.graph.WindowingOptimizer |
From |
To |
|
Rename Variable invokable : CoReduceInvokable<IN1,IN2,OUT> to operator : CoStreamReduce<IN1,IN2,OUT> in method protected getReduceOperator(coReducer CoReduceFunction<IN1,IN2,OUT>) : CoStreamOperator<IN1,IN2,OUT> in class org.apache.flink.streaming.api.datastream.ConnectedDataStream |
From |
To |
|
Rename Variable headInvokable : StreamInvokable<?,?> to headOperator : StreamOperator<?,?> in method private isChainable(edge StreamEdge) : boolean in class org.apache.flink.streaming.api.graph.StreamingJobGraphGenerator |
From |
To |
|
Rename Variable invokable : ChainableInvokable<?,?> to operator : ChainableStreamOperator<?,?> in method protected openOperator() : void in class org.apache.flink.streaming.runtime.tasks.StreamTask |
From |
To |
|
Rename Variable invokable1 : StreamFoldInvokable<Integer,String> to operator1 : StreamFold<Integer,String> in method public test() : void in class org.apache.flink.streaming.api.operators.StreamFoldTest |
From |
To |
|
Move And Rename Class org.apache.flink.streaming.api.invokable.StreamInvokable moved and renamed to org.apache.flink.streaming.api.operators.StreamOperator |
From |
To |
|
Move And Rename Class org.apache.flink.streaming.api.invokable.operator.co.CoMapInvokable moved and renamed to org.apache.flink.streaming.api.operators.co.CoStreamMap |
From |
To |
|
Move And Rename Class org.apache.flink.streaming.api.invokable.operator.MapInvokable moved and renamed to org.apache.flink.streaming.api.operators.StreamMap |
From |
To |
|
Move And Rename Class org.apache.flink.streaming.api.invokable.operator.StreamReduceInvokable moved and renamed to org.apache.flink.streaming.api.operators.StreamReduce |
From |
To |
|
Move And Rename Class org.apache.flink.streaming.api.invokable.operator.windowing.WindowBufferInvokable moved and renamed to org.apache.flink.streaming.api.operators.windowing.StreamWindowBuffer |
From |
To |
|
Move And Rename Class org.apache.flink.streaming.api.streamvertex.StreamVertexException moved and renamed to org.apache.flink.streaming.runtime.tasks.StreamTaskException |
From |
To |
|
Move And Rename Class org.apache.flink.streaming.api.invokable.operator.co.CoFlatMapInvokable moved and renamed to org.apache.flink.streaming.api.operators.co.CoStreamFlatMap |
From |
To |
|
Move And Rename Class org.apache.flink.streaming.api.invokable.operator.StreamFoldInvokable moved and renamed to org.apache.flink.streaming.api.operators.StreamFold |
From |
To |
|
Move And Rename Class org.apache.flink.streaming.api.invokable.operator.CounterInvokableTest moved and renamed to org.apache.flink.streaming.api.operators.CounterTest |
From |
To |
|
Move And Rename Class org.apache.flink.streaming.api.invokable.operator.GroupedReduceInvokableTest moved and renamed to org.apache.flink.streaming.api.operators.GroupedReduceTest |
From |
To |
|
Move And Rename Class org.apache.flink.streaming.api.streamvertex.StreamVertex moved and renamed to org.apache.flink.streaming.runtime.tasks.StreamTask |
From |
To |
|
Move And Rename Class org.apache.flink.streaming.api.invokable.operator.co.CoInvokable moved and renamed to org.apache.flink.streaming.api.operators.co.CoStreamOperator |
From |
To |
|
Move And Rename Class org.apache.flink.streaming.api.invokable.operator.co.CoGroupedReduceInvokable moved and renamed to org.apache.flink.streaming.api.operators.co.CoStreamGroupedReduce |
From |
To |
|
Move And Rename Class org.apache.flink.streaming.api.invokable.operator.windowing.GroupedWindowBufferInvokable moved and renamed to org.apache.flink.streaming.api.operators.windowing.GroupedWindowBuffer |
From |
To |
|
Move And Rename Class org.apache.flink.streaming.api.invokable.operator.co.CoWindowInvokable moved and renamed to org.apache.flink.streaming.api.operators.co.CoStreamWindow |
From |
To |
|
Move And Rename Class org.apache.flink.streaming.api.invokable.operator.FilterInvokable moved and renamed to org.apache.flink.streaming.api.operators.StreamFilter |
From |
To |
|
Move And Rename Class org.apache.flink.streaming.api.invokable.operator.GroupedFoldInvokable moved and renamed to org.apache.flink.streaming.api.operators.StreamGroupedFold |
From |
To |
|
Move And Rename Class org.apache.flink.streaming.api.invokable.operator.ProjectInvokable moved and renamed to org.apache.flink.streaming.api.operators.StreamProject |
From |
To |
|
Move And Rename Class org.apache.flink.streaming.api.invokable.operator.co.CoReduceInvokable moved and renamed to org.apache.flink.streaming.api.operators.co.CoStreamReduce |
From |
To |
|
Move And Rename Class org.apache.flink.streaming.api.invokable.operator.GroupedReduceInvokable moved and renamed to org.apache.flink.streaming.api.operators.StreamGroupedReduce |
From |
To |
|
Move And Rename Class org.apache.flink.streaming.api.streamvertex.CoStreamVertex moved and renamed to org.apache.flink.streaming.runtime.tasks.CoStreamTask |
From |
To |
|
Move And Rename Class org.apache.flink.streaming.api.invokable.ChainableInvokable moved and renamed to org.apache.flink.streaming.api.operators.ChainableStreamOperator |
From |
To |
|
Move And Rename Class org.apache.flink.streaming.api.invokable.SinkInvokable moved and renamed to org.apache.flink.streaming.api.operators.StreamSink |
From |
To |
|
Move And Rename Class org.apache.flink.streaming.api.invokable.operator.GroupedFoldInvokableTest moved and renamed to org.apache.flink.streaming.api.operators.GroupedFoldTest |
From |
To |
|
Move And Rename Class org.apache.flink.streaming.api.invokable.SourceInvokable moved and renamed to org.apache.flink.streaming.api.operators.StreamSource |
From |
To |
|
Move Class org.apache.flink.streaming.api.invokable.operator.windowing.WindowPartitioner moved to org.apache.flink.streaming.api.operators.windowing.WindowPartitioner |
From |
To |
|
Move Class org.apache.flink.streaming.api.function.sink.SinkFunction moved to org.apache.flink.streaming.api.functions.sink.SinkFunction |
From |
To |
|
Move Class org.apache.flink.streaming.api.function.source.FileSourceFunction moved to org.apache.flink.streaming.api.functions.source.FileSourceFunction |
From |
To |
|
Move Class org.apache.flink.streaming.api.invokable.operator.co.CoGroupedReduceTest moved to org.apache.flink.streaming.api.operators.co.CoGroupedReduceTest |
From |
To |
|
Move Class org.apache.flink.streaming.api.invokable.operator.MapTest moved to org.apache.flink.streaming.api.operators.MapTest |
From |
To |
|
Move Class org.apache.flink.streaming.api.function.co.CoWindowFunction moved to org.apache.flink.streaming.api.functions.co.CoWindowFunction |
From |
To |
|
Move Class org.apache.flink.streaming.api.invokable.operator.windowing.WindowMerger moved to org.apache.flink.streaming.api.operators.windowing.WindowMerger |
From |
To |
|
Move Class org.apache.flink.streaming.api.function.source.FileReadFunction moved to org.apache.flink.streaming.api.functions.source.FileReadFunction |
From |
To |
|
Move Class org.apache.flink.streaming.api.invokable.operator.windowing.ParallelMergeTest moved to org.apache.flink.streaming.api.operators.windowing.ParallelMergeTest |
From |
To |
|
Move Class org.apache.flink.streaming.api.JSONGenerator moved to org.apache.flink.streaming.api.graph.JSONGenerator |
From |
To |
|
Move Class org.apache.flink.streaming.api.function.sink.FileSinkFunction moved to org.apache.flink.streaming.api.functions.sink.FileSinkFunction |
From |
To |
|
Move Class org.apache.flink.streaming.api.invokable.operator.windowing.WindowReducerTest moved to org.apache.flink.streaming.api.operators.windowing.WindowReducerTest |
From |
To |
|
Move Class org.apache.flink.streaming.api.function.co.CoMapFunction moved to org.apache.flink.streaming.api.functions.co.CoMapFunction |
From |
To |
|
Move Class org.apache.flink.streaming.api.streamvertex.OutputHandler moved to org.apache.flink.streaming.runtime.tasks.OutputHandler |
From |
To |
|
Move Class org.apache.flink.streaming.api.function.WindowMapFunction moved to org.apache.flink.streaming.api.functions.WindowMapFunction |
From |
To |
|
Move Class org.apache.flink.streaming.api.streamvertex.InputHandler moved to org.apache.flink.streaming.runtime.tasks.InputHandler |
From |
To |
|
Move Class org.apache.flink.streaming.state.OperatorStateTest moved to org.apache.flink.streaming.api.state.OperatorStateTest |
From |
To |
|
Move Class org.apache.flink.streaming.api.invokable.operator.FilterTest moved to org.apache.flink.streaming.api.operators.FilterTest |
From |
To |
|
Move Class org.apache.flink.streaming.io.StreamingReader moved to org.apache.flink.streaming.runtime.io.StreamingReader |
From |
To |
|
Move Class org.apache.flink.streaming.api.function.co.CoFlatMapFunction moved to org.apache.flink.streaming.api.functions.co.CoFlatMapFunction |
From |
To |
|
Move Class org.apache.flink.streaming.api.invokable.operator.co.CoStreamReduceTest moved to org.apache.flink.streaming.api.operators.co.CoStreamReduceTest |
From |
To |
|
Move Class org.apache.flink.streaming.api.function.aggregation.Comparator moved to org.apache.flink.streaming.api.functions.aggregation.Comparator |
From |
To |
|
Move Class org.apache.flink.streaming.state.PartitionableState moved to org.apache.flink.streaming.api.state.PartitionableState |
From |
To |
|
Move Class org.apache.flink.streaming.io.CoReaderIterator moved to org.apache.flink.streaming.runtime.io.CoReaderIterator |
From |
To |
|
Move Class org.apache.flink.streaming.partitioner.BroadcastPartitioner moved to org.apache.flink.streaming.runtime.partitioner.BroadcastPartitioner |
From |
To |
|
Move Class org.apache.flink.streaming.api.function.source.FromElementsFunction moved to org.apache.flink.streaming.api.functions.source.FromElementsFunction |
From |
To |
|
Move Class org.apache.flink.streaming.api.function.co.RichCoMapFunction moved to org.apache.flink.streaming.api.functions.co.RichCoMapFunction |
From |
To |
|
Move Class org.apache.flink.streaming.io.SpillReader moved to org.apache.flink.streaming.runtime.io.SpillReader |
From |
To |
|
Move Class org.apache.flink.streaming.partitioner.ShufflePartitionerTest moved to org.apache.flink.streaming.runtime.partitioner.ShufflePartitionerTest |
From |
To |
|
Move Class org.apache.flink.streaming.api.function.co.RichCoFlatMapFunction moved to org.apache.flink.streaming.api.functions.co.RichCoFlatMapFunction |
From |
To |
|
Move Class org.apache.flink.streaming.api.function.source.SocketTextStreamFunction moved to org.apache.flink.streaming.api.functions.source.SocketTextStreamFunction |
From |
To |
|
Move Class org.apache.flink.streaming.io.IndexedReaderIterator moved to org.apache.flink.streaming.runtime.io.IndexedReaderIterator |
From |
To |
|
Move Class org.apache.flink.streaming.io.InputGateFactory moved to org.apache.flink.streaming.runtime.io.InputGateFactory |
From |
To |
|
Move Class org.apache.flink.streaming.api.invokable.operator.windowing.WindowReducer moved to org.apache.flink.streaming.api.operators.windowing.WindowReducer |
From |
To |
|
Move Class org.apache.flink.streaming.api.function.sink.WriteFormatAsCsv moved to org.apache.flink.streaming.api.functions.sink.WriteFormatAsCsv |
From |
To |
|
Move Class org.apache.flink.streaming.api.StreamGraph moved to org.apache.flink.streaming.api.graph.StreamGraph |
From |
To |
|
Move Class org.apache.flink.streaming.io.BarrierBuffer moved to org.apache.flink.streaming.runtime.io.BarrierBuffer |
From |
To |
|
Move Class org.apache.flink.streaming.partitioner.ForwardPartitionerTest moved to org.apache.flink.streaming.runtime.partitioner.ForwardPartitionerTest |
From |
To |
|
Move Class org.apache.flink.streaming.api.datastream.temporaloperator.StreamJoinOperator moved to org.apache.flink.streaming.api.datastream.temporal.StreamJoinOperator |
From |
To |
|
Move Class org.apache.flink.streaming.api.invokable.operator.co.CoWindowTest moved to org.apache.flink.streaming.api.operators.co.CoWindowTest |
From |
To |
|
Move Class org.apache.flink.streaming.api.invokable.operator.windowing.GroupedStreamDiscretizerTest moved to org.apache.flink.streaming.api.operators.windowing.GroupedStreamDiscretizerTest |
From |
To |
|
Move Class org.apache.flink.streaming.api.invokable.operator.windowing.WindowFlattenerTest moved to org.apache.flink.streaming.api.operators.windowing.WindowFlattenerTest |
From |
To |
|
Move Class org.apache.flink.streaming.api.invokable.operator.windowing.WindowPartitionerTest moved to org.apache.flink.streaming.api.operators.windowing.WindowPartitionerTest |
From |
To |
|
Move Class org.apache.flink.streaming.io.CoRecordReaderTest moved to org.apache.flink.streaming.runtime.io.CoRecordReaderTest |
From |
To |
|
Move Class org.apache.flink.streaming.api.invokable.operator.co.CoMapTest moved to org.apache.flink.streaming.api.operators.co.CoMapTest |
From |
To |
|
Move Class org.apache.flink.streaming.api.function.sink.FileSinkFunctionByMillis moved to org.apache.flink.streaming.api.functions.sink.FileSinkFunctionByMillis |
From |
To |
|
Move Class org.apache.flink.streaming.partitioner.GlobalPartitioner moved to org.apache.flink.streaming.runtime.partitioner.GlobalPartitioner |
From |
To |
|
Move Class org.apache.flink.streaming.api.invokable.operator.windowing.WindowMergerTest moved to org.apache.flink.streaming.api.operators.windowing.WindowMergerTest |
From |
To |
|
Move Class org.apache.flink.streaming.api.streamvertex.StreamVertexTest moved to org.apache.flink.streaming.api.streamtask.StreamVertexTest |
From |
To |
|
Move Class org.apache.flink.streaming.api.streamrecord.StreamRecordSerializer moved to org.apache.flink.streaming.runtime.streamrecord.StreamRecordSerializer |
From |
To |
|
Move Class org.apache.flink.streaming.io.SpillingBufferOrEvent moved to org.apache.flink.streaming.runtime.io.SpillingBufferOrEvent |
From |
To |
|
Move Class org.apache.flink.streaming.api.function.sink.WriteFormat moved to org.apache.flink.streaming.api.functions.sink.WriteFormat |
From |
To |
|
Move Class org.apache.flink.streaming.api.function.sink.PrintSinkFunction moved to org.apache.flink.streaming.api.functions.sink.PrintSinkFunction |
From |
To |
|
Move Class org.apache.flink.streaming.io.SpillingBufferOrEventTest moved to org.apache.flink.streaming.runtime.io.SpillingBufferOrEventTest |
From |
To |
|
Move Class org.apache.flink.streaming.io.IndexedMutableReader moved to org.apache.flink.streaming.runtime.io.IndexedMutableReader |
From |
To |
|
Move Class org.apache.flink.streaming.io.StreamingMutableRecordReader moved to org.apache.flink.streaming.runtime.io.StreamingMutableRecordReader |
From |
To |
|
Move Class org.apache.flink.streaming.io.CoRecordReader moved to org.apache.flink.streaming.runtime.io.CoRecordReader |
From |
To |
|
Move Class org.apache.flink.streaming.api.function.co.RichCoReduceFunction moved to org.apache.flink.streaming.api.functions.co.RichCoReduceFunction |
From |
To |
|
Move Class org.apache.flink.streaming.api.invokable.operator.windowing.WindowFolderTest moved to org.apache.flink.streaming.api.operators.windowing.WindowFolderTest |
From |
To |
|
Move Class org.apache.flink.streaming.api.invokable.operator.StreamReduceTest moved to org.apache.flink.streaming.api.operators.StreamReduceTest |
From |
To |
|
Move Class org.apache.flink.streaming.partitioner.GlobalPartitionerTest moved to org.apache.flink.streaming.runtime.partitioner.GlobalPartitionerTest |
From |
To |
|
Move Class org.apache.flink.streaming.api.streamvertex.StreamIterationTail moved to org.apache.flink.streaming.runtime.tasks.StreamIterationTail |
From |
To |
|
Move Class org.apache.flink.streaming.io.BarrierBufferTest moved to org.apache.flink.streaming.runtime.io.BarrierBufferTest |
From |
To |
|
Move Class org.apache.flink.streaming.api.function.co.RichCoWindowFunction moved to org.apache.flink.streaming.api.functions.co.RichCoWindowFunction |
From |
To |
|
Move Class org.apache.flink.streaming.io.BufferSpiller moved to org.apache.flink.streaming.runtime.io.BufferSpiller |
From |
To |
|
Move Class org.apache.flink.streaming.api.function.source.SourceFunction moved to org.apache.flink.streaming.api.functions.source.SourceFunction |
From |
To |
|
Move Class org.apache.flink.streaming.api.invokable.operator.co.SelfConnectionTest moved to org.apache.flink.streaming.api.operators.co.SelfConnectionTest |
From |
To |
|
Move Class org.apache.flink.streaming.api.invokable.operator.windowing.WindowPartExtractor moved to org.apache.flink.streaming.api.operators.windowing.WindowPartExtractor |
From |
To |
|
Move Class org.apache.flink.streaming.api.function.sink.RichSinkFunction moved to org.apache.flink.streaming.api.functions.sink.RichSinkFunction |
From |
To |
|
Move Class org.apache.flink.streaming.api.invokable.operator.windowing.GroupedActiveDiscretizer moved to org.apache.flink.streaming.api.operators.windowing.GroupedActiveDiscretizer |
From |
To |
|
Move Class org.apache.flink.streaming.api.WindowingOptimizer moved to org.apache.flink.streaming.api.graph.WindowingOptimizer |
From |
To |
|
Move Class org.apache.flink.streaming.api.datastream.temporaloperator.TemporalWindow moved to org.apache.flink.streaming.api.datastream.temporal.TemporalWindow |
From |
To |
|
Move Class org.apache.flink.streaming.partitioner.FieldsPartitioner moved to org.apache.flink.streaming.runtime.partitioner.FieldsPartitioner |
From |
To |
|
Move Class org.apache.flink.streaming.api.invokable.operator.windowing.StreamDiscretizer moved to org.apache.flink.streaming.api.operators.windowing.StreamDiscretizer |
From |
To |
|
Move Class org.apache.flink.streaming.api.invokable.operator.windowing.ParallelMerge moved to org.apache.flink.streaming.api.operators.windowing.ParallelMerge |
From |
To |
|
Move Class org.apache.flink.streaming.api.function.co.CrossWindowFunction moved to org.apache.flink.streaming.api.functions.co.CrossWindowFunction |
From |
To |
|
Move Class org.apache.flink.streaming.io.BlockingQueueBroker moved to org.apache.flink.streaming.runtime.io.BlockingQueueBroker |
From |
To |
|
Move Class org.apache.flink.streaming.api.function.source.ParallelSourceFunction moved to org.apache.flink.streaming.api.functions.source.ParallelSourceFunction |
From |
To |
|
Move Class org.apache.flink.streaming.api.function.sink.WriteSinkFunctionByMillis moved to org.apache.flink.streaming.api.functions.sink.WriteSinkFunctionByMillis |
From |
To |
|
Move Class org.apache.flink.streaming.api.function.co.JoinWindowFunction moved to org.apache.flink.streaming.api.functions.co.JoinWindowFunction |
From |
To |
|
Move Class org.apache.flink.streaming.state.CircularFifoList moved to org.apache.flink.streaming.api.state.CircularFifoList |
From |
To |
|
Move Class org.apache.flink.streaming.partitioner.ShufflePartitioner moved to org.apache.flink.streaming.runtime.partitioner.ShufflePartitioner |
From |
To |
|
Move Class org.apache.flink.streaming.partitioner.DistributePartitioner moved to org.apache.flink.streaming.runtime.partitioner.DistributePartitioner |
From |
To |
|
Move Class org.apache.flink.streaming.api.function.source.FileMonitoringFunction moved to org.apache.flink.streaming.api.functions.source.FileMonitoringFunction |
From |
To |
|
Move Class org.apache.flink.streaming.api.invokable.operator.co.CoFlatMapTest moved to org.apache.flink.streaming.api.operators.co.CoFlatMapTest |
From |
To |
|
Move Class org.apache.flink.streaming.partitioner.StreamPartitioner moved to org.apache.flink.streaming.runtime.partitioner.StreamPartitioner |
From |
To |
|
Move Class org.apache.flink.streaming.api.StreamEdge moved to org.apache.flink.streaming.api.graph.StreamEdge |
From |
To |
|
Move Class org.apache.flink.streaming.api.invokable.operator.windowing.EmptyWindowFilter moved to org.apache.flink.streaming.api.operators.windowing.EmptyWindowFilter |
From |
To |
|
Move Class org.apache.flink.streaming.api.function.source.GenSequenceFunction moved to org.apache.flink.streaming.api.functions.source.GenSequenceFunction |
From |
To |
|
Move Class org.apache.flink.streaming.api.function.sink.SocketClientSink moved to org.apache.flink.streaming.api.functions.sink.SocketClientSink |
From |
To |
|
Move Class org.apache.flink.streaming.io.StreamRecordWriter moved to org.apache.flink.streaming.runtime.io.StreamRecordWriter |
From |
To |
|
Move Class org.apache.flink.streaming.api.streamvertex.StreamTaskContext moved to org.apache.flink.streaming.runtime.tasks.StreamTaskContext |
From |
To |
|
Move Class org.apache.flink.streaming.api.function.source.RichSourceFunction moved to org.apache.flink.streaming.api.functions.source.RichSourceFunction |
From |
To |
|
Move Class org.apache.flink.streaming.api.datastream.temporaloperator.StreamCrossOperator moved to org.apache.flink.streaming.api.datastream.temporal.StreamCrossOperator |
From |
To |
|
Move Class org.apache.flink.streaming.api.StreamNode moved to org.apache.flink.streaming.api.graph.StreamNode |
From |
To |
|
Move Class org.apache.flink.streaming.state.NullableCircularBuffer moved to org.apache.flink.streaming.api.state.NullableCircularBuffer |
From |
To |
|
Move Class org.apache.flink.streaming.api.invokable.operator.windowing.WindowIntegrationTest moved to org.apache.flink.streaming.api.operators.windowing.WindowIntegrationTest |
From |
To |
|
Move Class org.apache.flink.streaming.api.invokable.operator.windowing.WindowMapperTest moved to org.apache.flink.streaming.api.operators.windowing.WindowMapperTest |
From |
To |
|
Move Class org.apache.flink.streaming.io.StreamingAbstractRecordReader moved to org.apache.flink.streaming.runtime.io.StreamingAbstractRecordReader |
From |
To |
|
Move Class org.apache.flink.streaming.io.RecordWriterFactory moved to org.apache.flink.streaming.runtime.io.RecordWriterFactory |
From |
To |
|
Move Class org.apache.flink.streaming.api.datastream.temporaloperator.TemporalOperator moved to org.apache.flink.streaming.api.datastream.temporal.TemporalOperator |
From |
To |
|
Move Class org.apache.flink.streaming.api.invokable.operator.windowing.StreamDiscretizerTest moved to org.apache.flink.streaming.api.operators.windowing.StreamDiscretizerTest |
From |
To |
|
Move Class org.apache.flink.streaming.api.StreamConfig moved to org.apache.flink.streaming.api.graph.StreamConfig |
From |
To |
|
Move Class org.apache.flink.streaming.api.function.sink.WriteSinkFunction moved to org.apache.flink.streaming.api.functions.sink.WriteSinkFunction |
From |
To |
|
Move Class org.apache.flink.streaming.api.streamvertex.MockRecordWriter moved to org.apache.flink.streaming.api.streamtask.MockRecordWriter |
From |
To |
|
Move Class org.apache.flink.streaming.api.invokable.operator.windowing.WindowFolder moved to org.apache.flink.streaming.api.operators.windowing.WindowFolder |
From |
To |
|
Move Class org.apache.flink.streaming.api.invokable.operator.ProjectTest moved to org.apache.flink.streaming.api.operators.ProjectTest |
From |
To |
|
Move Class org.apache.flink.streaming.api.function.co.CoReduceFunction moved to org.apache.flink.streaming.api.functions.co.CoReduceFunction |
From |
To |
|
Move Class org.apache.flink.streaming.api.function.aggregation.AggregationFunction moved to org.apache.flink.streaming.api.functions.aggregation.AggregationFunction |
From |
To |
|
Move Class org.apache.flink.streaming.partitioner.DistributePartitionerTest moved to org.apache.flink.streaming.runtime.partitioner.DistributePartitionerTest |
From |
To |
|
Move Class org.apache.flink.streaming.io.BarrierBufferIOTest moved to org.apache.flink.streaming.runtime.io.BarrierBufferIOTest |
From |
To |
|
Move Class org.apache.flink.streaming.api.function.source.GenericSourceFunction moved to org.apache.flink.streaming.api.functions.source.GenericSourceFunction |
From |
To |
|
Move Class org.apache.flink.streaming.api.streamvertex.StreamingSuperstep moved to org.apache.flink.streaming.runtime.tasks.StreamingSuperstep |
From |
To |
|
Move Class org.apache.flink.streaming.api.StreamingJobGraphGenerator moved to org.apache.flink.streaming.api.graph.StreamingJobGraphGenerator |
From |
To |
|
Move Class org.apache.flink.streaming.partitioner.BroadcastPartitionerTest moved to org.apache.flink.streaming.runtime.partitioner.BroadcastPartitionerTest |
From |
To |
|
Move Class org.apache.flink.streaming.api.streamvertex.StreamIterationHead moved to org.apache.flink.streaming.runtime.tasks.StreamIterationHead |
From |
To |
|
Move Class org.apache.flink.streaming.api.invokable.operator.FlatMapTest moved to org.apache.flink.streaming.api.operators.FlatMapTest |
From |
To |
|
Move Class org.apache.flink.streaming.api.streamvertex.StreamingRuntimeContext moved to org.apache.flink.streaming.runtime.tasks.StreamingRuntimeContext |
From |
To |
|
Move Class org.apache.flink.streaming.api.streamrecord.StreamRecord moved to org.apache.flink.streaming.runtime.streamrecord.StreamRecord |
From |
To |
|
Move Class org.apache.flink.streaming.api.function.aggregation.SumFunction moved to org.apache.flink.streaming.api.functions.aggregation.SumFunction |
From |
To |
|
Move Class org.apache.flink.streaming.api.function.sink.WriteFormatAsText moved to org.apache.flink.streaming.api.functions.sink.WriteFormatAsText |
From |
To |
|
Move Class org.apache.flink.streaming.api.function.RichWindowMapFunction moved to org.apache.flink.streaming.api.functions.RichWindowMapFunction |
From |
To |
|
Move Class org.apache.flink.streaming.api.function.aggregation.ComparableAggregator moved to org.apache.flink.streaming.api.functions.aggregation.ComparableAggregator |
From |
To |
|
Move Class org.apache.flink.streaming.api.invokable.operator.windowing.ParallelGroupedMerge moved to org.apache.flink.streaming.api.operators.windowing.ParallelGroupedMerge |
From |
To |
|
Move Class org.apache.flink.streaming.api.function.source.RichParallelSourceFunction moved to org.apache.flink.streaming.api.functions.source.RichParallelSourceFunction |
From |
To |
|
Move Class org.apache.flink.streaming.api.invokable.operator.StreamFoldTest moved to org.apache.flink.streaming.api.operators.StreamFoldTest |
From |
To |
|
Move Class org.apache.flink.streaming.partitioner.FieldsPartitionerTest moved to org.apache.flink.streaming.runtime.partitioner.FieldsPartitionerTest |
From |
To |
|
Move Class org.apache.flink.streaming.api.invokable.operator.windowing.WindowMapper moved to org.apache.flink.streaming.api.operators.windowing.WindowMapper |
From |
To |
|
Move Class org.apache.flink.streaming.api.function.aggregation.SumAggregator moved to org.apache.flink.streaming.api.functions.aggregation.SumAggregator |
From |
To |
|
Move Class org.apache.flink.streaming.api.invokable.operator.windowing.GroupedStreamDiscretizer moved to org.apache.flink.streaming.api.operators.windowing.GroupedStreamDiscretizer |
From |
To |
|
Change Variable Type windowReducer : StreamInvokable<StreamWindow<Integer>,StreamWindow<Integer>> to windowReducer : StreamOperator<StreamWindow<Integer>,StreamWindow<Integer>> in method public test() : void in class org.apache.flink.streaming.api.operators.windowing.WindowReducerTest |
From |
To |
|
Change Variable Type discretizer : StreamInvokable<OUT,WindowEvent<OUT>> to discretizer : StreamOperator<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 headInvokable : StreamInvokable<?,?> 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 : StreamInvokable<StreamWindow<Integer>,Integer> to flattener : StreamOperator<StreamWindow<Integer>,Integer> in method public test() : void in class org.apache.flink.streaming.api.operators.windowing.WindowFlattenerTest |
From |
To |
|
Change Variable Type bufferInvokable : StreamInvokable<WindowEvent<OUT>,StreamWindow<OUT>> to bufferOperator : StreamOperator<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 invokable : CoMapInvokable<Double,Integer,String> to invokable : CoStreamMap<Double,Integer,String> in method public coMapTest() : void in class org.apache.flink.streaming.api.operators.co.CoMapTest |
From |
To |
|
Change Variable Type invokable1 : StreamFoldInvokable<Integer,String> to operator1 : StreamFold<Integer,String> in method public test() : void in class org.apache.flink.streaming.api.operators.StreamFoldTest |
From |
To |
|
Change Variable Type windowReducer : StreamInvokable<StreamWindow<Integer>,StreamWindow<String>> to windowReducer : StreamOperator<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 : StreamInvokable<StreamWindow<Integer>,StreamWindow<Integer>> to windowMapper : StreamOperator<StreamWindow<Integer>,StreamWindow<Integer>> in method public test() : void in class org.apache.flink.streaming.api.operators.windowing.WindowMapperTest |
From |
To |
|
Change Variable Type buffer : WindowBufferInvokable<Integer> to buffer : StreamWindowBuffer<Integer> in method public testDiscretizer() : void in class org.apache.flink.streaming.api.operators.windowing.StreamDiscretizerTest |
From |
To |
|
Change Variable Type chainableInvokable : ChainableInvokable to chainableOperator : ChainableStreamOperator in method private createChainedCollector(chainedTaskConfig StreamConfig) : Collector<OUT> in class org.apache.flink.streaming.runtime.tasks.OutputHandler |
From |
To |
|
Change Variable Type buffer : WindowBufferInvokable<Integer> to buffer : StreamWindowBuffer<Integer> in method public groupedDiscretizerTest() : void in class org.apache.flink.streaming.api.operators.windowing.GroupedStreamDiscretizerTest |
From |
To |
|
Change Variable Type invokable1 : StreamReduceInvokable<Integer> to operator1 : StreamReduce<Integer> in method public test() : void in class org.apache.flink.streaming.api.operators.StreamReduceTest |
From |
To |
|
Change Variable Type invokable : StreamInvokable<?,?> 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 invokable : CounterInvokable<String> to operator : StreamCounter<String> in method public counterTest() : void in class org.apache.flink.streaming.api.operators.CounterTest |
From |
To |
|
Change Variable Type entry : Tuple2<Integer,StreamInvokable<?,?>> 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 invokable2 : CoWindowInvokable<Tuple2<Integer,Integer>,Tuple2<Integer,Integer>,Integer> to invokable2 : CoStreamWindow<Tuple2<Integer,Integer>,Tuple2<Integer,Integer>,Integer> in method public coWindowGroupReduceTest2() : void in class org.apache.flink.streaming.api.operators.co.CoWindowTest |
From |
To |
|
Change Variable Type buffer : WindowBufferInvokable<Integer> to buffer : StreamWindowBuffer<Integer> in method public testDiscretizer2() : void in class org.apache.flink.streaming.api.operators.windowing.StreamDiscretizerTest |
From |
To |
|
Change Variable Type invokable : FlatMapInvokable<Integer,Integer> to operator : StreamFlatMap<Integer,Integer> in method public flatMapTest() : void in class org.apache.flink.streaming.api.operators.FlatMapTest |
From |
To |
|
Change Variable Type splitPartitioner : StreamInvokable<StreamWindow<Integer>,StreamWindow<Integer>> to splitPartitioner : StreamOperator<StreamWindow<Integer>,StreamWindow<Integer>> in method public test() : void in class org.apache.flink.streaming.api.operators.windowing.WindowPartitionerTest |
From |
To |
|
Change Variable Type invokable1 : GroupedReduceInvokable<Integer> to operator1 : StreamGroupedReduce<Integer> in method public test() : void in class org.apache.flink.streaming.api.operators.GroupedReduceTest |
From |
To |
|
Change Variable Type invokable : CoGroupedReduceInvokable<Tuple3<String,String,String>,Tuple2<Integer,Integer>,String> to invokable : CoStreamGroupedReduce<Tuple3<String,String,String>,Tuple2<Integer,Integer>,String> in method public coGroupedReduceTest() : void in class org.apache.flink.streaming.api.operators.co.CoGroupedReduceTest |
From |
To |
|
Change Variable Type invokable : FilterInvokable<Integer> to operator : StreamFilter<Integer> in method public test() : void in class org.apache.flink.streaming.api.operators.FilterTest |
From |
To |
|
Change Variable Type invokables : Set<Tuple2<Integer,StreamInvokable<?,?>>> to operators : Set<Tuple2<Integer,StreamOperator<?,?>>> in method private setDiscretizerReuse(streamGraph StreamGraph) : void in class org.apache.flink.streaming.api.graph.WindowingOptimizer |
From |
To |
|
Change Variable Type sourceInvokable : StreamInvokable<OUT,OUT> to sourceOperator : StreamOperator<OUT,OUT> in method private addSource(function SourceFunction<OUT>, outTypeInfo TypeInformation<OUT>, sourceName String) : DataStreamSource<OUT> in class org.apache.flink.streaming.api.environment.StreamExecutionEnvironment |
From |
To |
|
Change Variable Type invokable1 : CoWindowInvokable<Integer,Integer,Integer> to invokable1 : CoStreamWindow<Integer,Integer,Integer> in method public coWindowGroupReduceTest2() : void in class org.apache.flink.streaming.api.operators.co.CoWindowTest |
From |
To |
|
Change Variable Type invokables : Set<Tuple2<Integer,StreamInvokable<?,?>>> 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 invokable : CoFlatMapInvokable<String,Integer,String> to invokable : CoStreamFlatMap<String,Integer,String> in method public coFlatMapTest() : void in class org.apache.flink.streaming.api.operators.co.CoFlatMapTest |
From |
To |
|
Change Variable Type entry : Tuple2<Integer,StreamInvokable<?,?>> to entry : Tuple2<Integer,StreamOperator<?,?>> in method private setDiscretizerReuse(streamGraph StreamGraph) : void in class org.apache.flink.streaming.api.graph.WindowingOptimizer |
From |
To |
|
Change Variable Type gbPartitioner : StreamInvokable<StreamWindow<Integer>,StreamWindow<Integer>> to gbPartitioner : StreamOperator<StreamWindow<Integer>,StreamWindow<Integer>> in method public test() : void in class org.apache.flink.streaming.api.operators.windowing.WindowPartitionerTest |
From |
To |
|
Change Variable Type invokable : ChainableInvokable<?,?> to operator : ChainableStreamOperator<?,?> in method protected openOperator() : void in class org.apache.flink.streaming.runtime.tasks.StreamTask |
From |
To |
|
Change Variable Type invokable : CoWindowInvokable<I1,I2,R> to operator : CoStreamWindow<I1,I2,R> in method public with(function CrossFunction<I1,I2,R>) : SingleOutputStreamOperator<R,?> in class org.apache.flink.streaming.api.datastream.temporal.StreamCrossOperator.CrossWindow |
From |
To |
|
Change Variable Type coReduce : CoReduceInvokable<Integer,String,Integer> to coReduce : CoStreamReduce<Integer,String,Integer> in method public coStreamReduceTest() : void in class org.apache.flink.streaming.api.operators.co.CoStreamReduceTest |
From |
To |
|
Change Variable Type invokable : CoWindowInvokable<I1,I2,OUT> to operator : CoStreamWindow<I1,I2,OUT> in method public with(joinFunction JoinFunction<I1,I2,OUT>) : SingleOutputStreamOperator<OUT,?> in class org.apache.flink.streaming.api.datastream.temporal.StreamJoinOperator.JoinedStream |
From |
To |
|
Change Variable Type outInvokable : StreamInvokable<?,?> to outOperator : StreamOperator<?,?> in method private isChainable(edge StreamEdge) : boolean in class org.apache.flink.streaming.api.graph.StreamingJobGraphGenerator |
From |
To |
|
Change Variable Type invokable : ProjectInvokable<Tuple5<Integer,String,Integer,String,Integer>,Tuple3<Integer,Integer,String>> to operator : StreamProject<Tuple5<Integer,String,Integer,String,Integer>,Tuple3<Integer,Integer,String>> in method public test() : void in class org.apache.flink.streaming.api.operators.ProjectTest |
From |
To |
|
Change Variable Type sinkInvokable : StreamInvokable<OUT,OUT> to sinkOperator : StreamOperator<OUT,OUT> in method public addSink(sinkFunction SinkFunction<OUT>) : DataStreamSink<OUT> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Variable Type invokableSet : Set<Tuple2<Integer,StreamInvokable<?,?>>> 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 invokable : GroupedReduceInvokable<OUT> to operator : StreamGroupedReduce<OUT> in method protected aggregate(aggregate AggregationFunction<OUT>) : SingleOutputStreamOperator<OUT,?> in class org.apache.flink.streaming.api.datastream.GroupedDataStream |
From |
To |
|
Change Variable Type invokable : StreamReduceInvokable<OUT> to operator : StreamReduce<OUT> in method protected aggregate(aggregate AggregationFunction<OUT>) : SingleOutputStreamOperator<OUT,?> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Variable Type invokable : MapInvokable<Integer,String> to operator : StreamMap<Integer,String> in method public mapTest() : void in class org.apache.flink.streaming.api.operators.MapTest |
From |
To |
|
Change Variable Type invokable : CoReduceInvokable<IN1,IN2,OUT> to operator : CoStreamReduce<IN1,IN2,OUT> in method protected getReduceOperator(coReducer CoReduceFunction<IN1,IN2,OUT>) : CoStreamOperator<IN1,IN2,OUT> in class org.apache.flink.streaming.api.datastream.ConnectedDataStream |
From |
To |
|
Change Variable Type windowMerger : StreamInvokable<StreamWindow<Integer>,StreamWindow<Integer>> to windowMerger : StreamOperator<StreamWindow<Integer>,StreamWindow<Integer>> in method public test() : void in class org.apache.flink.streaming.api.operators.windowing.WindowMergerTest |
From |
To |
|
Change Variable Type invokable1 : GroupedFoldInvokable<Integer,String> to operator1 : StreamGroupedFold<Integer,String> in method public test() : void in class org.apache.flink.streaming.api.operators.GroupedFoldTest |
From |
To |
|
Rename Parameter invokable : StreamInvokable<?,?> 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 |
|
Rename Parameter invokable : StreamInvokable<IN,R> to operator : StreamOperator<IN,R> in method public transform(operatorName String, outTypeInfo TypeInformation<R>, operator StreamOperator<IN,R>) : SingleOutputStreamOperator<R,?> in class org.apache.flink.streaming.api.datastream.IterativeDataStream |
From |
To |
|
Rename Parameter invokable : StreamInvokable<StreamWindow<OUT>,StreamWindow<R>> to operator : StreamOperator<StreamWindow<OUT>,StreamWindow<R>> in method private transform(transformation WindowTransformation, operatorName String, retType TypeInformation<R>, operator StreamOperator<StreamWindow<OUT>,StreamWindow<R>>) : DiscretizedStream<R> in class org.apache.flink.streaming.api.datastream.DiscretizedStream |
From |
To |
|
Rename Parameter functionInvokable : CoInvokable<IN1,IN2,OUT> to operator : CoStreamOperator<IN1,IN2,OUT> in method public addCoFunction(functionName String, outTypeInfo TypeInformation<OUT>, operator CoStreamOperator<IN1,IN2,OUT>) : SingleOutputStreamOperator<OUT,?> in class org.apache.flink.streaming.api.datastream.ConnectedDataStream |
From |
To |
|
Rename Parameter invokableObject : StreamInvokable<?,?> 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 |
|
Rename Parameter invokable : StreamInvokable<?,?> to operator : StreamOperator<?,?> in method protected DataStreamSink(environment StreamExecutionEnvironment, operatorType String, outTypeInfo TypeInformation<IN>, operator StreamOperator<?,?>) in class org.apache.flink.streaming.api.datastream.DataStreamSink |
From |
To |
|
Rename Parameter invokable : CoInvokable<IN1,IN2,OUT> to operator : CoStreamOperator<IN1,IN2,OUT> in method public createAndExecute(operator CoStreamOperator<IN1,IN2,OUT>, input1 List<IN1>, input2 List<IN2>) : List<OUT> in class org.apache.flink.streaming.util.MockCoContext |
From |
To |
|
Rename Parameter invokable : StreamInvokable<?,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 |
|
Rename Parameter invokableObject : StreamInvokable<?,?> to operator : StreamOperator<?,?> in method public setStreamOperator(operator StreamOperator<?,?>) : void in class org.apache.flink.streaming.api.graph.StreamConfig |
From |
To |
|
Rename Parameter taskInvokableObject : CoInvokable<IN1,IN2,OUT> to taskoperatorObject : CoStreamOperator<IN1,IN2,OUT> in method public addCoOperator(vertexID Integer, taskoperatorObject CoStreamOperator<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 |
|
Rename Parameter invokableObject : StreamInvokable<IN,OUT> to operatorObject : StreamOperator<IN,OUT> in method public addOperator(vertexID Integer, operatorObject StreamOperator<IN,OUT>, inTypeInfo TypeInformation<IN>, outTypeInfo TypeInformation<OUT>, operatorName String) : void in class org.apache.flink.streaming.api.graph.StreamGraph |
From |
To |
|
Rename Parameter invokable : StreamInvokable<?,?> to operator : StreamOperator<?,?> in method public setOperator(operator StreamOperator<?,?>) : void in class org.apache.flink.streaming.api.graph.StreamNode |
From |
To |
|
Rename Parameter invokableObject : StreamInvokable<IN,OUT> to operatorObject : StreamOperator<IN,OUT> in method public addSource(vertexID Integer, operatorObject StreamOperator<IN,OUT>, inTypeInfo TypeInformation<IN>, outTypeInfo TypeInformation<OUT>, operatorName String) : void in class org.apache.flink.streaming.api.graph.StreamGraph |
From |
To |
|
Rename Parameter invokable : StreamInvokable<OUT,R> to operator : StreamOperator<OUT,R> in method public transform(operatorName String, outTypeInfo TypeInformation<R>, operator StreamOperator<OUT,R>) : SingleOutputStreamOperator<R,?> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Rename Parameter invokable : StreamInvokable<?,?> 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 |
|
Rename Parameter invokable : StreamInvokable<IN,OUT> to operator : StreamOperator<IN,OUT> in method public createAndExecute(operator StreamOperator<IN,OUT>, inputs List<IN>) : List<OUT> in class org.apache.flink.streaming.util.MockContext |
From |
To |
|
Rename Parameter invokableObject : StreamInvokable<IN,OUT> to operatorObject : StreamOperator<IN,OUT> in method public setOperator(vertexID Integer, operatorObject StreamOperator<IN,OUT>) : void in class org.apache.flink.streaming.api.graph.StreamGraph |
From |
To |