Skip to content

Instantly share code, notes, and snippets.

@jjkoshy

jjkoshy/gist:3718883

Created September 14, 2012 00:18
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save jjkoshy/3718883 to your computer and use it in GitHub Desktop.
Save jjkoshy/3718883 to your computer and use it in GitHub Desktop.
Download ZIP
Topic partition tuples in kafka 0.8
Raw
gistfile1.txt
git grep -n "(String, Int)" -- *.scala
core/src/main/scala/kafka/api/LeaderAndISRRequest.scala:78: val leaderAndISRInfos = new HashMap[(String, Int), LeaderAndISR]
core/src/main/scala/kafka/api/LeaderAndISRRequest.scala:96: leaderAndISRInfos: Map[(String, Int), LeaderAndISR])
core/src/main/scala/kafka/api/LeaderAndISRRequest.scala:98: def this(isInit: Boolean, leaderAndISRInfos: Map[(String, Int), LeaderAndISR]) = {
core/src/main/scala/kafka/api/LeaderAndISRResponse.scala:32: val responseMap = new HashMap[(String, Int), Short]()
core/src/main/scala/kafka/api/LeaderAndISRResponse.scala:45: responseMap: Map[(String, Int), Short],
core/src/main/scala/kafka/api/LeaderAndISRResponse.scala:60: for ((key:(String, Int), value) <- responseMap){
core/src/main/scala/kafka/api/StopReplicaRequest.scala:36: val topicPartitionPairSet = new HashSet[(String, Int)]()
core/src/main/scala/kafka/api/StopReplicaRequest.scala:47: stopReplicaSet: Set[(String, Int)])
core/src/main/scala/kafka/api/StopReplicaRequest.scala:49: def this(stopReplicaSet: Set[(String, Int)]) = {
core/src/main/scala/kafka/api/StopReplicaResponse.scala:33: val responseMap = new HashMap[(String, Int), Short]()
core/src/main/scala/kafka/api/StopReplicaResponse.scala:46: val responseMap: Map[(String, Int), Short],
core/src/main/scala/kafka/api/StopReplicaResponse.scala:60: for ((key:(String, Int), value) <- responseMap){
core/src/main/scala/kafka/common/TopicPartition.scala:25: def this(tuple: (String, Int)) = this(tuple._1, tuple._2)
core/src/main/scala/kafka/consumer/ConsumerFetcherManager.scala:40: private var partitionMap: immutable.Map[(String, Int), PartitionTopicInfo] = null
core/src/main/scala/kafka/consumer/ConsumerFetcherManager.scala:111: def getPartitionTopicInfo(key: (String, Int)) : PartitionTopicInfo = {
core/src/main/scala/kafka/consumer/ZookeeperConsumerConnector.scala:487: var partitionOwnershipDecision = new collection.mutable.HashMap[(String, Int), String]()
core/src/main/scala/kafka/consumer/ZookeeperConsumerConnector.scala:605: private def reflectPartitionOwnershipDecision(partitionOwnershipDecision: Map[(String, Int), String]
core/src/main/scala/kafka/consumer/ZookeeperConsumerConnector.scala:606: var successfullyOwnedPartitions : List[(String, Int)] = Nil
core/src/main/scala/kafka/server/HighwaterMarkCheckpoint.scala:43: def write(highwaterMarksPerPartition: Map[(String, Int), Long]) {
core/src/main/scala/kafka/server/KafkaApis.scala:85: val responseMap = new HashMap[(String, Int), Short]
core/src/main/scala/kafka/server/KafkaController.scala:156: private var allPartitionReplicaAssignment: mutable.Map[(String, Int), Seq[Int]] = null
core/src/main/scala/kafka/server/KafkaController.scala:157: private var allLeaders: mutable.Map[(String, Int), Int] = null
core/src/main/scala/kafka/server/KafkaController.scala:174: allLeaders = new mutable.HashMap[(String, Int), Int]
core/src/main/scala/kafka/server/KafkaController.scala:283: val brokerToLeaderAndISRInfosMap = new mutable.HashMap[Int, mutable.HashMap[(String, Int), LeaderAndISR]]
core/src/main/scala/kafka/server/KafkaController.scala:294: brokerToLeaderAndISRInfosMap.put(b, new mutable.HashMap[(String, Int), LeaderAndISR])
core/src/main/scala/kafka/server/KafkaController.scala:316: private def initLeaders(partitionReplicaAssignment: collection.mutable.Map[(String, Int), Seq[Int]]) {
core/src/main/scala/kafka/server/KafkaController.scala:317: val brokerToLeaderAndISRInfosMap = new mutable.HashMap[Int, mutable.HashMap[(String, Int),LeaderAndISR]]
core/src/main/scala/kafka/server/KafkaController.scala:350: brokerToLeaderAndISRInfosMap.put(b, new mutable.HashMap[(String, Int), LeaderAndISR])
core/src/main/scala/kafka/server/KafkaController.scala:378: val brokerToLeaderAndISRInfosMap = new mutable.HashMap[Int, mutable.HashMap[(String, Int), LeaderAndISR]]
core/src/main/scala/kafka/server/KafkaController.scala:425: brokerToLeaderAndISRInfosMap.put(b, new mutable.HashMap[(String, Int), LeaderAndISR])
core/src/main/scala/kafka/server/KafkaController.scala:465: private def handleNewTopics(topics: Set[String], partitionReplicaAssignment: mutable.Map[(String, Int), Seq[Int]])
core/src/main/scala/kafka/server/KafkaController.scala:472: private def handleDeletedTopics(topics: Set[String], partitionReplicaAssignment: mutable.Map[(String, Int), Seq[Int
core/src/main/scala/kafka/server/KafkaController.scala:473: val brokerToPartitionToStopReplicaMap = new collection.mutable.HashMap[Int, collection.mutable.HashSet[(String, I
core/src/main/scala/kafka/server/KafkaController.scala:477: brokerToPartitionToStopReplicaMap.put(broker, new collection.mutable.HashSet[(String, Int)])
core/src/main/scala/kafka/server/ReplicaManager.scala:34: private val allPartitions = new Pool[(String, Int), Partition]
core/src/main/scala/kafka/server/ReplicaManager.scala:117: def becomeLeaderOrFollower(leaderAndISRRequest: LeaderAndISRRequest): collection.Map[(String, Int), Short] = {
core/src/main/scala/kafka/server/ReplicaManager.scala:119: val responseMap = new collection.mutable.HashMap[(String, Int), Short]
core/src/main/scala/kafka/utils/Utils.scala:465: def getHostPort(hostport: String) : (String, Int) = {
core/src/main/scala/kafka/utils/Utils.scala:470: def getTopicPartition(topicPartition: String) : (String, Int) = {
core/src/main/scala/kafka/utils/ZkUtils.scala:399: def getReplicaAssignmentForTopics(zkClient: ZkClient, topics: Iterator[String]): mutable.Map[(String, Int), Seq[Int]] = {
core/src/main/scala/kafka/utils/ZkUtils.scala:400: val ret = new mutable.HashMap[(String, Int), Seq[Int]]
core/src/main/scala/kafka/utils/ZkUtils.scala:418: def getPartitionLeaderAndISRForTopics(zkClient: ZkClient, topics: Iterator[String]): mutable.Map[(String, Int), LeaderAndISR
core/src/main/scala/kafka/utils/ZkUtils.scala:419: val ret = new mutable.HashMap[(String, Int), LeaderAndISR]
core/src/main/scala/kafka/utils/ZkUtils.scala:451: def getReplicaAssignmentFromPartitionAssignment(topicPartitionAssignment: mutable.Map[String, collection.Map[Int, Seq[Int]]]
core/src/main/scala/kafka/utils/ZkUtils.scala:452: val ret = new mutable.HashMap[(String, Int), Seq[Int]]
core/src/main/scala/kafka/utils/ZkUtils.scala:471: def getPartitionsAssignedToBroker(zkClient: ZkClient, topics: Seq[String], brokerId: Int): Map[(String, Int), Seq[Int]] = {
core/src/main/scala/kafka/utils/ZkUtils.scala:472: val ret = new mutable.HashMap[(String, Int), Seq[Int]]
core/src/test/scala/unit/kafka/server/ISRExpirationTest.scala:30: var topicPartitionISR: Map[(String, Int), Seq[Int]] = new HashMap[(String, Int), Seq[Int]]()
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment