|
Rename Method public getDirectedEmit() : boolean renamed to public isDirectedEmit() : boolean in class org.apache.flink.streaming.api.StreamConfig |
From |
To |
|
Rename Method private createChainedOutputs(chainedTaskIndex int) : Collector<OUT> renamed to private createChainedCollector(chainedTaskIndex int) : Collector<OUT> in class org.apache.flink.streaming.api.streamvertex.OutputHandler |
From |
To |
|
Rename Method public getInputType(inputNumber int) : int renamed to public getInputIndex(inputNumber int) : int in class org.apache.flink.streaming.api.StreamConfig |
From |
To |
|
Rename Method package setPartitioner(outputNumber int, endCollector StreamOutputWrapper<OUT>) : Collector<OUT> renamed to package addStreamOutput(outputNumber int, networkCollector StreamOutputWrapper<OUT>) : Collector<OUT> in class org.apache.flink.streaming.api.streamvertex.OutputHandler |
From |
To |
|
Rename Method public getSelectAll(outputIndex int) : boolean renamed to public isSelectAll(outputIndex int) : boolean in class org.apache.flink.streaming.api.StreamConfig |
From |
To |
|
Rename Method package setSerializers() : void renamed to package createOutSerializer() : void in class org.apache.flink.streaming.api.streamvertex.OutputHandler |
From |
To |
|
Rename Method private createEndCollector() : Collector<OUT> renamed to private createNetworkCollector() : Collector<OUT> in class org.apache.flink.streaming.api.streamvertex.OutputHandler |
From |
To |
|
Rename Method public setInputType(inputNumber int, inputTypeNumber Integer) : void renamed to public setInputIndex(inputNumber int, inputTypeNumber Integer) : void in class org.apache.flink.streaming.api.StreamConfig |
From |
To |
|
Rename Method public setBytesFrom(from String, to String) : void renamed to public setSerializersFrom(from String, to String) : void in class org.apache.flink.streaming.api.JobGraphBuilder |
From |
To |
|
Rename Attribute chainedInvokable : Map<String,List<ChainableInvokable<?,?>>> to lastInChains : Map<String,String> in class org.apache.flink.streaming.api.JobGraphBuilder |
From |
To |
|
Rename Attribute streamVertex : StreamVertex<?,OUT> to vertex : StreamVertex<?,OUT> in class org.apache.flink.streaming.api.streamvertex.OutputHandler |
From |
To |
|
Rename Attribute endCollector : Collector<OUT> to outerCollector : Collector<OUT> in class org.apache.flink.streaming.api.streamvertex.OutputHandler |
From |
To |
|
Rename Attribute outEdgeType : Map<String,List<Integer>> to outEdgeIndex : Map<String,List<Integer>> in class org.apache.flink.streaming.api.JobGraphBuilder |
From |
To |