Package org.apache.hadoop.hbase.regionserver.wal

Class ProtobufLogTestHelper

java.lang.Object

org.apache.hadoop.hbase.regionserver.wal.ProtobufLogTestHelper

public final class ProtobufLogTestHelper
extends Object

Helper class for testing protobuf log.

Constructor Summary

Constructors

Modifier	Constructor	Description
private	ProtobufLogTestHelper()

Method Summary

Modifier and Type	Method	Description
static void	doRead(org.apache.hadoop.hbase.regionserver.wal.ProtobufWALStreamReader reader, boolean withTrailer, org.apache.hadoop.hbase.client.RegionInfo hri, org.apache.hadoop.hbase.TableName tableName, int columnCount, int recordCount, byte[] row, long timestamp)
static void	doRead(org.apache.hadoop.hbase.regionserver.wal.ProtobufWALStreamReader reader, boolean withTrailer, org.apache.hadoop.hbase.TableName tableName, int columnCount, int recordCount, byte[] row, long timestamp)
static void	doWrite(org.apache.hadoop.hbase.wal.WALProvider.Writer writer, boolean withTrailer, org.apache.hadoop.hbase.TableName tableName, int columnCount, int recordCount, byte[] row, long timestamp)
static void	doWrite(org.apache.hadoop.hbase.wal.WAL wal, org.apache.hadoop.hbase.client.RegionInfo hri, org.apache.hadoop.hbase.TableName tableName, int columnCount, int recordCount, byte[] row, long timestamp, org.apache.hadoop.hbase.regionserver.MultiVersionConcurrencyControl mvcc)
private static org.apache.hadoop.hbase.wal.WAL.Entry	generateEdit(int i, org.apache.hadoop.hbase.client.RegionInfo hri, org.apache.hadoop.hbase.TableName tableName, byte[] row, int columnCount, long timestamp, org.apache.hadoop.hbase.regionserver.MultiVersionConcurrencyControl mvcc)
private static org.apache.hadoop.hbase.client.RegionInfo	toRegionInfo(org.apache.hadoop.hbase.TableName tableName)
private static byte[]	toValue(int prefix, int suffix)

Methods inherited from class java.lang.Object

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

Constructor Details

ProtobufLogTestHelper

private ProtobufLogTestHelper()

Method Details

toValue

private static byte[] toValue(int prefix,
 int suffix)

toRegionInfo

private static org.apache.hadoop.hbase.client.RegionInfo toRegionInfo(org.apache.hadoop.hbase.TableName tableName)

generateEdit

private static org.apache.hadoop.hbase.wal.WAL.Entry generateEdit(int i,
 org.apache.hadoop.hbase.client.RegionInfo hri,
 org.apache.hadoop.hbase.TableName tableName,
 byte[] row,
 int columnCount,
 long timestamp,
 org.apache.hadoop.hbase.regionserver.MultiVersionConcurrencyControl mvcc)

doWrite

public static void doWrite(org.apache.hadoop.hbase.wal.WALProvider.Writer writer,
 boolean withTrailer,
 org.apache.hadoop.hbase.TableName tableName,
 int columnCount,
 int recordCount,
 byte[] row,
 long timestamp)
                    throws IOException

Throws:

IOException

doWrite

public static void doWrite(org.apache.hadoop.hbase.wal.WAL wal,
 org.apache.hadoop.hbase.client.RegionInfo hri,
 org.apache.hadoop.hbase.TableName tableName,
 int columnCount,
 int recordCount,
 byte[] row,
 long timestamp,
 org.apache.hadoop.hbase.regionserver.MultiVersionConcurrencyControl mvcc)
                    throws IOException

Throws:

IOException

doRead

public static void doRead(org.apache.hadoop.hbase.regionserver.wal.ProtobufWALStreamReader reader,
 boolean withTrailer,
 org.apache.hadoop.hbase.client.RegionInfo hri,
 org.apache.hadoop.hbase.TableName tableName,
 int columnCount,
 int recordCount,
 byte[] row,
 long timestamp)
                   throws IOException

Throws:

IOException

doRead

public static void doRead(org.apache.hadoop.hbase.regionserver.wal.ProtobufWALStreamReader reader,
 boolean withTrailer,
 org.apache.hadoop.hbase.TableName tableName,
 int columnCount,
 int recordCount,
 byte[] row,
 long timestamp)
                   throws IOException

Throws:

IOException