public class OverseerCollectionProcessor extends Object implements Runnable, ClosableThread
Modifier and Type | Field and Description |
---|---|
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 |
static String |
SPLITSHARD |
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) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
amILeader() |
void |
close() |
boolean |
isClosed() |
protected SolrResponse |
processMessage(ZkNodeProps message,
String operation) |
void |
run() |
public static final String NUM_SLICES
public static final String REPLICATION_FACTOR
public static final String MAX_SHARDS_PER_NODE
public static final String CREATE_NODE_SET
public static final String DELETECOLLECTION
public static final String CREATECOLLECTION
public static final String RELOADCOLLECTION
public static final String CREATEALIAS
public static final String DELETEALIAS
public static final String SPLITSHARD
public OverseerCollectionProcessor(ZkStateReader zkStateReader, String myId, ShardHandler shardHandler, String adminPath)
protected OverseerCollectionProcessor(ZkStateReader zkStateReader, String myId, ShardHandler shardHandler, String adminPath, DistributedQueue workQueue)
public void close()
close
in interface ClosableThread
protected boolean amILeader()
protected SolrResponse processMessage(ZkNodeProps message, String operation)
public boolean isClosed()
isClosed
in interface ClosableThread
Copyright © 2000-2013 Apache Software Foundation. All Rights Reserved.