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

Fields

Modifier and Type	Field and Description
static String	CREATE_NODE_SET
static String	CREATECOLLECTION
static String	DELETECOLLECTION
static String	MAX_SHARDS_PER_NODE
static String	NUM_SLICES
static String	RELOADCOLLECTION
static String	REPLICATION_FACTOR

Constructor Summary

Constructors

Modifier	Constructor and Description
	OverseerCollectionProcessor(ZkStateReader zkStateReader, String myId, ShardHandler shardHandler, String adminPath)
protected	OverseerCollectionProcessor(ZkStateReader zkStateReader, String myId, ShardHandler shardHandler, String adminPath, DistributedQueue workQueue)

Method Summary

Methods

Modifier and Type	Method and Description
protected boolean	amILeader()
void	close()
boolean	isClosed()
protected boolean	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

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 boolean processMessage(ZkNodeProps message,
                     String operation)

isClosed

public boolean isClosed()

Specified by:

isClosed in interface ClosableThread