|
Move Method private isChainable(vertexName String, outName String) : boolean from class org.apache.flink.streaming.api.JobGraphBuilder to private isChainable(vertexName String, outName String) : boolean from class org.apache.flink.streaming.api.StreamingJobGraphGenerator |
From |
To |
|
Move Method private connect(headOfChain String, edge Tuple2<String,String>) : void from class org.apache.flink.streaming.api.JobGraphBuilder to private connect(headOfChain String, edge Tuple2<String,String>) : void from class org.apache.flink.streaming.api.StreamingJobGraphGenerator |
From |
To |
|
Move Method private createChain(startNode String, current String) : List<Tuple2<String,String>> from class org.apache.flink.streaming.api.JobGraphBuilder to private createChain(startNode String, current String) : List<Tuple2<String,String>> from class org.apache.flink.streaming.api.StreamingJobGraphGenerator |
From |
To |
|
Move Method private setSlotSharing() : void from class org.apache.flink.streaming.api.JobGraphBuilder to private setSlotSharing() : void from class org.apache.flink.streaming.api.StreamingJobGraphGenerator |
From |
To |
|
Move Method private createProcessingVertex(vertexName String) : StreamConfig from class org.apache.flink.streaming.api.JobGraphBuilder to private createProcessingVertex(vertexName String) : StreamConfig from class org.apache.flink.streaming.api.StreamingJobGraphGenerator |
From |
To |
|
Move Method private setVertexConfig(vertexName String, config StreamConfig, chainableOutputs List<String>, nonChainableOutputs List<String>) : void from class org.apache.flink.streaming.api.JobGraphBuilder to private setVertexConfig(vertexName String, config StreamConfig, chainableOutputs List<String>, nonChainableOutputs List<String>) : void from class org.apache.flink.streaming.api.StreamingJobGraphGenerator |
From |
To |
|
Move Attribute private streamVertices : Map<String,AbstractJobVertex> from class org.apache.flink.streaming.api.JobGraphBuilder to private streamVertices : Map<String,AbstractJobVertex> from class org.apache.flink.streaming.api.StreamingJobGraphGenerator |
From |
To |
|
Move Attribute private jobGraph : JobGraph from class org.apache.flink.streaming.api.JobGraphBuilder to private jobGraph : JobGraph from class org.apache.flink.streaming.api.StreamingJobGraphGenerator |
From |
To |
|
Move Attribute private chainedConfigs : Map<String,Map<String,StreamConfig>> from class org.apache.flink.streaming.api.JobGraphBuilder to private chainedConfigs : Map<String,Map<String,StreamConfig>> from class org.apache.flink.streaming.api.StreamingJobGraphGenerator |
From |
To |
|
Move Attribute private vertexConfigs : Map<String,StreamConfig> from class org.apache.flink.streaming.api.JobGraphBuilder to private vertexConfigs : Map<String,StreamConfig> from class org.apache.flink.streaming.api.StreamingJobGraphGenerator |
From |
To |
|
Rename Attribute outPartitioning : Map<String,List<StreamPartitioner<?>>> to outputPartitioners : Map<String,List<StreamPartitioner<?>>> in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Rename Attribute vertexClasses : Map<String,Class<? extends AbstractInvokable>> to jobVertexClasses : Map<String,Class<? extends AbstractInvokable>> in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Rename Attribute outEdgeIndex : Map<String,List<Integer>> to outEdgeTypes : Map<String,List<Integer>> in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Rename Attribute outEdgeList : Map<String,List<String>> to outEdgeLists : Map<String,List<String>> in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Rename Attribute bufferTimeout : Map<String,Long> to bufferTimeouts : Map<String,Long> in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Rename Attribute jobGraphBuilder : JobGraphBuilder to streamGraph : StreamGraph in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Rename Attribute RW_ORDER : String to EDGES_IN_ORDER : String in class org.apache.flink.streaming.api.StreamConfig |
From |
To |
|
Rename Attribute inputFormatList : Map<String,InputFormat<String,?>> to inputFormatLists : Map<String,InputFormat<String,?>> in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Rename Attribute outEdgeNames : Map<String,List<List<String>>> to selectedNames : Map<String,List<List<String>>> in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Rename Attribute recordWriterOrder : List<String> to outEdgesInOrder : List<Tuple2<String,String>> in class org.apache.flink.streaming.api.streamvertex.OutputHandler |
From |
To |
|
Rename Attribute jobGraphBuilder : JobGraphBuilder to streamGraph : StreamGraph in class org.apache.flink.streaming.api.environment.StreamExecutionEnvironment |
From |
To |
|
Rename Attribute inEdgeList : Map<String,List<String>> to inEdgeLists : Map<String,List<String>> in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Rename Attribute vertexParallelism : Map<String,Integer> to operatorParallelisms : Map<String,Integer> in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Rename Attribute outEdgeSelectAll : Map<String,List<Boolean>> to outEdgeSelectAlls : Map<String,List<Boolean>> in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Rename Attribute iterationWaitTime : Map<String,Long> to iterationTimeouts : Map<String,Long> in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Change Attribute Type jobGraphBuilder : JobGraphBuilder to jobGraphBuilder : StreamGraph in class org.apache.flink.streaming.api.datastream.ConnectedDataStream |
From |
To |
|
Change Attribute Type jobGraphBuilder : JobGraphBuilder to streamGraph : StreamGraph in class org.apache.flink.streaming.api.environment.StreamExecutionEnvironment |
From |
To |
|
Change Attribute Type jobGraphBuilder : JobGraphBuilder to streamGraph : StreamGraph in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Attribute Type outputSelectors : Map<String,byte[]> to outputSelectors : Map<String,OutputSelector<?>> in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Change Attribute Type recordWriterOrder : List<String> to outEdgesInOrder : List<Tuple2<String,String>> in class org.apache.flink.streaming.api.streamvertex.OutputHandler |
From |
To |
|
Rename Parameter serializedOutputSelector : byte[] to outputSelector : OutputSelector<?> in method public setOutputSelector(vertexName String, outputSelector OutputSelector<?>) : void in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Rename Parameter id : String to vertexName : String in method public getInvokable(vertexName String) : StreamInvokable<?,?> in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Rename Parameter name : String to outputVertex : String in method private createStreamOutput(outputVertex String, configuration StreamConfig, outputIndex int) : StreamOutput<T> in class org.apache.flink.streaming.api.streamvertex.OutputHandler |
From |
To |
|
Rename Parameter id : String to vertexName : String in method public setInvokable(vertexName String, invokableObject StreamInvokable<IN,OUT>) : void in class org.apache.flink.streaming.api.StreamGraph |
From |
To |