org.apache.solr.schema

Class ZkIndexSchemaReader

java.lang.Object

org.apache.solr.schema.ZkIndexSchemaReader

All Implemented Interfaces:

OnReconnect

public class ZkIndexSchemaReader
extends Object
implements OnReconnect

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

Constructor Summary

Constructors

Constructor and Description
ZkIndexSchemaReader(ManagedIndexSchemaFactory managedIndexSchemaFactory)

Method Summary

Methods

Modifier and Type	Method and Description
void	command() Called after a ZooKeeper session expiration occurs; need to re-create the watcher and update the current schema from ZooKeeper.
void	createSchemaWatcher()
Object	getSchemaUpdateLock()
ManagedIndexSchema	refreshSchemaFromZk(int expectedZkVersion)

Methods inherited from class java.lang.Object

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

Constructor Detail

ZkIndexSchemaReader

public ZkIndexSchemaReader(ManagedIndexSchemaFactory managedIndexSchemaFactory)

Method Detail

getSchemaUpdateLock

public Object getSchemaUpdateLock()

createSchemaWatcher

public void createSchemaWatcher()

refreshSchemaFromZk

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

Throws:

org.apache.zookeeper.KeeperException

InterruptedException

command

public void command()

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

Specified by:

command in interface OnReconnect