|
Rename Variable cnt : int to totalHitCount : int in method public testMultiKeys() : void in class org.apache.flink.runtime.operators.util.OutputEmitterTest |
From |
To |
|
Rename Variable oe1 : ChannelSelector<SerializationDelegate<Record>> to selector : ChannelSelector<SerializationDelegate<Record>> in method public testMultiKeys() : void in class org.apache.flink.runtime.operators.util.OutputEmitterTest |
From |
To |
|
Rename Variable oe1 : ChannelSelector<SerializationDelegate<Record>> to selector : ChannelSelector<SerializationDelegate<Record>> in method private getSelectedChannelsHitCount(shipStrategyType ShipStrategyType, numRecords int, numChannels int, recordType Enum) : int[] in class org.apache.flink.runtime.operators.util.OutputEmitterTest |
From |
To |
|
Rename Variable chan : int to channel : int in method private getSelectedChannelsHitCount(selector ChannelSelector<SerializationDelegate<Record>>, delegate SerializationDelegate<Record>, recordType Enum, numRecords int, numChannels int) : int[] in class org.apache.flink.runtime.operators.util.OutputEmitterTest |
From |
To |
|
Rename Variable oe1 : ChannelSelector<SerializationDelegate<Record>> to selector : ChannelSelector<SerializationDelegate<Record>> in method public testWrongKeyClass() : void in class org.apache.flink.runtime.operators.util.OutputEmitterTest |
From |
To |
|
Rename Variable rec : Record to record : Record in method private getSelectedChannelsHitCount(selector ChannelSelector<SerializationDelegate<Record>>, delegate SerializationDelegate<Record>, recordType Enum, numRecords int, numChannels int) : int[] in class org.apache.flink.runtime.operators.util.OutputEmitterTest |
From |
To |
|
Rename Variable chans : int[] to channels : int[] in method public testMultiKeys() : void in class org.apache.flink.runtime.operators.util.OutputEmitterTest |
From |
To |
|
Rename Variable hit : int[] to hits : int[] in method public testMultiKeys() : void in class org.apache.flink.runtime.operators.util.OutputEmitterTest |
From |
To |
|
Rename Variable k : IntValue to value : Value in method private getSelectedChannelsHitCount(selector ChannelSelector<SerializationDelegate<Record>>, delegate SerializationDelegate<Record>, recordType Enum, numRecords int, numChannels int) : int[] in class org.apache.flink.runtime.operators.util.OutputEmitterTest |
From |
To |
|
Rename Variable aHit : int to hit : int in method public testMultiKeys() : void in class org.apache.flink.runtime.operators.util.OutputEmitterTest |
From |
To |
|
Rename Variable cnt : int to totalHitCount : int in method private verifyPartitionHashSelectedChannels(numRecords int, numChannels int, recordType Enum) : void in class org.apache.flink.runtime.operators.util.OutputEmitterTest |
From |
To |
|
Rename Variable chans : int[] to channels : int[] in method private getSelectedChannelsHitCount(selector ChannelSelector<SerializationDelegate<Record>>, delegate SerializationDelegate<Record>, recordType Enum, numRecords int, numChannels int) : int[] in class org.apache.flink.runtime.operators.util.OutputEmitterTest |
From |
To |
|
Rename Variable oe1 : ChannelSelector<SerializationDelegate<Record>> to selector : ChannelSelector<SerializationDelegate<Record>> in method public testForcedRebalance() : void in class org.apache.flink.runtime.operators.util.OutputEmitterTest |
From |
To |
|
Rename Variable aHit : int to hit : int in method private verifyPartitionHashSelectedChannels(numRecords int, numChannels int, recordType Enum) : void in class org.apache.flink.runtime.operators.util.OutputEmitterTest |
From |
To |
|
Rename Variable oe2 : ChannelSelector<SerializationDelegate<Record>> to selector2 : ChannelSelector<SerializationDelegate<Record>> in method public testForcedRebalance() : void in class org.apache.flink.runtime.operators.util.OutputEmitterTest |
From |
To |
|
Rename Variable intComp : TypeComparator<Record> to comparator : TypeComparator<Record> in method private verifyWrongPartitionHashKey(position int, fieldNum int) : boolean in class org.apache.flink.runtime.operators.util.OutputEmitterTest |
From |
To |
|
Rename Variable chan : int to channel : int in method public testMultiKeys() : void in class org.apache.flink.runtime.operators.util.OutputEmitterTest |
From |
To |
|
Rename Variable intDel : SerializationDelegate<Integer> to serializationDelegate : SerializationDelegate<Integer> in method public testPartitionHash() : void in class org.apache.flink.runtime.operators.util.OutputEmitterTest |
From |
To |
|
Rename Variable rec : Record to record : Record in method public testWrongKeyClass() : void in class org.apache.flink.runtime.operators.util.OutputEmitterTest |
From |
To |
|
Rename Variable rec : Record to record : Record in method private verifyWrongPartitionHashKey(position int, fieldNum int) : boolean in class org.apache.flink.runtime.operators.util.OutputEmitterTest |
From |
To |
|
Rename Variable hit : int[] to hits : int[] in method public testForcedRebalance() : void in class org.apache.flink.runtime.operators.util.OutputEmitterTest |
From |
To |
|
Rename Variable oe3 : ChannelSelector<SerializationDelegate<Integer>> to selector : ChannelSelector<SerializationDelegate<Integer>> in method public testPartitionHash() : void in class org.apache.flink.runtime.operators.util.OutputEmitterTest |
From |
To |
|
Rename Variable oe1 : ChannelSelector<SerializationDelegate<Record>> to selector : ChannelSelector<SerializationDelegate<Record>> in method private verifyWrongPartitionHashKey(position int, fieldNum int) : boolean in class org.apache.flink.runtime.operators.util.OutputEmitterTest |
From |
To |
|
Rename Variable cnt : int to totalHitCount : int in method public testForcedRebalance() : void in class org.apache.flink.runtime.operators.util.OutputEmitterTest |
From |
To |
|
Rename Variable k : StringValue to value : Value in method private getSelectedChannelsHitCount(selector ChannelSelector<SerializationDelegate<Record>>, delegate SerializationDelegate<Record>, recordType Enum, numRecords int, numChannels int) : int[] in class org.apache.flink.runtime.operators.util.OutputEmitterTest |
From |
To |
|
Rename Variable rec : Record to record : Record in method public testMultiKeys() : void in class org.apache.flink.runtime.operators.util.OutputEmitterTest |
From |
To |
|
Parameterize Variable numRecs : int to numRecords : int in method private getSelectedChannelsHitCount(selector ChannelSelector<SerializationDelegate<Record>>, delegate SerializationDelegate<Record>, recordType Enum, numRecords int, numChannels int) : int[] in class org.apache.flink.runtime.operators.util.OutputEmitterTest |
From |
To |
|
Parameterize Variable oe1 : ChannelSelector<SerializationDelegate<Record>> to selector : ChannelSelector<SerializationDelegate<Record>> in method private getSelectedChannelsHitCount(selector ChannelSelector<SerializationDelegate<Record>>, delegate SerializationDelegate<Record>, recordType Enum, numRecords int, numChannels int) : int[] in class org.apache.flink.runtime.operators.util.OutputEmitterTest |
From |
To |
|
Parameterize Variable oe2 : ChannelSelector<SerializationDelegate<Record>> to selector : ChannelSelector<SerializationDelegate<Record>> in method private getSelectedChannelsHitCount(selector ChannelSelector<SerializationDelegate<Record>>, delegate SerializationDelegate<Record>, recordType Enum, numRecords int, numChannels int) : int[] in class org.apache.flink.runtime.operators.util.OutputEmitterTest |
From |
To |
|
Parameterize Variable numChans : int to numChannels : int in method private getSelectedChannelsHitCount(selector ChannelSelector<SerializationDelegate<Record>>, delegate SerializationDelegate<Record>, recordType Enum, numRecords int, numChannels int) : int[] in class org.apache.flink.runtime.operators.util.OutputEmitterTest |
From |
To |