Package org.apache.hadoop.hbase.replication

Class ReplicationBarrierFamilyFormat

java.lang.Object

org.apache.hadoop.hbase.replication.ReplicationBarrierFamilyFormat

@Private
public final class ReplicationBarrierFamilyFormat
extends Object

Helper class for storing replication barriers in family 'rep_barrier' of meta table.

See SerialReplicationChecker on how to make use of the barriers.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	ReplicationBarrierFamilyFormat.ReplicationBarrierResult

Field Summary

Fields

Modifier and Type	Field	Description
private static final byte	ESCAPE_BYTE
static final byte[]	REPLICATION_PARENT_QUALIFIER
private static final byte	SEPARATED_BYTE

Constructor Summary

Constructors

Modifier	Constructor	Description
private	ReplicationBarrierFamilyFormat()

Method Summary

Modifier and Type	Method	Description
static void	addReplicationBarrier(Put put, long openSeqNum)
static void	addReplicationParent(Put put, List<RegionInfo> parents)
static byte[]	getParentsBytes(List<RegionInfo> parents)
private static long	getReplicationBarrier(Cell c)
static ReplicationBarrierFamilyFormat.ReplicationBarrierResult	getReplicationBarrierResult(Connection conn, TableName tableName, byte[] row, byte[] encodedRegionName)
private static ReplicationBarrierFamilyFormat.ReplicationBarrierResult	getReplicationBarrierResult(Result result)
static long[]	getReplicationBarriers(Connection conn, byte[] regionName)
static long[]	getReplicationBarriers(Result result)
static List<Pair<String,Long>>	getTableEncodedRegionNameAndLastBarrier(Connection conn, TableName tableName)
static List<String>	getTableEncodedRegionNamesForSerialReplication(Connection conn, TableName tableName)
static Put	makePutForReplicationBarrier(RegionInfo regionInfo, long openSeqNum, long ts)
private static List<byte[]>	parseParentsBytes(byte[] bytes)
private static void	writeRegionName(ByteArrayOutputStream out, byte[] regionName)

Methods inherited from class java.lang.Object

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

Field Details

REPLICATION_PARENT_QUALIFIER

public static final byte[] REPLICATION_PARENT_QUALIFIER

ESCAPE_BYTE

private static final byte ESCAPE_BYTE

See Also:

• Constant Field Values

SEPARATED_BYTE

private static final byte SEPARATED_BYTE

See Also:

• Constant Field Values

Constructor Details

ReplicationBarrierFamilyFormat

private ReplicationBarrierFamilyFormat()

Method Details

addReplicationBarrier

public static void addReplicationBarrier(Put put,
 long openSeqNum)
                                  throws IOException

Throws:

IOException

writeRegionName

private static void writeRegionName(ByteArrayOutputStream out,
 byte[] regionName)

getParentsBytes

public static byte[] getParentsBytes(List<RegionInfo> parents)

parseParentsBytes

private static List<byte[]> parseParentsBytes(byte[] bytes)

addReplicationParent

public static void addReplicationParent(Put put,
 List<RegionInfo> parents)
                                 throws IOException

Throws:

IOException

makePutForReplicationBarrier

public static Put makePutForReplicationBarrier(RegionInfo regionInfo,
 long openSeqNum,
 long ts)
                                        throws IOException

Throws:

IOException

getReplicationBarrier

private static long getReplicationBarrier(Cell c)

getReplicationBarriers

public static long[] getReplicationBarriers(Result result)

getReplicationBarrierResult

private static ReplicationBarrierFamilyFormat.ReplicationBarrierResult getReplicationBarrierResult(Result result)

getReplicationBarrierResult

public static ReplicationBarrierFamilyFormat.ReplicationBarrierResult getReplicationBarrierResult(Connection conn,
 TableName tableName,
 byte[] row,
 byte[] encodedRegionName)
                                                                                           throws IOException

Throws:

IOException

getReplicationBarriers

public static long[] getReplicationBarriers(Connection conn,
 byte[] regionName)
                                     throws IOException

Throws:

IOException

getTableEncodedRegionNameAndLastBarrier

public static List<Pair<String,Long>> getTableEncodedRegionNameAndLastBarrier(Connection conn,
 TableName tableName)
                                                                       throws IOException

Throws:

IOException

getTableEncodedRegionNamesForSerialReplication

public static List<String> getTableEncodedRegionNamesForSerialReplication(Connection conn,
 TableName tableName)
                                                                   throws IOException

Throws:

IOException