ZkUtils

Value Members

1. final def !=(arg0: Any): Boolean

   

   Definition Classes

   AnyRef → Any

2. final def ##(): Int

   

   Definition Classes

   AnyRef → Any

3. final def ==(arg0: Any): Boolean

   

   Definition Classes

   AnyRef → Any

4. val AdminPath: String

   

5. val BrokerIdsPath: String

   

6. val BrokerTopicsPath: String

   

7. val ConsumersPath: String

   

8. val ControllerEpochPath: String

   

9. val ControllerPath: String

   

10. val DeleteTopicsPath: String

    

11. val PreferredReplicaLeaderElectionPath: String

    

12. val ReassignPartitionsPath: String

    

13. val TopicConfigChangesPath: String

    

14. val TopicConfigPath: String

    

15. final def asInstanceOf[T0]: T0

    

    Definition Classes

    Any

16. def clone(): AnyRef

    

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

17. def createPersistentPath(curator: CuratorFramework, path: String, data: Array[Byte]): Unit

    

    Create a persistent node with the given path and data.

    Create a persistent node with the given path and data. Create parents if necessary.

18. def createPersistentPath(curator: CuratorFramework, path: String): Unit

    

19. final def eq(arg0: AnyRef): Boolean

    

    Definition Classes

    AnyRef

20. def equals(arg0: Any): Boolean

    

    Definition Classes

    AnyRef → Any

21. def finalize(): Unit

    

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

    @throws( classOf[java.lang.Throwable] )

22. final def getClass(): Class[_]

    

    Definition Classes

    AnyRef → Any

23. def getDeleteTopicPath(topic: String): String

    

24. def getPartitionReassignmentZkData(partitionsToBeReassigned: Map[TopicAndPartition, Seq[Int]]): String

    

25. def getTopicConfigPath(topic: String): String

    

26. def getTopicPartitionsPath(topic: String): String

    

27. def getTopicPath(topic: String): String

    

28. def hashCode(): Int

    

    Definition Classes

    AnyRef → Any

29. final def isInstanceOf[T0]: Boolean

    

    Definition Classes

    Any

30. final def ne(arg0: AnyRef): Boolean

    

    Definition Classes

    AnyRef

31. final def notify(): Unit

    

    Definition Classes

    AnyRef

32. final def notifyAll(): Unit

    

    Definition Classes

    AnyRef

33. def readData(curator: CuratorFramework, path: String): (String, Stat)

    

34. def readDataMaybeNull(curator: CuratorFramework, path: String): (Option[String], Stat)

    

35. def replicaAssignmentZkData(map: Map[String, Seq[Int]]): String

    

    Get JSON partition to replica map from zookeeper.

36. implicit def serializeString(str: String): Array[Byte]

    

37. final def synchronized[T0](arg0: ⇒ T0): T0

    

    Definition Classes

    AnyRef

38. def toString(): String

    

    Definition Classes

    AnyRef → Any

39. def updatePersistentPath(curator: CuratorFramework, path: String, ba: Array[Byte], version: Int = 1): Any

    

    Update the value of a persistent node with the given path and data.

    Update the value of a persistent node with the given path and data. create parent directory if necessary. Never throw NodeExistException. Return the updated path zkVersion

40. final def wait(): Unit

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

41. final def wait(arg0: Long, arg1: Int): Unit

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

42. final def wait(arg0: Long): Unit

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )