public class OverseerCollectionProcessor extends Object implements Runnable, ClosableThread
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 |
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 boolean |
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 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 boolean processMessage(ZkNodeProps message, String operation)
public boolean isClosed()
isClosed
in interface ClosableThread
Copyright © 2000-2013 Apache Software Foundation. All Rights Reserved.