org.apache.solr.cloud
Class OverseerCollectionProcessor

java.lang.Object
  org.apache.solr.cloud.OverseerCollectionProcessor

All Implemented Interfaces:

Runnable, ClosableThread

public class OverseerCollectionProcessor
extends Object
implements Runnable, ClosableThread

Field Summary

static String	COLL_CONF
static Map<String,Object>	COLL_PROPS
static String	CREATE_NODE_SET
static String	CREATEALIAS
static String	CREATECOLLECTION
static String	CREATESHARD
static String	DELETEALIAS
static String	DELETECOLLECTION
static String	DELETESHARD
static String	MAX_SHARDS_PER_NODE
static String	NUM_SLICES
static String	RELOADCOLLECTION
static String	REPLICATION_FACTOR
static String	ROUTER
static String	SHARDS_PROP
static String	SPLITSHARD

Constructor Summary

	OverseerCollectionProcessor(ZkStateReader zkStateReader, String myId, ShardHandler shardHandler, String adminPath)
protected	OverseerCollectionProcessor(ZkStateReader zkStateReader, String myId, ShardHandler shardHandler, String adminPath, DistributedQueue workQueue)

Method Summary

protected boolean	amILeader()
void	close()
boolean	isClosed()
protected SolrResponse	processMessage(ZkNodeProps message, String operation)
void	run()

Methods inherited from class java.lang.Object

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

Field Detail

NUM_SLICES

public static final String NUM_SLICES

See Also:

Constant Field Values

REPLICATION_FACTOR

public static final String REPLICATION_FACTOR

See Also:

Constant Field Values

MAX_SHARDS_PER_NODE

public static final String MAX_SHARDS_PER_NODE

See Also:

Constant Field Values

CREATE_NODE_SET

public static final String CREATE_NODE_SET

See Also:

Constant Field Values

DELETECOLLECTION

public static final String DELETECOLLECTION

See Also:

Constant Field Values

CREATECOLLECTION

public static final String CREATECOLLECTION

See Also:

Constant Field Values

RELOADCOLLECTION

public static final String RELOADCOLLECTION

See Also:

Constant Field Values

CREATEALIAS

public static final String CREATEALIAS

See Also:

Constant Field Values

DELETEALIAS

public static final String DELETEALIAS

See Also:

Constant Field Values

SPLITSHARD

public static final String SPLITSHARD

See Also:

Constant Field Values

DELETESHARD

public static final String DELETESHARD

See Also:

Constant Field Values

ROUTER

public static final String ROUTER

See Also:

Constant Field Values

SHARDS_PROP

public static final String SHARDS_PROP

See Also:

Constant Field Values

CREATESHARD

public static final String CREATESHARD

See Also:

Constant Field Values

COLL_CONF

public static final String COLL_CONF

See Also:

Constant Field Values

COLL_PROPS

public static final Map<String,Object> COLL_PROPS

Constructor Detail

OverseerCollectionProcessor

public OverseerCollectionProcessor(ZkStateReader zkStateReader,
                                   String myId,
                                   ShardHandler shardHandler,
                                   String adminPath)

OverseerCollectionProcessor

protected OverseerCollectionProcessor(ZkStateReader zkStateReader,
                                      String myId,
                                      ShardHandler shardHandler,
                                      String adminPath,
                                      DistributedQueue workQueue)

Method Detail

run

public void run()

Specified by:

run in interface Runnable

close

public void close()

Specified by:

close in interface ClosableThread

amILeader

protected boolean amILeader()

processMessage

protected SolrResponse processMessage(ZkNodeProps message,
                                      String operation)

isClosed

public boolean isClosed()

Specified by:

isClosed in interface ClosableThread