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
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
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
OverseerCollectionProcessor
public OverseerCollectionProcessor(ZkStateReader zkStateReader,
String myId,
ShardHandler shardHandler,
String adminPath)
OverseerCollectionProcessor
protected OverseerCollectionProcessor(ZkStateReader zkStateReader,
String myId,
ShardHandler shardHandler,
String adminPath,
DistributedQueue workQueue)
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
Copyright © 2000-2013 Apache Software Foundation. All Rights Reserved.