| Modifier and Type | Class and Description |
|---|---|
static class |
ZkOpenRegionCoordination.ZkOpenRegionDetails
ZK-based implementation.
|
| Modifier and Type | Method and Description |
|---|---|
OpenRegionCoordination.OpenRegionDetails |
OpenRegionCoordination.getDetailsForNonCoordinatedOpening()
Get details object with params for case when we're opening on
regionserver side with all "default" properties.
|
OpenRegionCoordination.OpenRegionDetails |
ZkOpenRegionCoordination.getDetailsForNonCoordinatedOpening()
No ZK tracking will be performed for that case.
|
OpenRegionCoordination.OpenRegionDetails |
OpenRegionCoordination.parseFromProtoRequest(org.apache.hadoop.hbase.protobuf.generated.AdminProtos.OpenRegionRequest.RegionOpenInfo regionOpenInfo)
Construct OpenRegionDetails instance from part of protobuf request.
|
OpenRegionCoordination.OpenRegionDetails |
ZkOpenRegionCoordination.parseFromProtoRequest(org.apache.hadoop.hbase.protobuf.generated.AdminProtos.OpenRegionRequest.RegionOpenInfo regionOpenInfo)
Parse ZK-related fields from request.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
OpenRegionCoordination.commitOpenOnMasterSide(AssignmentManager assignmentManager,
HRegionInfo regionInfo,
OpenRegionCoordination.OpenRegionDetails ord)
Commits opening operation on HM side (steps required for "commit"
are determined by coordination implementation).
|
boolean |
ZkOpenRegionCoordination.commitOpenOnMasterSide(AssignmentManager assignmentManager,
HRegionInfo regionInfo,
OpenRegionCoordination.OpenRegionDetails ord) |
private boolean |
ZkOpenRegionCoordination.deleteOpenedNode(HRegionInfo regionInfo,
OpenRegionCoordination.OpenRegionDetails ord) |
boolean |
OpenRegionCoordination.tickleOpening(OpenRegionCoordination.OpenRegionDetails ord,
HRegionInfo regionInfo,
RegionServerServices rsServices,
String context)
Heartbeats to prevent timeouts.
|
boolean |
ZkOpenRegionCoordination.tickleOpening(OpenRegionCoordination.OpenRegionDetails ord,
HRegionInfo regionInfo,
RegionServerServices rsServices,
String context)
Update our OPENING state in zookeeper.
|
boolean |
OpenRegionCoordination.transitionFromOfflineToOpening(HRegionInfo regionInfo,
OpenRegionCoordination.OpenRegionDetails ord)
Transitions region from offline to opening state.
|
boolean |
ZkOpenRegionCoordination.transitionFromOfflineToOpening(HRegionInfo regionInfo,
OpenRegionCoordination.OpenRegionDetails ord)
Transition ZK node from OFFLINE to OPENING.
|
boolean |
OpenRegionCoordination.transitionToOpened(HRegion r,
OpenRegionCoordination.OpenRegionDetails ord)
Tries to move regions to OPENED state.
|
boolean |
ZkOpenRegionCoordination.transitionToOpened(HRegion r,
OpenRegionCoordination.OpenRegionDetails ord) |
boolean |
OpenRegionCoordination.tryTransitionFromOfflineToFailedOpen(RegionServerServices rsServices,
HRegionInfo hri,
OpenRegionCoordination.OpenRegionDetails ord)
Tries transition region from offline to failed open.
|
boolean |
ZkOpenRegionCoordination.tryTransitionFromOfflineToFailedOpen(RegionServerServices rsServices,
HRegionInfo hri,
OpenRegionCoordination.OpenRegionDetails ord)
Try to transition to open.
|
boolean |
OpenRegionCoordination.tryTransitionFromOpeningToFailedOpen(HRegionInfo hri,
OpenRegionCoordination.OpenRegionDetails ord)
Tries transition from Opening to Failed open.
|
boolean |
ZkOpenRegionCoordination.tryTransitionFromOpeningToFailedOpen(HRegionInfo hri,
OpenRegionCoordination.OpenRegionDetails ord)
This is not guaranteed to succeed, we just do our best.
|
| Modifier and Type | Method and Description |
|---|---|
(package private) void |
AssignmentManager.handleRegion(RegionTransition rt,
OpenRegionCoordination coordination,
OpenRegionCoordination.OpenRegionDetails ord)
Handles various states an unassigned node can be in.
|
(package private) boolean |
AssignmentManager.processRegionsInTransition(RegionTransition rt,
HRegionInfo regionInfo,
OpenRegionCoordination coordination,
OpenRegionCoordination.OpenRegionDetails ord)
This call is invoked only (1) master assign meta;
(2) during failover mode startup, zk assignment node processing.
|
| Modifier and Type | Field and Description |
|---|---|
private OpenRegionCoordination.OpenRegionDetails |
OpenedRegionHandler.ord |
| Constructor and Description |
|---|
OpenedRegionHandler(Server server,
AssignmentManager assignmentManager,
HRegionInfo regionInfo,
OpenRegionCoordination coordination,
OpenRegionCoordination.OpenRegionDetails ord) |
| Modifier and Type | Field and Description |
|---|---|
private OpenRegionCoordination.OpenRegionDetails |
OpenRegionHandler.ord |
| Modifier and Type | Method and Description |
|---|---|
private void |
OpenRegionHandler.doCleanUpOnFailedOpen(HRegion region,
boolean transitionedToOpening,
OpenRegionCoordination.OpenRegionDetails ord) |
| Constructor and Description |
|---|
OpenMetaHandler(Server server,
RegionServerServices rsServices,
HRegionInfo regionInfo,
HTableDescriptor htd,
long masterSystemTime,
OpenRegionCoordination coordination,
OpenRegionCoordination.OpenRegionDetails ord) |
OpenRegionHandler(Server server,
RegionServerServices rsServices,
HRegionInfo regionInfo,
HTableDescriptor htd,
EventType eventType,
long masterSystemTime,
OpenRegionCoordination coordination,
OpenRegionCoordination.OpenRegionDetails ord) |
OpenRegionHandler(Server server,
RegionServerServices rsServices,
HRegionInfo regionInfo,
HTableDescriptor htd,
long masterSystemTime,
OpenRegionCoordination coordination,
OpenRegionCoordination.OpenRegionDetails ord) |
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.