Modifier and Type | Method and Description |
---|---|
EventType |
RegionTransition.getEventType() |
Modifier and Type | Method and Description |
---|---|
static RegionTransition |
RegionTransition.createRegionTransition(EventType type,
byte[] regionName,
ServerName sn) |
static RegionTransition |
RegionTransition.createRegionTransition(EventType type,
byte[] regionName,
ServerName sn,
byte[] payload) |
Modifier and Type | Method and Description |
---|---|
private void |
ZkRegionMergeCoordination.transitionMergingNode(HRegionInfo merged,
HRegionInfo a,
HRegionInfo b,
ServerName serverName,
RegionMergeCoordination.RegionMergeDetails rmd,
EventType beginState,
EventType endState)
Transitions an existing ephemeral node for the specified region which is
currently in the begin state to be in the end state.
|
private int |
ZKSplitTransactionCoordination.transitionSplittingNode(HRegionInfo parent,
HRegionInfo a,
HRegionInfo b,
ServerName serverName,
SplitTransactionCoordination.SplitTransactionDetails std,
EventType beginState,
EventType endState)
Transitions an existing ephemeral node for the specified region which is currently in the begin
state to be in the end state.
|
Modifier and Type | Field and Description |
---|---|
protected EventType |
EventHandler.eventType |
Modifier and Type | Field and Description |
---|---|
private ConcurrentHashMap<EventType,EventHandler.EventHandlerListener> |
ExecutorService.eventHandlerListeners |
private Map<EventType,EventHandler.EventHandlerListener> |
ExecutorService.Executor.eventHandlerListeners |
Modifier and Type | Method and Description |
---|---|
static EventType |
EventType.get(int code) |
EventType |
EventHandler.getEventType()
Return the event type
|
static EventType |
EventType.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static EventType[] |
EventType.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
void |
ExecutorService.registerListener(EventType type,
EventHandler.EventHandlerListener listener)
Subscribe to updates before and after processing instances of
EventType . |
EventHandler.EventHandlerListener |
ExecutorService.unregisterListener(EventType type)
Stop receiving updates before and after processing instances of
EventType |
Constructor and Description |
---|
EventHandler(Server server,
EventType eventType)
Default base class constructor.
|
Constructor and Description |
---|
ExecutorService.Executor(String name,
int maxThreads,
Map<EventType,EventHandler.EventHandlerListener> eventHandlerListeners) |
Modifier and Type | Field and Description |
---|---|
private List<EventType> |
AssignmentManager.ignoreStatesRSOffline |
Modifier and Type | Method and Description |
---|---|
private boolean |
AssignmentManager.deleteNodeInStates(String encodedName,
String desc,
ServerName sn,
EventType... types) |
Constructor and Description |
---|
TableEventHandler(EventType eventType,
TableName tableName,
Server server,
MasterServices masterServices) |
Constructor and Description |
---|
CloseRegionHandler(Server server,
RegionServerServices rsServices,
HRegionInfo regionInfo,
boolean abort,
CloseRegionCoordination closeRegionCoordination,
CloseRegionCoordination.CloseRegionDetails crd,
EventType eventType) |
CloseRegionHandler(Server server,
RegionServerServices rsServices,
HRegionInfo regionInfo,
boolean abort,
CloseRegionCoordination closeRegionCoordination,
CloseRegionCoordination.CloseRegionDetails crd,
EventType eventType,
ServerName destination) |
OpenRegionHandler(Server server,
RegionServerServices rsServices,
HRegionInfo regionInfo,
HTableDescriptor htd,
EventType eventType,
long masterSystemTime,
OpenRegionCoordination coordination,
OpenRegionCoordination.OpenRegionDetails ord) |
Modifier and Type | Method and Description |
---|---|
static void |
ZKAssign.createNodeOffline(ZooKeeperWatcher zkw,
HRegionInfo region,
ServerName serverName,
EventType event) |
static boolean |
ZKAssign.deleteNode(ZooKeeperWatcher zkw,
String encodedRegionName,
EventType expectedState,
int expectedVersion)
Deletes an existing unassigned node that is in the specified state for the
specified region.
|
static boolean |
ZKAssign.deleteNode(ZooKeeperWatcher zkw,
String encodedRegionName,
EventType expectedState,
ServerName sn)
Deletes an existing unassigned node that is in the specified state for the
specified region.
|
static boolean |
ZKAssign.deleteNode(ZooKeeperWatcher zkw,
String encodedRegionName,
EventType expectedState,
ServerName serverName,
int expectedVersion)
Deletes an existing unassigned node that is in the specified state for the
specified region.
|
static int |
ZKAssign.transitionNode(ZooKeeperWatcher zkw,
HRegionInfo region,
ServerName serverName,
EventType beginState,
EventType endState,
int expectedVersion)
Method that actually performs unassigned node transitions.
|
static int |
ZKAssign.transitionNode(ZooKeeperWatcher zkw,
HRegionInfo region,
ServerName serverName,
EventType beginState,
EventType endState,
int expectedVersion,
byte[] payload) |
static int |
ZKAssign.transitionNodeOpening(ZooKeeperWatcher zkw,
HRegionInfo region,
ServerName serverName,
EventType beginState) |
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.