|
Rename Variable topicCountMap : Map<String,Integer> to topicCntMap : Map<String,Integer> in method public start() : void in class org.apache.ignite.stream.kafka.KafkaStreamer |
From |
To |
|
Rename Variable event : int to evt : int in method private produceStream(topic String) : Map<String,String> in class org.apache.ignite.stream.kafka.KafkaIgniteStreamerSelfTest |
From |
To |
|
Rename Variable zooServer : ZooKeeperServer to zkSrv : ZooKeeperServer in method package startup() : void in class org.apache.ignite.stream.kafka.KafkaEmbeddedBroker.EmbeddedZooKeeper |
From |
To |
|
Rename Variable partitionState : PartitionStateInfo to partState : PartitionStateInfo in method private isMetadataPropagated(topic String, part int) : boolean in class org.apache.ignite.stream.kafka.KafkaEmbeddedBroker |
From |
To |
|
Rename Variable stringDecoder : StringDecoder to strDecoder : StringDecoder in method private consumerStream(topic String, keyValMap Map<String,String>) : void in class org.apache.ignite.stream.kafka.KafkaIgniteStreamerSelfTest |
From |
To |
|
Rename Variable keyValueMap : Map<String,String> to keyValMap : Map<String,String> in method private produceStream(topic String) : Map<String,String> in class org.apache.ignite.stream.kafka.KafkaIgniteStreamerSelfTest |
From |
To |
|
Rename Variable keyValueMap : Map<String,String> to keyValMap : Map<String,String> in method public testKafkaStreamer() : void in class org.apache.ignite.stream.kafka.KafkaIgniteStreamerSelfTest |
From |
To |
|
Rename Parameter keyValueMap : Map<String,String> to keyValMap : Map<String,String> in method private consumerStream(topic String, keyValMap Map<String,String>) : void in class org.apache.ignite.stream.kafka.KafkaIgniteStreamerSelfTest |
From |
To |
|
Rename Parameter groupId : String to grpId : String in method private createDefaultConsumerConfig(zooKeeper String, grpId String) : ConsumerConfig in class org.apache.ignite.stream.kafka.KafkaIgniteStreamerSelfTest |
From |
To |
|
Rename Parameter valueDecoder : Decoder<V> to valDecoder : Decoder<V> in method public setValueDecoder(valDecoder Decoder<V>) : void in class org.apache.ignite.stream.kafka.KafkaStreamer |
From |
To |
|
Rename Parameter partition : int to part : int in method private isMetadataPropagated(topic String, part int) : boolean in class org.apache.ignite.stream.kafka.KafkaEmbeddedBroker |
From |
To |
|
Rename Parameter consumerConfig : ConsumerConfig to consumerCfg : ConsumerConfig in method public setConsumerConfig(consumerCfg ConsumerConfig) : void in class org.apache.ignite.stream.kafka.KafkaStreamer |
From |
To |
|
Rename Parameter partitionSize : int to partSize : int in method public partition(key Object, partSize int) : int in class org.apache.ignite.stream.kafka.SimplePartitioner |
From |
To |
|
Rename Parameter partition : int to part : int in method private waitUntilMetadataIsPropagated(topic String, part int, timeout long, interval long) : void in class org.apache.ignite.stream.kafka.KafkaEmbeddedBroker |
From |
To |