org.apache.hadoop.hbase

Class TimestampTestBase

java.lang.Object

org.apache.hadoop.hbase.TimestampTestBase

public class TimestampTestBase
extends Object

Tests user specifiable time stamps putting, getting and scanning. Also tests same in presence of deletes. Test cores are written so can be run against an HRegion and against an HTable: i.e. both local and remote.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
(package private) static interface	TimestampTestBase.FlushCache

Field Summary

Fields

Modifier and Type	Field and Description
static byte[]	FAMILY_NAME
private static byte[]	QUALIFIER_NAME
private static byte[]	ROW
private static long	T0
private static long	T1
private static long	T2

Constructor Summary

Constructors

Constructor and Description
TimestampTestBase()

Method Summary

Modifier and Type	Method and Description
private static void	assertOnlyLatest(org.apache.hadoop.hbase.client.Table incommon, long currentTime)
static int	assertScanContentTimestamp(org.apache.hadoop.hbase.client.Table in, long ts)
static void	assertVersions(org.apache.hadoop.hbase.client.Table incommon, long[] tss)
static void	delete(org.apache.hadoop.hbase.client.Table loader)
static void	delete(org.apache.hadoop.hbase.client.Table loader, byte[] column)
static void	delete(org.apache.hadoop.hbase.client.Table loader, byte[] column, long ts)
static void	delete(org.apache.hadoop.hbase.client.Table loader, long ts)
static void	doTestDelete(org.apache.hadoop.hbase.client.Table table, TimestampTestBase.FlushCache flusher)
static void	doTestTimestampScanning(org.apache.hadoop.hbase.client.Table incommon, TimestampTestBase.FlushCache flusher)
static org.apache.hadoop.hbase.client.Result	get(org.apache.hadoop.hbase.client.Table loader)
static void	put(org.apache.hadoop.hbase.client.Table loader)
static void	put(org.apache.hadoop.hbase.client.Table loader, byte[] bytes, long ts)
static void	put(org.apache.hadoop.hbase.client.Table loader, long ts)

Methods inherited from class java.lang.Object

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

Field Detail

T0

private static final long T0

See Also:

Constant Field Values

T1

private static final long T1

See Also:

Constant Field Values

T2

private static final long T2

See Also:

Constant Field Values

FAMILY_NAME

public static final byte[] FAMILY_NAME

QUALIFIER_NAME

private static final byte[] QUALIFIER_NAME

ROW

private static final byte[] ROW

Constructor Detail

TimestampTestBase

public TimestampTestBase()

Method Detail

doTestDelete

public static void doTestDelete(org.apache.hadoop.hbase.client.Table table,
                                TimestampTestBase.FlushCache flusher)
                         throws IOException

Throws:

IOException

assertOnlyLatest

private static void assertOnlyLatest(org.apache.hadoop.hbase.client.Table incommon,
                                     long currentTime)
                              throws IOException

Throws:

IOException

assertVersions

public static void assertVersions(org.apache.hadoop.hbase.client.Table incommon,
                                  long[] tss)
                           throws IOException

Throws:

IOException

doTestTimestampScanning

public static void doTestTimestampScanning(org.apache.hadoop.hbase.client.Table incommon,
                                           TimestampTestBase.FlushCache flusher)
                                    throws IOException

Throws:

IOException

assertScanContentTimestamp

public static int assertScanContentTimestamp(org.apache.hadoop.hbase.client.Table in,
                                             long ts)
                                      throws IOException

Throws:

IOException

put

public static void put(org.apache.hadoop.hbase.client.Table loader,
                       long ts)
                throws IOException

Throws:

IOException

put

public static void put(org.apache.hadoop.hbase.client.Table loader)
                throws IOException

Throws:

IOException

put

public static void put(org.apache.hadoop.hbase.client.Table loader,
                       byte[] bytes,
                       long ts)
                throws IOException

Throws:

IOException

delete

public static void delete(org.apache.hadoop.hbase.client.Table loader)
                   throws IOException

Throws:

IOException

delete

public static void delete(org.apache.hadoop.hbase.client.Table loader,
                          byte[] column)
                   throws IOException

Throws:

IOException

delete

public static void delete(org.apache.hadoop.hbase.client.Table loader,
                          long ts)
                   throws IOException

Throws:

IOException

delete

public static void delete(org.apache.hadoop.hbase.client.Table loader,
                          byte[] column,
                          long ts)
                   throws IOException

Throws:

IOException

get

public static org.apache.hadoop.hbase.client.Result get(org.apache.hadoop.hbase.client.Table loader)
                                                 throws IOException

Throws:

IOException