public final class ProtobufLogTestHelper extends Object
Modifier | Constructor and Description |
---|---|
private |
ProtobufLogTestHelper() |
Modifier and Type | Method and 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) |
private ProtobufLogTestHelper()
private static byte[] toValue(int prefix, int suffix)
private static org.apache.hadoop.hbase.client.RegionInfo toRegionInfo(org.apache.hadoop.hbase.TableName tableName)
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)
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
IOException
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
IOException
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
IOException
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
IOException
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.