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 | Field and Description |
---|---|
protected EventType |
EventHandler.eventType |
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 |
---|
TableEventHandler(EventType eventType,
TableName tableName,
Server server,
MasterServices masterServices) |
Modifier and Type | Method and Description |
---|---|
static int |
RegionMergeTransaction.transitionMergingNode(ZooKeeperWatcher zkw,
HRegionInfo merged,
HRegionInfo a,
HRegionInfo b,
ServerName serverName,
int znodeVersion,
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.
|
static int |
SplitTransaction.transitionSplittingNode(ZooKeeperWatcher zkw,
HRegionInfo parent,
HRegionInfo a,
HRegionInfo b,
ServerName serverName,
int znodeVersion,
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.
|
Constructor and Description |
---|
CloseRegionHandler(Server server,
RegionServerServices rsServices,
HRegionInfo regionInfo,
boolean abort,
boolean zk,
int versionOfClosingNode,
EventType eventType) |
CloseRegionHandler(Server server,
RegionServerServices rsServices,
HRegionInfo regionInfo,
boolean abort,
boolean zk,
int versionOfClosingNode,
EventType eventType,
ServerName destination) |
OpenRegionHandler(Server server,
RegionServerServices rsServices,
HRegionInfo regionInfo,
HTableDescriptor htd,
EventType eventType,
int versionOfOfflineNode) |
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)
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,
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 © 2013 The Apache Software Foundation. All rights reserved.