org.apache.hadoop.hbase.client

Class HBaseHbck

java.lang.Object

org.apache.hadoop.hbase.client.HBaseHbck

All Implemented Interfaces:

Closeable, AutoCloseable, Abortable, Hbck

@InterfaceAudience.Private
public class HBaseHbck
extends Object
implements Hbck

Use ClusterConnection.getHbck() to obtain an instance of Hbck instead of constructing an HBaseHbck directly. This will be mostly used by hbck tool.

Connection should be an unmanaged connection obtained via ConnectionFactory.createConnection(Configuration).

An instance of this class is lightweight and not-thread safe. A new instance should be created by each thread. Pooling or caching of the instance is not recommended.

See Also:

ConnectionFactory, ClusterConnection, Hbck

Field Summary

Fields

Modifier and Type	Field and Description
private boolean	aborted
private org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.HbckService.BlockingInterface	hbck
private static org.slf4j.Logger	LOG
private RpcControllerFactory	rpcControllerFactory

Constructor Summary

Constructors

Constructor and Description
HBaseHbck(org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.HbckService.BlockingInterface hbck, RpcControllerFactory rpcControllerFactory)

Method Summary

Modifier and Type	Method and Description
void	abort(String why, Throwable e) Abort the server or client.
List<Long>	assigns(List<String> encodedRegionNames, boolean override) Like Admin.assign(byte[]) but 'raw' in that it can do more than one Region at a time -- good if many Regions to online -- and it will schedule the assigns even in the case where Master is initializing (as long as the ProcedureExecutor is up).
List<Boolean>	bypassProcedure(List<Long> pids, long waitTime, boolean override, boolean recursive) Bypass specified procedure and move it to completion.
void	close()
void	fixMeta() Fix Meta.
boolean	isAborted() Check if the server or client was aborted.
boolean	runHbckChore() Request HBCK chore to run at master side.
List<Long>	scheduleServerCrashProcedure(List<org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.ServerName> serverNames)
TableState	setTableStateInMeta(TableState state) NOTE: This is a dangerous action, as existing running procedures for the table or regions which belong to the table may get confused.
private static String	toCommaDelimitedString(List<String> list)
List<Long>	unassigns(List<String> encodedRegionNames, boolean override) Like Admin.unassign(byte[], boolean) but 'raw' in that it can do more than one Region at a time -- good if many Regions to offline -- and it will schedule the assigns even in the case where Master is initializing (as long as the ProcedureExecutor is up).

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.hadoop.hbase.client.Hbck

assigns, unassigns

Field Detail

LOG

private static final org.slf4j.Logger LOG

aborted

private boolean aborted

hbck

private final org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.HbckService.BlockingInterface hbck

rpcControllerFactory

private RpcControllerFactory rpcControllerFactory

Constructor Detail

HBaseHbck

HBaseHbck(org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.HbckService.BlockingInterface hbck,
          RpcControllerFactory rpcControllerFactory)

Method Detail

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException

abort

public void abort(String why,
                  Throwable e)

Description copied from interface: Abortable

Abort the server or client.

Specified by:

abort in interface Abortable

Parameters:

why - Why we're aborting.

e - Throwable that caused abort. Can be null.

isAborted

public boolean isAborted()

Description copied from interface: Abortable

Check if the server or client was aborted.

Specified by:

isAborted in interface Abortable

Returns:

true if the server or client was aborted, false otherwise

setTableStateInMeta

public TableState setTableStateInMeta(TableState state)
                               throws IOException

NOTE: This is a dangerous action, as existing running procedures for the table or regions which belong to the table may get confused.

Specified by:

setTableStateInMeta in interface Hbck

Parameters:

state - table state

Returns:

previous state of the table in Meta

Throws:

IOException

assigns

public List<Long> assigns(List<String> encodedRegionNames,
                          boolean override)
                   throws IOException

Description copied from interface: Hbck

Like Admin.assign(byte[]) but 'raw' in that it can do more than one Region at a time -- good if many Regions to online -- and it will schedule the assigns even in the case where Master is initializing (as long as the ProcedureExecutor is up). Does NOT call Coprocessor hooks.

Specified by:

assigns in interface Hbck

Parameters:

encodedRegionNames - Region encoded names; e.g. 1588230740 is the hard-coded encoding for hbase:meta region and de00010733901a05f5a2a3a382e27dd4 is an example of what a random user-space encoded Region name looks like.

override - You need to add the override for case where a region has previously been bypassed. When a Procedure has been bypassed, a Procedure will have completed but no other Procedure will be able to make progress on the target entity (intentionally). This override flag will override this fencing mechanism.

Throws:

IOException

unassigns

public List<Long> unassigns(List<String> encodedRegionNames,
                            boolean override)
                     throws IOException

Description copied from interface: Hbck

Like Admin.unassign(byte[], boolean) but 'raw' in that it can do more than one Region at a time -- good if many Regions to offline -- and it will schedule the assigns even in the case where Master is initializing (as long as the ProcedureExecutor is up). Does NOT call Coprocessor hooks.

Specified by:

unassigns in interface Hbck

Parameters:

encodedRegionNames - Region encoded names; e.g. 1588230740 is the hard-coded encoding for hbase:meta region and de00010733901a05f5a2a3a382e27dd4 is an example of what a random user-space encoded Region name looks like.

override - You need to add the override for case where a region has previously been bypassed. When a Procedure has been bypassed, a Procedure will have completed but no other Procedure will be able to make progress on the target entity (intentionally). This override flag will override this fencing mechanism.

Throws:

IOException

toCommaDelimitedString

private static String toCommaDelimitedString(List<String> list)

bypassProcedure

public List<Boolean> bypassProcedure(List<Long> pids,
                                     long waitTime,
                                     boolean override,
                                     boolean recursive)
                              throws IOException

Description copied from interface: Hbck

Bypass specified procedure and move it to completion. Procedure is marked completed but no actual work is done from the current state/step onwards. Parents of the procedure are also marked for bypass.

Specified by:

bypassProcedure in interface Hbck

Parameters:

pids - of procedures to complete.

waitTime - wait time in ms for acquiring lock for a procedure

override - if override set to true, we will bypass the procedure even if it is executing. This is for procedures which can't break out during execution (bugs?).

recursive - If set, if a parent procedure, we will find and bypass children and then the parent procedure (Dangerous but useful in case where child procedure has been 'lost'). Does not always work. Experimental.

Returns:

true if procedure is marked for bypass successfully, false otherwise

Throws:

IOException

scheduleServerCrashProcedure

public List<Long> scheduleServerCrashProcedure(List<org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.ServerName> serverNames)
                                        throws IOException

Specified by:

scheduleServerCrashProcedure in interface Hbck

Throws:

IOException

runHbckChore

public boolean runHbckChore()
                     throws IOException

Description copied from interface: Hbck

Request HBCK chore to run at master side.

Specified by:

runHbckChore in interface Hbck

Returns:

true if HBCK chore ran, false if HBCK chore already running

Throws:

IOException - if a remote or network exception occurs

fixMeta

public void fixMeta()
             throws IOException

Description copied from interface: Hbck

Fix Meta.

Specified by:

fixMeta in interface Hbck

Throws:

IOException