Package org.apache.solr.schema

Class ZkIndexSchemaReader

java.lang.Object

org.apache.solr.schema.ZkIndexSchemaReader

All Implemented Interfaces:

org.apache.curator.framework.state.ConnectionStateListener, org.apache.solr.common.cloud.OnReconnect

public class ZkIndexSchemaReader
extends Object
implements org.apache.solr.common.cloud.OnReconnect

Keeps a ManagedIndexSchema up-to-date when changes are made to the serialized managed schema in ZooKeeper

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ZkIndexSchemaReader.SchemaWatcher	Watches for schema changes and triggers updates in the ZkIndexSchemaReader.

Constructor Summary

Constructors

Constructor	Description
ZkIndexSchemaReader(ManagedIndexSchemaFactory managedIndexSchemaFactory, SolrCore solrCore)

Method Summary

Modifier and Type	Method	Description
ZkIndexSchemaReader.SchemaWatcher	createSchemaWatcher()	Creates a schema watcher and returns it for controlling purposes.
boolean	equals(Object other)
Object	getSchemaUpdateLock()
String	getUniqueCoreId()
int	hashCode()
void	onReconnect()	Called after a ZooKeeper session expiration occurs; need to re-create the watcher and update the current schema from ZooKeeper.
ManagedIndexSchema	refreshSchemaFromZk(int expectedZkVersion)
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.curator.framework.state.ConnectionStateListener

doNotProxy

Methods inherited from interface org.apache.solr.common.cloud.OnReconnect

stateChanged

Constructor Details

ZkIndexSchemaReader

public ZkIndexSchemaReader(ManagedIndexSchemaFactory managedIndexSchemaFactory,
 SolrCore solrCore)

Method Details

getSchemaUpdateLock

public Object getSchemaUpdateLock()

createSchemaWatcher

public ZkIndexSchemaReader.SchemaWatcher createSchemaWatcher()

Creates a schema watcher and returns it for controlling purposes.

Returns:

the registered ZkIndexSchemaReader.SchemaWatcher.

refreshSchemaFromZk

public ManagedIndexSchema refreshSchemaFromZk(int expectedZkVersion)
                                       throws org.apache.zookeeper.KeeperException,
InterruptedException

Throws:

org.apache.zookeeper.KeeperException

InterruptedException

onReconnect

public void onReconnect()

Called after a ZooKeeper session expiration occurs; need to re-create the watcher and update the current schema from ZooKeeper.

Specified by:

onReconnect in interface org.apache.solr.common.cloud.OnReconnect

getUniqueCoreId

public String getUniqueCoreId()

toString

public String toString()

Overrides:

toString in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object other)

Overrides:

equals in class Object