Package org.apache.solr.client.solrj.impl

Class ZkClientClusterStateProvider

java.lang.Object

org.apache.solr.client.solrj.impl.ZkClientClusterStateProvider

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.solr.client.solrj.impl.ClusterStateProvider, org.apache.solr.client.solrj.impl.SolrZkClientTimeout.SolrZkClientTimeoutAware, org.apache.solr.common.SolrCloseable

public class ZkClientClusterStateProvider
extends Object
implements org.apache.solr.client.solrj.impl.ClusterStateProvider, org.apache.solr.client.solrj.impl.SolrZkClientTimeout.SolrZkClientTimeoutAware

Retrieves cluster state from Zookeeper

Constructor Summary

Constructors

Constructor	Description
ZkClientClusterStateProvider(String zkHost)
ZkClientClusterStateProvider(Collection<String> zkHosts, String chroot)
ZkClientClusterStateProvider(Collection<String> zkHosts, String chroot, boolean canUseZkACLs)
ZkClientClusterStateProvider(ZkStateReader zkStateReader)

Method Summary

Modifier and Type	Method	Description
void	close()
static ZkClientClusterStateProvider	from(org.apache.solr.client.solrj.impl.CloudSolrClient client)	Extracts this from the client, or throws an exception if of the wrong type.
Map<String,String>	getAliasProperties(String alias)
Map<String,Object>	getClusterProperties()
Object	getClusterProperty(String propertyName)
<T> T	getClusterProperty(String propertyName, T def)
org.apache.solr.common.cloud.ClusterState	getClusterState()
Set<String>	getLiveNodes()
String	getPolicyNameByCollection(String coll)
String	getQuorumHosts()
org.apache.solr.common.cloud.ClusterState.CollectionRef	getState(String collection)
String	getUrlScheme()
int	getZkClientTimeout()
int	getZkConnectTimeout()
String	getZkHost()
ZkStateReader	getZkStateReader()
boolean	isClosed()
List<String>	resolveAlias(String alias)
String	resolveSimpleAlias(String alias)
void	setZkClientTimeout(int zkClientTimeout)	Set the timeout to the zookeeper ensemble in ms
void	setZkConnectTimeout(int zkConnectTimeout)	Set the connect timeout to the zookeeper ensemble in ms
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.solr.client.solrj.impl.ClusterStateProvider

getCollection, isRoutedAlias

Constructor Details

ZkClientClusterStateProvider

public ZkClientClusterStateProvider(ZkStateReader zkStateReader)

ZkClientClusterStateProvider

public ZkClientClusterStateProvider(Collection<String> zkHosts,
 String chroot)

ZkClientClusterStateProvider

public ZkClientClusterStateProvider(Collection<String> zkHosts,
 String chroot,
 boolean canUseZkACLs)

ZkClientClusterStateProvider

public ZkClientClusterStateProvider(String zkHost)

Method Details

from

public static ZkClientClusterStateProvider from(org.apache.solr.client.solrj.impl.CloudSolrClient client)

Extracts this from the client, or throws an exception if of the wrong type.

getState

public org.apache.solr.common.cloud.ClusterState.CollectionRef getState(String collection)

Specified by:

getState in interface org.apache.solr.client.solrj.impl.ClusterStateProvider

getLiveNodes

public Set<String> getLiveNodes()

Specified by:

getLiveNodes in interface org.apache.solr.client.solrj.impl.ClusterStateProvider

resolveAlias

public List<String> resolveAlias(String alias)

Specified by:

resolveAlias in interface org.apache.solr.client.solrj.impl.ClusterStateProvider

getAliasProperties

public Map<String,String> getAliasProperties(String alias)

Specified by:

getAliasProperties in interface org.apache.solr.client.solrj.impl.ClusterStateProvider

resolveSimpleAlias

public String resolveSimpleAlias(String alias)
                          throws IllegalArgumentException

Specified by:

resolveSimpleAlias in interface org.apache.solr.client.solrj.impl.ClusterStateProvider

Throws:

IllegalArgumentException

getClusterProperty

public Object getClusterProperty(String propertyName)

Specified by:

getClusterProperty in interface org.apache.solr.client.solrj.impl.ClusterStateProvider

getClusterProperty

public <T> T getClusterProperty(String propertyName,
 T def)

Specified by:

getClusterProperty in interface org.apache.solr.client.solrj.impl.ClusterStateProvider

getClusterState

public org.apache.solr.common.cloud.ClusterState getClusterState()

Specified by:

getClusterState in interface org.apache.solr.client.solrj.impl.ClusterStateProvider

getClusterProperties

public Map<String,Object> getClusterProperties()

Specified by:

getClusterProperties in interface org.apache.solr.client.solrj.impl.ClusterStateProvider

getPolicyNameByCollection

public String getPolicyNameByCollection(String coll)

Specified by:

getPolicyNameByCollection in interface org.apache.solr.client.solrj.impl.ClusterStateProvider

getZkStateReader

public ZkStateReader getZkStateReader()

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException

getQuorumHosts

public String getQuorumHosts()

Specified by:

getQuorumHosts in interface org.apache.solr.client.solrj.impl.ClusterStateProvider

toString

public String toString()

Overrides:

toString in class Object

isClosed

public boolean isClosed()

Specified by:

isClosed in interface org.apache.solr.common.SolrCloseable

getZkHost

public String getZkHost()

Returns:

the zkHost value used to connect to zookeeper.

getZkConnectTimeout

public int getZkConnectTimeout()

setZkConnectTimeout

public void setZkConnectTimeout(int zkConnectTimeout)

Set the connect timeout to the zookeeper ensemble in ms

Specified by:

setZkConnectTimeout in interface org.apache.solr.client.solrj.impl.SolrZkClientTimeout.SolrZkClientTimeoutAware

getZkClientTimeout

public int getZkClientTimeout()

setZkClientTimeout

public void setZkClientTimeout(int zkClientTimeout)

Set the timeout to the zookeeper ensemble in ms

Specified by:

setZkClientTimeout in interface org.apache.solr.client.solrj.impl.SolrZkClientTimeout.SolrZkClientTimeoutAware

getUrlScheme

public String getUrlScheme()

Specified by:

getUrlScheme in interface org.apache.solr.client.solrj.impl.ClusterStateProvider

Returns:

url scheme with the help of cluster property or environment variable.