|
Rename Method public selectChannels(record SerializationDelegate<StreamRecord<T>>) : int[] renamed to public selectChannel(record SerializationDelegate<StreamRecord<T>>) : int in class org.apache.flink.streaming.runtime.partitioner.KeyGroupStreamPartitioner |
From |
To |
|
Rename Method public selectChannels(record SerializationDelegate<T>) : int[] renamed to public selectChannel(record SerializationDelegate<T>) : int in class org.apache.flink.runtime.operators.shipping.OutputEmitter |
From |
To |
|
Rename Method public selectChannels(record SerializationDelegate<StreamRecord<T>>) : int[] renamed to public selectChannel(record SerializationDelegate<StreamRecord<T>>) : int in class org.apache.flink.streaming.runtime.partitioner.CustomPartitionerWrapper |
From |
To |
|
Rename Method public selectChannels(record SerializationDelegate<StreamRecord<T>>) : int[] renamed to public selectChannel(record SerializationDelegate<StreamRecord<T>>) : int in class org.apache.flink.streaming.runtime.partitioner.RebalancePartitioner |
From |
To |
|
Rename Method public selectChannels(record SerializationDelegate<StreamRecord<T>>) : int[] renamed to public selectChannel(record SerializationDelegate<StreamRecord<T>>) : int in class org.apache.flink.streaming.runtime.partitioner.RescalePartitioner |
From |
To |
|
Change Return Type int[] to int in method public selectChannel(record SerializationDelegate<StreamRecord<T>>) : int in class org.apache.flink.streaming.runtime.partitioner.RescalePartitioner |
From |
To |
|
Change Return Type int[] to int in method private selectChannels(serializationDelegate SerializationDelegate<StreamRecord<Tuple2<String,Integer>>>, numberOfChannels int) : int in class org.apache.flink.streaming.runtime.partitioner.KeyGroupStreamPartitionerTest |
From |
To |
|
Change Return Type int[] to int in method public selectChannel(record SerializationDelegate<T>) : int in class org.apache.flink.runtime.operators.shipping.OutputEmitter |
From |
To |
|
Change Return Type int[] to int in method private customPartition(record T, numberOfChannels int) : int in class org.apache.flink.runtime.operators.shipping.OutputEmitter |
From |
To |
|
Change Return Type int[] to int in method public selectChannel(record SerializationDelegate<StreamRecord<T>>) : int in class org.apache.flink.streaming.runtime.partitioner.CustomPartitionerWrapper |
From |
To |
|
Change Return Type int[] to int in method private forward() : int in class org.apache.flink.runtime.operators.shipping.OutputEmitter |
From |
To |
|
Change Return Type int[] to int in method public selectChannel(record SerializationDelegate<StreamRecord<T>>) : int in class org.apache.flink.streaming.runtime.partitioner.RebalancePartitioner |
From |
To |
|
Change Return Type int[] to int in method public selectChannel(record SerializationDelegate<StreamRecord<T>>) : int in class org.apache.flink.streaming.runtime.partitioner.KeyGroupStreamPartitioner |
From |
To |
|
Change Return Type int[] to int in method private robin(numberOfChannels int) : int in class org.apache.flink.runtime.operators.shipping.OutputEmitter |
From |
To |
|
Change Return Type int[] to int in method private hashPartitionDefault(record T, numberOfChannels int) : int in class org.apache.flink.runtime.operators.shipping.OutputEmitter |
From |
To |
|
Change Return Type int[] to int in method private rangePartition(record T, numberOfChannels int) : int in class org.apache.flink.runtime.operators.shipping.OutputEmitter |
From |
To |