|
Change Parameter Type chainableOutputs : List<String> to chainableOutputs : List<Integer> in method private setVertexConfig(vertexID Integer, config StreamConfig, chainableOutputs List<Integer>, nonChainableOutputs List<Integer>) : void in class org.apache.flink.streaming.api.StreamingJobGraphGenerator |
From |
To |
|
Change Parameter Type downStreamVertex : String to downStreamVertex : Integer in method public getSelectedNames(upStreamVertex Integer, downStreamVertex Integer) : List<String> in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Change Parameter Type id : String to id : Integer in method private validateMerge(id Integer) : void in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Parameter Type vertexName : String to vertexID : Integer in method public addStreamVertex(vertexID Integer, invokableObject StreamInvokable<IN,OUT>, inTypeInfo TypeInformation<IN>, outTypeInfo TypeInformation<OUT>, operatorName String, parallelism int) : void in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Change Parameter Type discretizers : List<Tuple2<String,StreamDiscretizer<?>>> to discretizers : List<Tuple2<Integer,StreamDiscretizer<?>>> in method private setDiscretizerReuse(streamGraph StreamGraph, discretizers List<Tuple2<Integer,StreamDiscretizer<?>>>) : void in class org.apache.flink.streaming.api.WindowingOptimzier |
From |
To |
|
Change Parameter Type upStreamVertexName : String to upStreamVertexID : Integer in method public setEdge(upStreamVertexID Integer, downStreamVertexID Integer, partitionerObject StreamPartitioner<?>, typeNumber int, outputNames List<String>) : void in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Change Parameter Type vertexID : String to vertexID : Integer in method private createChainedName(vertexID Integer, chainedOutputs List<Integer>) : String in class org.apache.flink.streaming.api.StreamingJobGraphGenerator |
From |
To |
|
Change Parameter Type current : String to current : Integer in method private createChain(startNode Integer, current Integer) : List<Tuple2<Integer,Integer>> in class org.apache.flink.streaming.api.StreamingJobGraphGenerator |
From |
To |
|
Change Parameter Type vertexName : String to vertexID : Integer in method public addIterationHead(vertexID Integer, iterationHead Integer, iterationID Integer, parallelism int, waitTime long) : void in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Change Parameter Type vertexName : String to vertexID : Integer in method public getOutputSelector(vertexID Integer) : List<OutputSelector<?>> in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Change Parameter Type vertexName : String to vertexID : Integer in method public getInEdges(vertexID Integer) : List<Integer> in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Change Parameter Type vertexName : String to vertexID : Integer in method public getOutEdges(vertexID Integer) : List<Integer> in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Change Parameter Type toRemove : String to toRemove : Integer in method public removeVertex(toRemove Integer) : void in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Change Parameter Type id : String to id : Integer in method public setOutType(id Integer, outType TypeInformation<OUT>) : void in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Change Parameter Type vertexName : String to vertexID : Integer in method public addIterationTail(vertexID Integer, iterationTail Integer, iterationID Integer, waitTime long) : void in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Change Parameter Type vertexName : String to vertexID : Integer in method public getJobVertexClass(vertexID Integer) : Class<? extends AbstractInvokable> in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Change Parameter Type headOfChain : String to headOfChain : Integer in method private connect(headOfChain Integer, edge Tuple2<Integer,Integer>) : void in class org.apache.flink.streaming.api.StreamingJobGraphGenerator |
From |
To |
|
Change Parameter Type nonChainableOutputs : List<String> to nonChainableOutputs : List<Integer> in method private setVertexConfig(vertexID Integer, config StreamConfig, chainableOutputs List<Integer>, nonChainableOutputs List<Integer>) : void in class org.apache.flink.streaming.api.StreamingJobGraphGenerator |
From |
To |
|
Change Parameter Type downStreamVertex : String to downStreamVertex : Integer in method public getOutPartitioner(upStreamVertex Integer, downStreamVertex Integer) : StreamPartitioner<?> in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Change Parameter Type vertexName : String to vertexID : Integer in method private isChainable(vertexID Integer, outName Integer) : boolean in class org.apache.flink.streaming.api.StreamingJobGraphGenerator |
From |
To |
|
Change Parameter Type outputVertex : String to outputVertex : Integer in method private createStreamOutput(outputVertex Integer, configuration StreamConfig, outputIndex int) : StreamOutput<T> in class org.apache.flink.streaming.api.streamvertex.OutputHandler |
From |
To |
|
Change Parameter Type vertexName : String to vertexID : Integer in method private addVertex(vertexID Integer, vertexClass Class<? extends AbstractInvokable>, invokableObject StreamInvokable<?,?>, operatorName String, parallelism int) : void in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Change Parameter Type iterationHead : String to iterationHead : Integer in method public addIterationHead(vertexID Integer, iterationHead Integer, iterationID Integer, parallelism int, waitTime long) : void in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Change Parameter Type edge : Tuple2<String,String> to edge : Tuple2<Integer,Integer> in method private connect(headOfChain Integer, edge Tuple2<Integer,Integer>) : void in class org.apache.flink.streaming.api.StreamingJobGraphGenerator |
From |
To |
|
Change Parameter Type vertexName : String to vertexID : Integer in method public getOperatorName(vertexID Integer) : String in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Change Parameter Type replaceWith : String to replaceWith : Integer in method private replaceDiscretizer(streamGraph StreamGraph, toReplace Integer, replaceWith Integer) : void in class org.apache.flink.streaming.api.WindowingOptimzier |
From |
To |
|
Change Parameter Type vertexName : String to vertexID : Integer in method public getIterationTimeout(vertexID Integer) : long in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Change Parameter Type startNode : String to startNode : Integer in method private createChain(startNode Integer, current Integer) : List<Tuple2<Integer,Integer>> in class org.apache.flink.streaming.api.StreamingJobGraphGenerator |
From |
To |
|
Change Parameter Type vertexName : String to vertexID : Integer in method public setBufferTimeout(vertexID Integer, bufferTimeout long) : void in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Change Parameter Type vertexName : String to vertexID : Integer in method public getInSerializer2(vertexID Integer) : StreamRecordSerializer<IN> in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Change Parameter Type iterationTail : String to iterationTail : Integer in method public addIterationTail(vertexID Integer, iterationTail Integer, iterationID Integer, waitTime long) : void in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Change Parameter Type vertexName : String to vertexID : Integer in method private addTypeSerializers(vertexID Integer, in1 StreamRecordSerializer<?>, in2 StreamRecordSerializer<?>, out1 StreamRecordSerializer<?>, out2 StreamRecordSerializer<?>) : void in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Change Parameter Type vertexName : String to vertexID : Integer in method public getInSerializer1(vertexID Integer) : StreamRecordSerializer<IN> in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Change Parameter Type chainedOutputs : List<String> to chainedOutputs : List<Integer> in method private createChainedName(vertexID Integer, chainedOutputs List<Integer>) : String in class org.apache.flink.streaming.api.StreamingJobGraphGenerator |
From |
To |
|
Change Parameter Type vertexName : String to vertexID : Integer in method public getOutSerializer2(vertexID Integer) : StreamRecordSerializer<OUT> in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Change Parameter Type vertexName : String to vertexID : Integer in method public addCoTask(vertexID Integer, taskInvokableObject CoInvokable<IN1,IN2,OUT>, in1TypeInfo TypeInformation<IN1>, in2TypeInfo TypeInformation<IN2>, outTypeInfo TypeInformation<OUT>, operatorName String, parallelism int) : void in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Change Parameter Type vertexName : String to vertexID : Integer in method public setParallelism(vertexID Integer, parallelism int) : void in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Change Parameter Type outputID : String to outputID : Integer in method protected connectGraph(inputStream DataStream<X>, outputID Integer, typeNumber int) : void in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Parameter Type veretxName : String to veretxName : Integer in method public addOperatorState(veretxName Integer, stateName String, state OperatorState<?>) : void in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Change Parameter Type output : String to output : Integer in method public getPartitioner(cl ClassLoader, output Integer) : StreamPartitioner<T> in class org.apache.flink.streaming.api.StreamConfig |
From |
To |
|
Change Parameter Type vertexName : String to vertexID : Integer in method public setOutputSelector(vertexID Integer, outputSelector OutputSelector<T>) : void in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Change Parameter Type vertexName : String to vertexID : Integer in method public getOutSerializer1(vertexID Integer) : StreamRecordSerializer<OUT> in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Change Parameter Type upStreamVertex : String to upStreamVertex : Integer in method public getSelectedNames(upStreamVertex Integer, downStreamVertex Integer) : List<String> in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Change Parameter Type vertexName : String to vertexID : Integer in method public getInputFormat(vertexID Integer) : InputFormat<String,?> in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Change Parameter Type upStream : String to upStream : Integer in method public removeEdge(upStream Integer, downStream Integer) : void in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Change Parameter Type vertexName : String to vertexID : Integer in method public setInputFormat(vertexID Integer, inputFormat InputFormat<String,?>) : void in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Change Parameter Type to : String to to : Integer in method public setSerializersFrom(from Integer, to Integer) : void in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Change Parameter Type vertexName : String to vertexID : Integer in method public setInvokable(vertexID Integer, invokableObject StreamInvokable<IN,OUT>) : void in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Change Parameter Type vertexName : String to vertexID : Integer in method private setVertexConfig(vertexID Integer, config StreamConfig, chainableOutputs List<Integer>, nonChainableOutputs List<Integer>) : void in class org.apache.flink.streaming.api.StreamingJobGraphGenerator |
From |
To |
|
Change Parameter Type chainedTaskConfigs : Map<String,StreamConfig> to chainedTaskConfigs : Map<Integer,StreamConfig> in method public setTransitiveChainedTaskConfigs(chainedTaskConfigs Map<Integer,StreamConfig>) : void in class org.apache.flink.streaming.api.StreamConfig |
From |
To |
|
Change Parameter Type vertexName : String to vertexID : Integer in method public getBufferTimeout(vertexID Integer) : long in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Change Parameter Type vertexName : String to vertexID : Integer in method public getIterationID(vertexID Integer) : Integer in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Change Parameter Type vertexName : String to vertexID : Integer in method public getParallelism(vertexID Integer) : int in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Change Parameter Type vertexName : String to vertexID : Integer in method private createProcessingVertex(vertexID Integer) : StreamConfig in class org.apache.flink.streaming.api.StreamingJobGraphGenerator |
From |
To |
|
Change Parameter Type outputVertexNames : List<String> to outputvertexIDs : List<Integer> in method public setOutputs(outputvertexIDs List<Integer>) : void in class org.apache.flink.streaming.api.StreamConfig |
From |
To |
|
Change Parameter Type output : String to output : Integer in method public getSelectedNames(output Integer) : List<String> in class org.apache.flink.streaming.api.StreamConfig |
From |
To |
|
Change Parameter Type vertexName : String to vertexID : Integer in method public getState(vertexID Integer) : Map<String,OperatorState<?>> in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Change Parameter Type from : String to from : Integer in method public setSerializersFrom(from Integer, to Integer) : void in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Change Parameter Type upStreamVertex : String to upStreamVertex : Integer in method public getOutPartitioner(upStreamVertex Integer, downStreamVertex Integer) : StreamPartitioner<?> in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Change Parameter Type vertexName : String to vertexID : Integer in method public setVertexID(vertexID Integer) : void in class org.apache.flink.streaming.api.StreamConfig |
From |
To |
|
Change Parameter Type outName : String to outName : Integer in method private isChainable(vertexID Integer, outName Integer) : boolean in class org.apache.flink.streaming.api.StreamingJobGraphGenerator |
From |
To |
|
Change Parameter Type chainedOutputs : List<String> to chainedOutputs : List<Integer> in method public setChainedOutputs(chainedOutputs List<Integer>) : void in class org.apache.flink.streaming.api.StreamConfig |
From |
To |
|
Change Parameter Type output : String to output : Integer in method public setPartitioner(output Integer, partitionerObject StreamPartitioner<T>) : void in class org.apache.flink.streaming.api.StreamConfig |
From |
To |
|
Change Parameter Type toReplace : String to toReplace : Integer in method private replaceDiscretizer(streamGraph StreamGraph, toReplace Integer, replaceWith Integer) : void in class org.apache.flink.streaming.api.WindowingOptimzier |
From |
To |
|
Change Parameter Type vertexName : String to vertexID : Integer in method public getInvokable(vertexID Integer) : StreamInvokable<?,?> in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Change Parameter Type outEdgeList : List<Tuple2<String,String>> to outEdgeList : List<Tuple2<Integer,Integer>> in method public setOutEdgesInOrder(outEdgeList List<Tuple2<Integer,Integer>>) : void in class org.apache.flink.streaming.api.StreamConfig |
From |
To |
|
Change Parameter Type downStreamVertexName : String to downStreamVertexID : Integer in method public setEdge(upStreamVertexID Integer, downStreamVertexID Integer, partitionerObject StreamPartitioner<?>, typeNumber int, outputNames List<String>) : void in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Change Parameter Type vertexName : String to vertexID : Integer in method public getOutEdgeTypes(vertexID Integer) : List<Integer> in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Change Parameter Type downStream : String to downStream : Integer in method public removeEdge(upStream Integer, downStream Integer) : void in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Change Parameter Type vertexName : String to vertexID : Integer in method public addSourceVertex(vertexID Integer, invokableObject StreamInvokable<IN,OUT>, inTypeInfo TypeInformation<IN>, outTypeInfo TypeInformation<OUT>, operatorName String, parallelism int) : void in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Change Parameter Type output : String to output : Integer in method public setSelectedNames(output Integer, selected List<String>) : void in class org.apache.flink.streaming.api.StreamConfig |
From |
To |
|
Change Variable Type invokables : Set<Entry<String,StreamInvokable<?,?>>> to invokables : Set<Entry<Integer,StreamInvokable<?,?>>> in method public optimizeGraph(streamGraph StreamGraph) : void in class org.apache.flink.streaming.api.WindowingOptimzier |
From |
To |
|
Change Variable Type discretizers : List<Tuple2<String,StreamDiscretizer<?>>> to discretizers : List<Tuple2<Integer,StreamDiscretizer<?>>> in method public optimizeGraph(streamGraph StreamGraph) : void in class org.apache.flink.streaming.api.WindowingOptimzier |
From |
To |
|
Change Variable Type transitiveOutEdges : List<Tuple2<String,String>> to transitiveOutEdges : List<Tuple2<Integer,Integer>> 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 output : String to output : Integer in method private createChainedCollector(chainedTaskConfig StreamConfig) : Collector<OUT> in class org.apache.flink.streaming.api.streamvertex.OutputHandler |
From |
To |
|
Change Variable Type first : String to first : Integer in method private setDiscretizerReuse(streamGraph StreamGraph, discretizers List<Tuple2<Integer,StreamDiscretizer<?>>>) : void in class org.apache.flink.streaming.api.WindowingOptimzier |
From |
To |
|
Change Variable Type chainedConfs : Map<String,StreamConfig> to chainedConfs : Map<Integer,StreamConfig> 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 upStreamVertexName : String to upStreamvertexID : Integer in method private connect(headOfChain Integer, edge Tuple2<Integer,Integer>) : void in class org.apache.flink.streaming.api.StreamingJobGraphGenerator |
From |
To |
|
Change Variable Type entry : Entry<String,StreamInvokable<?,?>> to entry : Entry<Integer,StreamInvokable<?,?>> in method public optimizeGraph(streamGraph StreamGraph) : void in class org.apache.flink.streaming.api.WindowingOptimzier |
From |
To |
|
Change Variable Type discretizer : Tuple2<String,StreamDiscretizer<?>> to discretizer : Tuple2<Integer,StreamDiscretizer<?>> in method private setDiscretizerReuse(streamGraph StreamGraph, discretizers List<Tuple2<Integer,StreamDiscretizer<?>>>) : void in class org.apache.flink.streaming.api.WindowingOptimzier |
From |
To |
|
Change Variable Type matchingNames : List<String> to matchingNames : List<Integer> in method private setDiscretizerReuse(streamGraph StreamGraph, discretizers List<Tuple2<Integer,StreamDiscretizer<?>>>) : void in class org.apache.flink.streaming.api.WindowingOptimzier |
From |
To |
|
Change Variable Type output : String to output : Integer in method private setVertexConfig(vertexID Integer, config StreamConfig, chainableOutputs List<Integer>, nonChainableOutputs List<Integer>) : void in class org.apache.flink.streaming.api.StreamingJobGraphGenerator |
From |
To |
|
Change Variable Type output : String to output : Integer in method public removeVertex(toRemove Integer) : void in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Change Variable Type matching : Tuple2<StreamDiscretizer<?>,List<String>> to matching : Tuple2<StreamDiscretizer<?>,List<Integer>> in method private setDiscretizerReuse(streamGraph StreamGraph, discretizers List<Tuple2<Integer,StreamDiscretizer<?>>>) : void in class org.apache.flink.streaming.api.WindowingOptimzier |
From |
To |
|
Change Variable Type outEdges : List<String> to outEdges : List<Integer> in method public removeVertex(toRemove Integer) : void in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Change Variable Type outName : String to output : Integer in method private replaceDiscretizer(streamGraph StreamGraph, toReplace Integer, replaceWith Integer) : void in class org.apache.flink.streaming.api.WindowingOptimzier |
From |
To |
|
Change Variable Type chainable : String to chainable : Integer in method private createChainedName(vertexID Integer, chainedOutputs List<Integer>) : String in class org.apache.flink.streaming.api.StreamingJobGraphGenerator |
From |
To |
|
Change Variable Type matchingDiscretizers : List<Tuple2<StreamDiscretizer<?>,List<String>>> to matchingDiscretizers : List<Tuple2<StreamDiscretizer<?>,List<Integer>>> in method private setDiscretizerReuse(streamGraph StreamGraph, discretizers List<Tuple2<Integer,StreamDiscretizer<?>>>) : void in class org.apache.flink.streaming.api.WindowingOptimzier |
From |
To |
|
Change Variable Type allOutputs : List<String> to allOutputs : List<Integer> in method private setVertexConfig(vertexID Integer, config StreamConfig, chainableOutputs List<Integer>, nonChainableOutputs List<Integer>) : void in class org.apache.flink.streaming.api.StreamingJobGraphGenerator |
From |
To |
|
Change Variable Type inEdges : List<String> to inEdges : List<Integer> in method public removeVertex(toRemove Integer) : void in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Change Variable Type chainable : String to chainable : Integer 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 sourceName : String to sourceName : Integer in method private setChaining() : void in class org.apache.flink.streaming.api.StreamingJobGraphGenerator |
From |
To |
|
Change Variable Type downStreamVertexName : String to downStreamvertexID : Integer in method private connect(headOfChain Integer, edge Tuple2<Integer,Integer>) : void in class org.apache.flink.streaming.api.StreamingJobGraphGenerator |
From |
To |
|
Change Variable Type outEdge : Tuple2<String,String> to outEdge : Tuple2<Integer,Integer> in method public OutputHandler(vertex StreamVertex<?,OUT>) in class org.apache.flink.streaming.api.streamvertex.OutputHandler |
From |
To |
|
Change Variable Type nonChainable : String to nonChainable : Integer 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 matchingInEdges : Set<String> to matchingInEdges : Set<Integer> in method private setDiscretizerReuse(streamGraph StreamGraph, discretizers List<Tuple2<Integer,StreamDiscretizer<?>>>) : void in class org.apache.flink.streaming.api.WindowingOptimzier |
From |
To |
|
Change Variable Type outName : String to outName : Integer 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 outputname : String to outputname : Integer in method public toString() : String in class org.apache.flink.streaming.api.StreamConfig |
From |
To |
|
Change Variable Type confs : Map<String,StreamConfig> to confs : Map<Integer,StreamConfig> in method public getTransitiveChainedTaskConfigs(cl ClassLoader) : Map<Integer,StreamConfig> in class org.apache.flink.streaming.api.StreamConfig |
From |
To |
|
Change Variable Type chainableOutputs : List<String> to chainableOutputs : List<Integer> 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 inName : String to input : Integer in method private replaceDiscretizer(streamGraph StreamGraph, toReplace Integer, replaceWith Integer) : void in class org.apache.flink.streaming.api.WindowingOptimzier |
From |
To |
|
Change Variable Type nonChainableOutputs : List<String> to nonChainableOutputs : List<Integer> 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 discretizerInEdges : Set<String> to discretizerInEdges : Set<Integer> in method private setDiscretizerReuse(streamGraph StreamGraph, discretizers List<Tuple2<Integer,StreamDiscretizer<?>>>) : void in class org.apache.flink.streaming.api.WindowingOptimzier |
From |
To |
|
Change Variable Type inID : String to inID : Integer in method public getStreamingPlanAsJSON() : String in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Change Variable Type inEdges : List<String> to inEdges : List<Integer> in method private replaceDiscretizer(streamGraph StreamGraph, toReplace Integer, replaceWith Integer) : void in class org.apache.flink.streaming.api.WindowingOptimzier |
From |
To |
|
Change Variable Type map : Map<String,?> to map : Map<Integer,?> in method public removeVertex(toRemove Integer) : void in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Change Variable Type outEdges : List<String> to outEdges : List<Integer> in method private replaceDiscretizer(streamGraph StreamGraph, toReplace Integer, replaceWith Integer) : void in class org.apache.flink.streaming.api.WindowingOptimzier |
From |
To |
|
Change Variable Type input : String to input : Integer in method public removeVertex(toRemove Integer) : void in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Change Variable Type edge : Tuple2<String,String> to edge : Tuple2<Integer,Integer> 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 matchList : List<String> to matchList : List<Integer> in method private setDiscretizerReuse(streamGraph StreamGraph, discretizers List<Tuple2<Integer,StreamDiscretizer<?>>>) : void in class org.apache.flink.streaming.api.WindowingOptimzier |
From |
To |
|
Change Attribute Type typeSerializersIn1 : Map<String,StreamRecordSerializer<?>> to typeSerializersIn1 : Map<Integer,StreamRecordSerializer<?>> in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Change Attribute Type bufferTimeouts : Map<String,Long> to bufferTimeouts : Map<Integer,Long> in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Change Attribute Type id : String to id : Integer in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Attribute Type outputPartitioners : Map<String,List<StreamPartitioner<?>>> to outputPartitioners : Map<Integer,List<StreamPartitioner<?>>> in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Change Attribute Type inEdgeLists : Map<String,List<String>> to inEdgeLists : Map<Integer,List<Integer>> in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Change Attribute Type iterationIDtoHeadName : Map<Integer,String> to iterationIDtoHeadID : Map<Integer,Integer> in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Change Attribute Type chainedNames : Map<String,String> to chainedNames : Map<Integer,String> in class org.apache.flink.streaming.api.StreamingJobGraphGenerator |
From |
To |
|
Change Attribute Type outputMap : Map<String,StreamOutput<?>> to outputMap : Map<Integer,StreamOutput<?>> in class org.apache.flink.streaming.api.streamvertex.OutputHandler |
From |
To |
|
Change Attribute Type jobVertexClasses : Map<String,Class<? extends AbstractInvokable>> to jobVertexClasses : Map<Integer,Class<? extends AbstractInvokable>> in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Change Attribute Type sources : Set<String> to sources : Set<Integer> in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Change Attribute Type outEdgesInOrder : List<Tuple2<String,String>> to outEdgesInOrder : List<Tuple2<Integer,Integer>> in class org.apache.flink.streaming.api.streamvertex.OutputHandler |
From |
To |
|
Change Attribute Type vertexConfigs : Map<String,StreamConfig> to vertexConfigs : Map<Integer,StreamConfig> in class org.apache.flink.streaming.api.StreamingJobGraphGenerator |
From |
To |
|
Change Attribute Type typeSerializersOut2 : Map<String,StreamRecordSerializer<?>> to typeSerializersOut2 : Map<Integer,StreamRecordSerializer<?>> in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Change Attribute Type iterationIds : Map<String,Integer> to iterationIds : Map<Integer,Integer> in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Change Attribute Type operatorParallelisms : Map<String,Integer> to operatorParallelisms : Map<Integer,Integer> in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Change Attribute Type chainedConfigs : Map<String,StreamConfig> to chainedConfigs : Map<Integer,StreamConfig> in class org.apache.flink.streaming.api.streamvertex.OutputHandler |
From |
To |
|
Change Attribute Type containingMaps : List<Map<String,?>> to containingMaps : List<Map<Integer,?>> in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Change Attribute Type selectedNames : Map<String,List<List<String>>> to selectedNames : Map<Integer,List<List<String>>> in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Change Attribute Type iterationTailCount : Map<String,Integer> to iterationTailCount : Map<Integer,Integer> in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Change Attribute Type outEdgeLists : Map<String,List<String>> to outEdgeLists : Map<Integer,List<Integer>> in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Change Attribute Type builtNodes : Collection<String> to builtVertices : Collection<Integer> in class org.apache.flink.streaming.api.StreamingJobGraphGenerator |
From |
To |
|
Change Attribute Type chainedConfigs : Map<String,Map<String,StreamConfig>> to chainedConfigs : Map<Integer,Map<Integer,StreamConfig>> in class org.apache.flink.streaming.api.StreamingJobGraphGenerator |
From |
To |
|
Change Attribute Type outEdgeTypes : Map<String,List<Integer>> to outEdgeTypes : Map<Integer,List<Integer>> in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Change Attribute Type iterationTimeouts : Map<String,Long> to iterationTimeouts : Map<Integer,Long> in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Change Attribute Type streamVertices : Map<String,AbstractJobVertex> to streamVertices : Map<Integer,AbstractJobVertex> in class org.apache.flink.streaming.api.StreamingJobGraphGenerator |
From |
To |
|
Change Attribute Type inputFormatLists : Map<String,InputFormat<String,?>> to inputFormatLists : Map<Integer,InputFormat<String,?>> in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Change Attribute Type operatorStates : Map<String,Map<String,OperatorState<?>>> to operatorStates : Map<Integer,Map<String,OperatorState<?>>> in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Change Attribute Type invokableObjects : Map<String,StreamInvokable<?,?>> to invokableObjects : Map<Integer,StreamInvokable<?,?>> in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Change Attribute Type typeSerializersOut1 : Map<String,StreamRecordSerializer<?>> to typeSerializersOut1 : Map<Integer,StreamRecordSerializer<?>> in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Change Attribute Type typeSerializersIn2 : Map<String,StreamRecordSerializer<?>> to typeSerializersIn2 : Map<Integer,StreamRecordSerializer<?>> in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Change Attribute Type operatorNames : Map<String,String> to operatorNames : Map<Integer,String> in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Change Attribute Type iterationIDtoTailName : Map<Integer,String> to iterationIDtoTailID : Map<Integer,Integer> in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Change Attribute Type outputSelectors : Map<String,List<OutputSelector<?>>> to outputSelectors : Map<Integer,List<OutputSelector<?>>> in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Rename Parameter vertexName : String to vertexID : Integer in method public getInvokable(vertexID Integer) : StreamInvokable<?,?> in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Rename Parameter vertexName : String to vertexID : Integer in method private createProcessingVertex(vertexID Integer) : StreamConfig in class org.apache.flink.streaming.api.StreamingJobGraphGenerator |
From |
To |
|
Rename Parameter vertexName : String to vertexID : Integer in method public setOutputSelector(vertexID Integer, outputSelector OutputSelector<T>) : void in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Rename Parameter vertexName : String to vertexID : Integer in method public getOutEdgeTypes(vertexID Integer) : List<Integer> in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Rename Parameter vertexName : String to vertexID : Integer in method public getOutSerializer2(vertexID Integer) : StreamRecordSerializer<OUT> in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Rename Parameter vertexName : String to vertexID : Integer in method public addSourceVertex(vertexID Integer, invokableObject StreamInvokable<IN,OUT>, inTypeInfo TypeInformation<IN>, outTypeInfo TypeInformation<OUT>, operatorName String, parallelism int) : void in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Rename Parameter vertexName : String to vertexID : Integer in method public getOperatorName(vertexID Integer) : String in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Rename Parameter outputVertexNames : List<String> to outputvertexIDs : List<Integer> in method public setOutputs(outputvertexIDs List<Integer>) : void in class org.apache.flink.streaming.api.StreamConfig |
From |
To |
|
Rename Parameter vertexName : String to vertexID : Integer in method public getInputFormat(vertexID Integer) : InputFormat<String,?> in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Rename Parameter vertexName : String to vertexID : Integer in method public addStreamVertex(vertexID Integer, invokableObject StreamInvokable<IN,OUT>, inTypeInfo TypeInformation<IN>, outTypeInfo TypeInformation<OUT>, operatorName String, parallelism int) : void in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Rename Parameter vertexName : String to vertexID : Integer in method private addTypeSerializers(vertexID Integer, in1 StreamRecordSerializer<?>, in2 StreamRecordSerializer<?>, out1 StreamRecordSerializer<?>, out2 StreamRecordSerializer<?>) : void in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Rename Parameter vertexName : String to vertexID : Integer in method private setVertexConfig(vertexID Integer, config StreamConfig, chainableOutputs List<Integer>, nonChainableOutputs List<Integer>) : void in class org.apache.flink.streaming.api.StreamingJobGraphGenerator |
From |
To |
|
Rename Parameter vertexName : String to vertexID : Integer in method public getInEdges(vertexID Integer) : List<Integer> in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Rename Parameter downStreamVertexName : String to downStreamVertexID : Integer in method public setEdge(upStreamVertexID Integer, downStreamVertexID Integer, partitionerObject StreamPartitioner<?>, typeNumber int, outputNames List<String>) : void in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Rename Parameter vertexName : String to vertexID : Integer in method private addVertex(vertexID Integer, vertexClass Class<? extends AbstractInvokable>, invokableObject StreamInvokable<?,?>, operatorName String, parallelism int) : void in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Rename Parameter vertexName : String to vertexID : Integer in method public getOutSerializer1(vertexID Integer) : StreamRecordSerializer<OUT> in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Rename Parameter vertexName : String to vertexID : Integer in method public addIterationTail(vertexID Integer, iterationTail Integer, iterationID Integer, waitTime long) : void in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Rename Parameter vertexName : String to vertexID : Integer in method public getJobVertexClass(vertexID Integer) : Class<? extends AbstractInvokable> in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Rename Parameter vertexName : String to vertexID : Integer in method public getInSerializer2(vertexID Integer) : StreamRecordSerializer<IN> in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Rename Parameter vertexName : String to vertexID : Integer in method private isChainable(vertexID Integer, outName Integer) : boolean in class org.apache.flink.streaming.api.StreamingJobGraphGenerator |
From |
To |
|
Rename Parameter vertexName : String to vertexID : Integer in method public getInSerializer1(vertexID Integer) : StreamRecordSerializer<IN> in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Rename Parameter vertexName : String to vertexID : Integer in method public getBufferTimeout(vertexID Integer) : long in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Rename Parameter upStreamVertexName : String to upStreamVertexID : Integer in method public setEdge(upStreamVertexID Integer, downStreamVertexID Integer, partitionerObject StreamPartitioner<?>, typeNumber int, outputNames List<String>) : void in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Rename Parameter vertexName : String to vertexID : Integer in method public addIterationHead(vertexID Integer, iterationHead Integer, iterationID Integer, parallelism int, waitTime long) : void in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Rename Parameter vertexName : String to vertexID : Integer in method public getOutputSelector(vertexID Integer) : List<OutputSelector<?>> in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Rename Parameter vertexName : String to vertexID : Integer in method public getOutEdges(vertexID Integer) : List<Integer> in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Rename Parameter vertexName : String to vertexID : Integer in method public getState(vertexID Integer) : Map<String,OperatorState<?>> in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Rename Parameter vertexName : String to vertexID : Integer in method public getIterationTimeout(vertexID Integer) : long in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Rename Parameter vertexName : String to vertexID : Integer in method public setInputFormat(vertexID Integer, inputFormat InputFormat<String,?>) : void in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Rename Parameter vertexName : String to vertexID : Integer in method public setInvokable(vertexID Integer, invokableObject StreamInvokable<IN,OUT>) : void in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Rename Parameter vertexName : String to vertexID : Integer in method public getIterationID(vertexID Integer) : Integer in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Rename Parameter vertexName : String to vertexID : Integer in method public getParallelism(vertexID Integer) : int in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Rename Parameter vertexName : String to vertexID : Integer in method public addCoTask(vertexID Integer, taskInvokableObject CoInvokable<IN1,IN2,OUT>, in1TypeInfo TypeInformation<IN1>, in2TypeInfo TypeInformation<IN2>, outTypeInfo TypeInformation<OUT>, operatorName String, parallelism int) : void in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Rename Parameter vertexName : String to vertexID : Integer in method public setVertexID(vertexID Integer) : void in class org.apache.flink.streaming.api.StreamConfig |
From |
To |
|
Rename Parameter vertexName : String to vertexID : Integer in method public setParallelism(vertexID Integer, parallelism int) : void in class org.apache.flink.streaming.api.StreamGraph |
From |
To |
|
Rename Parameter vertexName : String to vertexID : Integer in method public setBufferTimeout(vertexID Integer, bufferTimeout long) : void in class org.apache.flink.streaming.api.StreamGraph |
From |
To |