|
Change Parameter Type outputvertexIDs : List<Integer> to outputvertexIDs : List<StreamEdge> in method public setNonChainedOutputs(outputvertexIDs List<StreamEdge>) : void in class org.apache.flink.streaming.api.StreamConfig |
From |
To |
|
Change Parameter Type chainedOutputs : List<Integer> to chainedOutputs : List<StreamEdge> in method public setChainedOutputs(chainedOutputs List<StreamEdge>) : void in class org.apache.flink.streaming.api.StreamConfig |
From |
To |
|
Change Parameter Type chainableOutputs : List<Integer> to chainableOutputs : List<StreamEdge> in method private setVertexConfig(vertexID Integer, config StreamConfig, chainableOutputs List<StreamEdge>, nonChainableOutputs List<StreamEdge>) : void in class org.apache.flink.streaming.api.StreamingJobGraphGenerator |
From |
To |
|
Change Parameter Type chainedOutputs : List<Integer> to chainedOutputs : List<StreamEdge> in method private createChainedName(vertexID Integer, chainedOutputs List<StreamEdge>) : String in class org.apache.flink.streaming.api.StreamingJobGraphGenerator |
From |
To |
|
Change Parameter Type nonChainableOutputs : List<Integer> to nonChainableOutputs : List<StreamEdge> in method private setVertexConfig(vertexID Integer, config StreamConfig, chainableOutputs List<StreamEdge>, nonChainableOutputs List<StreamEdge>) : void in class org.apache.flink.streaming.api.StreamingJobGraphGenerator |
From |
To |
|
Change Variable Type nonChainableOutputs : List<Integer> to nonChainableOutputs : List<StreamEdge> in method private createChain(startNode Integer, current Integer) : List<Tuple2<Integer,Integer>> in class org.apache.flink.streaming.api.StreamingJobGraphGenerator |
From |
To |
|
Change Variable Type chainable : Integer to chainable : StreamEdge in method private createChainedName(vertexID Integer, chainedOutputs List<StreamEdge>) : String in class org.apache.flink.streaming.api.StreamingJobGraphGenerator |
From |
To |
|
Change Variable Type nonChainable : Integer to nonChainable : StreamEdge in method private createChain(startNode Integer, current Integer) : List<Tuple2<Integer,Integer>> in class org.apache.flink.streaming.api.StreamingJobGraphGenerator |
From |
To |
|
Change Variable Type chainable : Integer to chainable : StreamEdge in method private createChain(startNode Integer, current Integer) : List<Tuple2<Integer,Integer>> in class org.apache.flink.streaming.api.StreamingJobGraphGenerator |
From |
To |
|
Change Variable Type chainableOutputs : List<Integer> to chainableOutputs : List<StreamEdge> in method private createChain(startNode Integer, current Integer) : List<Tuple2<Integer,Integer>> in class org.apache.flink.streaming.api.StreamingJobGraphGenerator |
From |
To |
|
Change Variable Type allOutputs : List<Integer> to allOutputs : List<StreamEdge> in method private setVertexConfig(vertexID Integer, config StreamConfig, chainableOutputs List<StreamEdge>, nonChainableOutputs List<StreamEdge>) : void in class org.apache.flink.streaming.api.StreamingJobGraphGenerator |
From |
To |
|
Change Variable Type output : Integer to output : StreamEdge in method private setVertexConfig(vertexID Integer, config StreamConfig, chainableOutputs List<StreamEdge>, nonChainableOutputs List<StreamEdge>) : void in class org.apache.flink.streaming.api.StreamingJobGraphGenerator |
From |
To |