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.common.SolrCloseable

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

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()
void	connect()
static org.apache.solr.common.cloud.ClusterState	createFromJsonSupportingLegacyConfigName(int version, byte[] bytes, Set<String> liveNodes, String coll, SolrZkClient zkClient, Instant createTime)	Deprecated.
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)
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 Detail

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 Detail

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.

createFromJsonSupportingLegacyConfigName

@Deprecated
public static org.apache.solr.common.cloud.ClusterState createFromJsonSupportingLegacyConfigName(int version,
                                                                                                 byte[] bytes,
                                                                                                 Set<String> liveNodes,
                                                                                                 String coll,
                                                                                                 SolrZkClient zkClient,
                                                                                                 Instant createTime)

Deprecated.

Create a ClusterState from Json. This method supports legacy configName location

Parameters:

bytes - a byte array of a Json representation of a mapping from collection name to the Json representation of a DocCollection as written by MapWriter.write(JSONWriter). It can represent one or more collections.

liveNodes - list of live nodes

coll - collection name

zkClient - ZK client

createTime - creation time of the data/bytes

Returns:

the ClusterState

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

connect

public void connect()

Specified by:

connect 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

getZkClientTimeout

public int getZkClientTimeout()

setZkClientTimeout

public void setZkClientTimeout(int zkClientTimeout)

Set the timeout to the zookeeper ensemble in ms