|
Rename Method public addCoTask(vertexID Integer, taskInvokableObject CoInvokable<IN1,IN2,OUT>, in1TypeInfo TypeInformation<IN1>, in2TypeInfo TypeInformation<IN2>, outTypeInfo TypeInformation<OUT>, operatorName String, parallelism int) : void renamed to public addCoOperator(vertexID Integer, taskInvokableObject CoInvokable<IN1,IN2,OUT>, in1TypeInfo TypeInformation<IN1>, in2TypeInfo TypeInformation<IN2>, outTypeInfo TypeInformation<OUT>, operatorName String) : void in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Rename Method public setOutputSelector(vertexID Integer, outputSelector OutputSelector<T>) : void renamed to public addOutputSelector(vertexID Integer, outputSelector OutputSelector<T>) : void in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Rename Method public addStreamVertex(vertexID Integer, invokableObject StreamInvokable<IN,OUT>, inTypeInfo TypeInformation<IN>, outTypeInfo TypeInformation<OUT>, operatorName String, parallelism int) : void renamed to public addOperator(vertexID Integer, invokableObject StreamInvokable<IN,OUT>, inTypeInfo TypeInformation<IN>, outTypeInfo TypeInformation<OUT>, operatorName String) : void in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Rename Method public getIterationID(vertexID Integer) : Integer renamed to public getVertex(vertexID Integer) : StreamNode in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Rename Method public getSources() : Collection<Integer> renamed to public getSourceIDs() : Collection<Integer> in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Change Parameter Type targetVertex : int to targetVertex : StreamNode in method public StreamEdge(sourceVertex StreamNode, targetVertex StreamNode, typeNumber int, selectedNames List<String>, outputPartitioner StreamPartitioner<?>) in class org.apache.flink.streaming.api.StreamEdge |
From |
To |
|
Change Parameter Type invokable : StreamInvokable<?,?> to invokable : StreamInvokable<?,OUT> in method public DataStreamSource(environment StreamExecutionEnvironment, operatorType String, outTypeInfo TypeInformation<OUT>, invokable StreamInvokable<?,OUT>, isParallel boolean, sourceName String) in class org.apache.flink.streaming.api.datastream.DataStreamSource |
From |
To |
|
Change Parameter Type sourceVertex : int to sourceVertex : StreamNode in method public StreamEdge(sourceVertex StreamNode, targetVertex StreamNode, typeNumber int, selectedNames List<String>, outputPartitioner StreamPartitioner<?>) in class org.apache.flink.streaming.api.StreamEdge |
From |
To |
|
Rename Variable outpartitionerIndexToCopy : int to outpartitionerIndex : int in method public addIterationHead(vertexID Integer, iterationHead Integer, iterationID Integer, timeOut long) : void in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Rename Variable flattener : Integer to flattenerID : Integer in method private removeMergeBeforeFlatten(streamGraph StreamGraph) : void in class org.apache.flink.streaming.api.WindowingOptimizer |
From |
To |
|
Rename Variable iterID : Integer to loop : StreamLoop in method private setSlotSharing() : void in class org.apache.flink.streaming.api.StreamingJobGraphGenerator |
From |
To |
|
Rename Variable vertex : AbstractJobVertex to jobVertex : AbstractJobVertex in method private createProcessingVertex(vertexID Integer) : StreamConfig in class org.apache.flink.streaming.api.StreamingJobGraphGenerator |
From |
To |
|
Rename Variable vertexID : int to upStreamVertex : StreamNode in method private isChainable(edge StreamEdge) : boolean in class org.apache.flink.streaming.api.StreamingJobGraphGenerator |
From |
To |
|
Rename Variable outName : int to downStreamVertex : StreamNode in method private isChainable(edge StreamEdge) : boolean in class org.apache.flink.streaming.api.StreamingJobGraphGenerator |
From |
To |
|
Rename Variable output : Integer to outEdge : StreamEdge in method private replaceDiscretizer(streamGraph StreamGraph, toReplaceID Integer, replaceWithID Integer) : void in class org.apache.flink.streaming.api.WindowingOptimizer |
From |
To |
|
Change Variable Type outName : int to downStreamVertex : StreamNode in method private isChainable(edge StreamEdge) : boolean in class org.apache.flink.streaming.api.StreamingJobGraphGenerator |
From |
To |
|
Change Variable Type output : Integer to outEdge : StreamEdge in method private replaceDiscretizer(streamGraph StreamGraph, toReplaceID Integer, replaceWithID Integer) : void in class org.apache.flink.streaming.api.WindowingOptimizer |
From |
To |
|
Change Variable Type entry : Entry<Integer,StreamInvokable<?,?>> to entry : Tuple2<Integer,StreamInvokable<?,?>> in method private removeMergeBeforeFlatten(streamGraph StreamGraph) : void in class org.apache.flink.streaming.api.WindowingOptimizer |
From |
To |
|
Change Variable Type outEdges : List<Integer> to outEdges : List<StreamEdge> in method private replaceDiscretizer(streamGraph StreamGraph, toReplaceID Integer, replaceWithID Integer) : void in class org.apache.flink.streaming.api.WindowingOptimizer |
From |
To |
|
Change Variable Type invokables : Set<Entry<Integer,StreamInvokable<?,?>>> to invokables : Set<Tuple2<Integer,StreamInvokable<?,?>>> in method private removeMergeBeforeFlatten(streamGraph StreamGraph) : void in class org.apache.flink.streaming.api.WindowingOptimizer |
From |
To |
|
Change Variable Type input : Integer to input : StreamNode in method private removeMergeBeforeFlatten(streamGraph StreamGraph) : void in class org.apache.flink.streaming.api.WindowingOptimizer |
From |
To |
|
Change Variable Type entry : Entry<Integer,StreamInvokable<?,?>> to entry : Tuple2<Integer,StreamInvokable<?,?>> in method private setDiscretizerReuse(streamGraph StreamGraph) : void in class org.apache.flink.streaming.api.WindowingOptimizer |
From |
To |
|
Change Variable Type iterID : Integer to loop : StreamLoop in method private setSlotSharing() : void in class org.apache.flink.streaming.api.StreamingJobGraphGenerator |
From |
To |
|
Change Variable Type mergeInput : Integer to mergeInput : StreamNode in method private removeMergeBeforeFlatten(streamGraph StreamGraph) : void in class org.apache.flink.streaming.api.WindowingOptimizer |
From |
To |
|
Change Variable Type invokables : Set<Entry<Integer,StreamInvokable<?,?>>> to invokables : Set<Tuple2<Integer,StreamInvokable<?,?>>> in method private setDiscretizerReuse(streamGraph StreamGraph) : void in class org.apache.flink.streaming.api.WindowingOptimizer |
From |
To |
|
Change Variable Type vertexID : int to upStreamVertex : StreamNode in method private isChainable(edge StreamEdge) : boolean in class org.apache.flink.streaming.api.StreamingJobGraphGenerator |
From |
To |