Package org.apache.hadoop.hbase
Class TimestampTestBase
java.lang.Object
org.apache.hadoop.hbase.TimestampTestBase
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 -
Field Summary
FieldsModifier and TypeFieldDescriptionstatic final byte[]private static final byte[]private static final byte[]private static final longprivate static final longprivate static final long -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprivate static voidassertOnlyLatest(org.apache.hadoop.hbase.client.Table incommon, long currentTime) static intassertScanContentTimestamp(org.apache.hadoop.hbase.client.Table in, long ts) static voidassertVersions(org.apache.hadoop.hbase.client.Table incommon, long[] tss) static voiddelete(org.apache.hadoop.hbase.client.Table loader) static voiddelete(org.apache.hadoop.hbase.client.Table loader, byte[] column) static voiddelete(org.apache.hadoop.hbase.client.Table loader, byte[] column, long ts) static voiddelete(org.apache.hadoop.hbase.client.Table loader, long ts) static voiddoTestDelete(org.apache.hadoop.hbase.client.Table table, TimestampTestBase.FlushCache flusher) static voiddoTestTimestampScanning(org.apache.hadoop.hbase.client.Table incommon, TimestampTestBase.FlushCache flusher) static org.apache.hadoop.hbase.client.Resultget(org.apache.hadoop.hbase.client.Table loader) static voidput(org.apache.hadoop.hbase.client.Table loader) static voidput(org.apache.hadoop.hbase.client.Table loader, byte[] bytes, long ts) static voidput(org.apache.hadoop.hbase.client.Table loader, long ts)
-
Field Details
-
T0
- See Also:
-
T1
- See Also:
-
T2
- See Also:
-
FAMILY_NAME
-
QUALIFIER_NAME
-
ROW
-
-
Constructor Details
-
TimestampTestBase
public TimestampTestBase()
-
-
Method Details
-
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
- Throws:
IOException
-
put
- Throws:
IOException
-
put
public static void put(org.apache.hadoop.hbase.client.Table loader, byte[] bytes, long ts) throws IOException - Throws:
IOException
-
delete
- Throws:
IOException
-
delete
public static void delete(org.apache.hadoop.hbase.client.Table loader, byte[] column) throws IOException - Throws:
IOException
-
delete
- 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
-