protected CuratorFramework createZKClient ( ) { val serviceConfig = getServiceConfig ( ) ; CuratorFramework zkClient = CuratorFrameworkFactory . builder ( ) . connectString ( serviceConfig . getZkURL ( ) ) . namespace ( "pravega/" + serviceConfig . getClusterName ( ) ) . retryPolicy ( new ExponentialBackoffRetry ( serviceConfig . getZkRetrySleepMs ( ) , serviceConfig . getZkRetryCount ( ) ) ) . sessionTimeoutMs ( serviceConfig . getZkSessionTimeoutMs ( ) ) . build ( ) ; zkClient . start ( ) ; return zkClient ; }
Creates a new instance of the CuratorFramework class using configuration from the shared AdminCommandState .