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	CREATE_NODE_SET
static String	CREATEALIAS
static String	CREATECOLLECTION
static String	DELETEALIAS
static String	DELETECOLLECTION
static String	MAX_SHARDS_PER_NODE
static String	NUM_SLICES
static String	RELOADCOLLECTION
static String	REPLICATION_FACTOR

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

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