Java 类org.apache.hadoop.hbase.regionserver.DeleteTracker.DeleteResult 实例源码

项目:pbase    文件:TestScanDeleteTracker.java   
public void testDelete_DeleteColumn() {
  byte [] qualifier = Bytes.toBytes("qualifier");
  deleteType = KeyValue.Type.Delete.getCode();
  KeyValue kv = new KeyValue(Bytes.toBytes("row"), Bytes.toBytes("f"),
      qualifier, timestamp, KeyValue.Type.Delete);
  sdt.add(kv);

  timestamp -= 5;
  kv = new KeyValue(Bytes.toBytes("row"), Bytes.toBytes("f"),
      qualifier, timestamp, KeyValue.Type.DeleteColumn);
  deleteType = KeyValue.Type.DeleteColumn.getCode();
  sdt.add(kv);

  timestamp -= 5;
  kv = new KeyValue(Bytes.toBytes("row"), Bytes.toBytes("f"),
      qualifier, timestamp, KeyValue.Type.DeleteColumn);
  DeleteResult ret = sdt.isDeleted(kv);
  assertEquals(DeleteResult.COLUMN_DELETED, ret);
}
项目:pbase    文件:TestScanDeleteTracker.java   
public void testDeleteColumn_Delete() {
  byte [] qualifier = Bytes.toBytes("qualifier");
  deleteType = KeyValue.Type.DeleteColumn.getCode();
  KeyValue kv = new KeyValue(Bytes.toBytes("row"), Bytes.toBytes("f"),
      qualifier, timestamp, KeyValue.Type.DeleteColumn);
  sdt.add(kv);

  qualifier = Bytes.toBytes("qualifier1");
  deleteType = KeyValue.Type.Delete.getCode();
  kv = new KeyValue(Bytes.toBytes("row"), Bytes.toBytes("f"),
      qualifier, timestamp, KeyValue.Type.Delete);
  sdt.add(kv);

  DeleteResult ret = sdt.isDeleted(kv);
  assertEquals( DeleteResult.VERSION_DELETED, ret);
}
项目:pbase    文件:TestScanDeleteTracker.java   
public void testDelete_KeepVersionZero(){
  byte [] qualifier = Bytes.toBytes("qualifier");
  deleteType = KeyValue.Type.Delete.getCode();

  long deleteTimestamp = 10;
  long valueTimestamp = 0;

  sdt.reset();
  KeyValue kv = new KeyValue(Bytes.toBytes("row"), Bytes.toBytes("f"),
      qualifier, deleteTimestamp, KeyValue.Type.Delete);
  sdt.add(kv);
  kv = new KeyValue(Bytes.toBytes("row"), Bytes.toBytes("f"),
      qualifier, valueTimestamp, KeyValue.Type.Delete);
  DeleteResult ret = sdt.isDeleted(kv);
  assertEquals(DeleteResult.NOT_DELETED, ret);
}
项目:HIndex    文件:TestScanDeleteTracker.java   
public void testDelete_DeleteColumn() {
  byte [] qualifier = Bytes.toBytes("qualifier");
  deleteType = KeyValue.Type.Delete.getCode();
  KeyValue kv = new KeyValue(Bytes.toBytes("row"), Bytes.toBytes("f"),
      qualifier, timestamp, KeyValue.Type.Delete);
  sdt.add(kv);

  timestamp -= 5;
  kv = new KeyValue(Bytes.toBytes("row"), Bytes.toBytes("f"),
      qualifier, timestamp, KeyValue.Type.DeleteColumn);
  deleteType = KeyValue.Type.DeleteColumn.getCode();
  sdt.add(kv);

  timestamp -= 5;
  kv = new KeyValue(Bytes.toBytes("row"), Bytes.toBytes("f"),
      qualifier, timestamp, KeyValue.Type.DeleteColumn);
  DeleteResult ret = sdt.isDeleted(kv);
  assertEquals(DeleteResult.COLUMN_DELETED, ret);
}
项目:HIndex    文件:TestScanDeleteTracker.java   
public void testDeleteColumn_Delete() {
  byte [] qualifier = Bytes.toBytes("qualifier");
  deleteType = KeyValue.Type.DeleteColumn.getCode();
  KeyValue kv = new KeyValue(Bytes.toBytes("row"), Bytes.toBytes("f"),
      qualifier, timestamp, KeyValue.Type.DeleteColumn);
  sdt.add(kv);

  qualifier = Bytes.toBytes("qualifier1");
  deleteType = KeyValue.Type.Delete.getCode();
  kv = new KeyValue(Bytes.toBytes("row"), Bytes.toBytes("f"),
      qualifier, timestamp, KeyValue.Type.Delete);
  sdt.add(kv);

  DeleteResult ret = sdt.isDeleted(kv);
  assertEquals( DeleteResult.VERSION_DELETED, ret);
}
项目:HIndex    文件:TestScanDeleteTracker.java   
public void testDelete_KeepVersionZero(){
  byte [] qualifier = Bytes.toBytes("qualifier");
  deleteType = KeyValue.Type.Delete.getCode();

  long deleteTimestamp = 10;
  long valueTimestamp = 0;

  sdt.reset();
  KeyValue kv = new KeyValue(Bytes.toBytes("row"), Bytes.toBytes("f"),
      qualifier, deleteTimestamp, KeyValue.Type.Delete);
  sdt.add(kv);
  kv = new KeyValue(Bytes.toBytes("row"), Bytes.toBytes("f"),
      qualifier, valueTimestamp, KeyValue.Type.Delete);
  DeleteResult ret = sdt.isDeleted(kv);
  assertEquals(DeleteResult.NOT_DELETED, ret);
}
项目:PyroDB    文件:TestScanDeleteTracker.java   
public void testDelete_DeleteColumn() {
  byte [] qualifier = Bytes.toBytes("qualifier");
  deleteType = KeyValue.Type.Delete.getCode();
  KeyValue kv = new KeyValue(Bytes.toBytes("row"), Bytes.toBytes("f"),
      qualifier, timestamp, KeyValue.Type.Delete);
  sdt.add(kv);

  timestamp -= 5;
  kv = new KeyValue(Bytes.toBytes("row"), Bytes.toBytes("f"),
      qualifier, timestamp, KeyValue.Type.DeleteColumn);
  deleteType = KeyValue.Type.DeleteColumn.getCode();
  sdt.add(kv);

  timestamp -= 5;
  kv = new KeyValue(Bytes.toBytes("row"), Bytes.toBytes("f"),
      qualifier, timestamp, KeyValue.Type.DeleteColumn);
  DeleteResult ret = sdt.isDeleted(kv);
  assertEquals(DeleteResult.COLUMN_DELETED, ret);
}
项目:PyroDB    文件:TestScanDeleteTracker.java   
public void testDeleteColumn_Delete() {
  byte [] qualifier = Bytes.toBytes("qualifier");
  deleteType = KeyValue.Type.DeleteColumn.getCode();
  KeyValue kv = new KeyValue(Bytes.toBytes("row"), Bytes.toBytes("f"),
      qualifier, timestamp, KeyValue.Type.DeleteColumn);
  sdt.add(kv);

  qualifier = Bytes.toBytes("qualifier1");
  deleteType = KeyValue.Type.Delete.getCode();
  kv = new KeyValue(Bytes.toBytes("row"), Bytes.toBytes("f"),
      qualifier, timestamp, KeyValue.Type.Delete);
  sdt.add(kv);

  DeleteResult ret = sdt.isDeleted(kv);
  assertEquals( DeleteResult.VERSION_DELETED, ret);
}
项目:PyroDB    文件:TestScanDeleteTracker.java   
public void testDelete_KeepVersionZero(){
  byte [] qualifier = Bytes.toBytes("qualifier");
  deleteType = KeyValue.Type.Delete.getCode();

  long deleteTimestamp = 10;
  long valueTimestamp = 0;

  sdt.reset();
  KeyValue kv = new KeyValue(Bytes.toBytes("row"), Bytes.toBytes("f"),
      qualifier, deleteTimestamp, KeyValue.Type.Delete);
  sdt.add(kv);
  kv = new KeyValue(Bytes.toBytes("row"), Bytes.toBytes("f"),
      qualifier, valueTimestamp, KeyValue.Type.Delete);
  DeleteResult ret = sdt.isDeleted(kv);
  assertEquals(DeleteResult.NOT_DELETED, ret);
}
项目:ditb    文件:TestScanDeleteTracker.java   
public void testDeletedBy_Delete() {
  KeyValue kv = new KeyValue(Bytes.toBytes("row"), Bytes.toBytes("f"),
      Bytes.toBytes("qualifier"), timestamp, KeyValue.Type.Delete);
  sdt.add(kv);
  DeleteResult ret = sdt.isDeleted(kv);
  assertEquals(DeleteResult.VERSION_DELETED, ret);
}
项目:LCIndex-HBase-0.94.16    文件:TestScanDeleteTracker.java   
public void testDeletedBy_Delete() {
  byte [] qualifier = Bytes.toBytes("qualifier");
  deleteType = KeyValue.Type.Delete.getCode();

  sdt.add(qualifier, 0, qualifier.length, timestamp, deleteType);
  DeleteResult ret = sdt.isDeleted(qualifier, 0, qualifier.length, timestamp);
  assertEquals(DeleteResult.VERSION_DELETED, ret);
}
项目:LCIndex-HBase-0.94.16    文件:TestScanDeleteTracker.java   
public void testDeletedBy_DeleteColumn() {
  byte [] qualifier = Bytes.toBytes("qualifier");
  deleteType = KeyValue.Type.DeleteColumn.getCode();

  sdt.add(qualifier, 0, qualifier.length, timestamp, deleteType);
  timestamp -= 5;
  DeleteResult ret = sdt.isDeleted(qualifier, 0, qualifier.length, timestamp);
  assertEquals(DeleteResult.COLUMN_DELETED, ret);
}
项目:LCIndex-HBase-0.94.16    文件:TestScanDeleteTracker.java   
public void testDeletedBy_DeleteFamily() {
  byte [] qualifier = Bytes.toBytes("qualifier");
  deleteType = KeyValue.Type.DeleteFamily.getCode();

  sdt.add(qualifier, 0, qualifier.length, timestamp, deleteType);

  timestamp -= 5;
  DeleteResult ret = sdt.isDeleted(qualifier, 0, qualifier.length, timestamp);
  assertEquals(DeleteResult.FAMILY_DELETED, ret);
}
项目:LCIndex-HBase-0.94.16    文件:TestScanDeleteTracker.java   
public void testDelete_DeleteColumn() {
  byte [] qualifier = Bytes.toBytes("qualifier");
  deleteType = KeyValue.Type.Delete.getCode();

  sdt.add(qualifier, 0, qualifier.length, timestamp, deleteType);

  timestamp -= 5;
  deleteType = KeyValue.Type.DeleteColumn.getCode();
  sdt.add(qualifier, 0, qualifier.length, timestamp, deleteType);

  timestamp -= 5;
  DeleteResult ret = sdt.isDeleted(qualifier, 0, qualifier.length, timestamp);
  assertEquals(DeleteResult.COLUMN_DELETED, ret);
}
项目:LCIndex-HBase-0.94.16    文件:TestScanDeleteTracker.java   
public void testDeleteColumn_Delete() {
  byte [] qualifier = Bytes.toBytes("qualifier");
  deleteType = KeyValue.Type.DeleteColumn.getCode();

  sdt.add(qualifier, 0, qualifier.length, timestamp, deleteType);

  qualifier = Bytes.toBytes("qualifier1");
  deleteType = KeyValue.Type.Delete.getCode();
  sdt.add(qualifier, 0, qualifier.length, timestamp, deleteType);

  DeleteResult ret = sdt.isDeleted(qualifier, 0, qualifier.length, timestamp);
  assertEquals( DeleteResult.VERSION_DELETED, ret);
}
项目:LCIndex-HBase-0.94.16    文件:TestScanDeleteTracker.java   
public void testDelete_KeepVersionZero(){
  byte [] qualifier = Bytes.toBytes("qualifier");
  deleteType = KeyValue.Type.Delete.getCode();

  long deleteTimestamp = 10;
  long valueTimestamp = 0;

  sdt.reset();
  sdt.add(qualifier, 0, qualifier.length, deleteTimestamp, deleteType);
  DeleteResult ret = sdt.isDeleted(qualifier, 0, qualifier.length, valueTimestamp);
  assertEquals(DeleteResult.NOT_DELETED, ret);
}
项目:pbase    文件:TestScanDeleteTracker.java   
public void testDeletedBy_Delete() {
  KeyValue kv = new KeyValue(Bytes.toBytes("row"), Bytes.toBytes("f"),
      Bytes.toBytes("qualifier"), timestamp, KeyValue.Type.Delete);
  sdt.add(kv);
  DeleteResult ret = sdt.isDeleted(kv);
  assertEquals(DeleteResult.VERSION_DELETED, ret);
}
项目:pbase    文件:TestScanDeleteTracker.java   
public void testDeletedBy_DeleteColumn() {
  KeyValue kv = new KeyValue(Bytes.toBytes("row"), Bytes.toBytes("f"),
      Bytes.toBytes("qualifier"), timestamp, KeyValue.Type.DeleteColumn);
  sdt.add(kv);
  timestamp -= 5;
  kv = new KeyValue(Bytes.toBytes("row"), Bytes.toBytes("f"),
      Bytes.toBytes("qualifier"), timestamp , KeyValue.Type.DeleteColumn);
  DeleteResult ret = sdt.isDeleted(kv);
  assertEquals(DeleteResult.COLUMN_DELETED, ret);
}
项目:pbase    文件:TestScanDeleteTracker.java   
public void testDeletedBy_DeleteFamily() {
  KeyValue kv = new KeyValue(Bytes.toBytes("row"), Bytes.toBytes("f"),
      Bytes.toBytes("qualifier"), timestamp, KeyValue.Type.DeleteFamily);
  sdt.add(kv);
  timestamp -= 5;
  kv = new KeyValue(Bytes.toBytes("row"), Bytes.toBytes("f"),
      Bytes.toBytes("qualifier"), timestamp , KeyValue.Type.DeleteColumn);
  DeleteResult ret = sdt.isDeleted(kv);
  assertEquals(DeleteResult.FAMILY_DELETED, ret);
}
项目:HIndex    文件:TestScanDeleteTracker.java   
public void testDeletedBy_Delete() {
  KeyValue kv = new KeyValue(Bytes.toBytes("row"), Bytes.toBytes("f"),
      Bytes.toBytes("qualifier"), timestamp, KeyValue.Type.Delete);
  sdt.add(kv);
  DeleteResult ret = sdt.isDeleted(kv);
  assertEquals(DeleteResult.VERSION_DELETED, ret);
}
项目:HIndex    文件:TestScanDeleteTracker.java   
public void testDeletedBy_DeleteColumn() {
  KeyValue kv = new KeyValue(Bytes.toBytes("row"), Bytes.toBytes("f"),
      Bytes.toBytes("qualifier"), timestamp, KeyValue.Type.DeleteColumn);
  sdt.add(kv);
  timestamp -= 5;
  kv = new KeyValue(Bytes.toBytes("row"), Bytes.toBytes("f"),
      Bytes.toBytes("qualifier"), timestamp , KeyValue.Type.DeleteColumn);
  DeleteResult ret = sdt.isDeleted(kv);
  assertEquals(DeleteResult.COLUMN_DELETED, ret);
}
项目:HIndex    文件:TestScanDeleteTracker.java   
public void testDeletedBy_DeleteFamily() {
  KeyValue kv = new KeyValue(Bytes.toBytes("row"), Bytes.toBytes("f"),
      Bytes.toBytes("qualifier"), timestamp, KeyValue.Type.DeleteFamily);
  sdt.add(kv);
  timestamp -= 5;
  kv = new KeyValue(Bytes.toBytes("row"), Bytes.toBytes("f"),
      Bytes.toBytes("qualifier"), timestamp , KeyValue.Type.DeleteColumn);
  DeleteResult ret = sdt.isDeleted(kv);
  assertEquals(DeleteResult.FAMILY_DELETED, ret);
}
项目:IRIndex    文件:TestScanDeleteTracker.java   
public void testDeletedBy_Delete() {
  byte [] qualifier = Bytes.toBytes("qualifier");
  deleteType = KeyValue.Type.Delete.getCode();

  sdt.add(qualifier, 0, qualifier.length, timestamp, deleteType);
  DeleteResult ret = sdt.isDeleted(qualifier, 0, qualifier.length, timestamp);
  assertEquals(DeleteResult.VERSION_DELETED, ret);
}
项目:IRIndex    文件:TestScanDeleteTracker.java   
public void testDeletedBy_DeleteColumn() {
  byte [] qualifier = Bytes.toBytes("qualifier");
  deleteType = KeyValue.Type.DeleteColumn.getCode();

  sdt.add(qualifier, 0, qualifier.length, timestamp, deleteType);
  timestamp -= 5;
  DeleteResult ret = sdt.isDeleted(qualifier, 0, qualifier.length, timestamp);
  assertEquals(DeleteResult.COLUMN_DELETED, ret);
}
项目:IRIndex    文件:TestScanDeleteTracker.java   
public void testDeletedBy_DeleteFamily() {
  byte [] qualifier = Bytes.toBytes("qualifier");
  deleteType = KeyValue.Type.DeleteFamily.getCode();

  sdt.add(qualifier, 0, qualifier.length, timestamp, deleteType);

  timestamp -= 5;
  DeleteResult ret = sdt.isDeleted(qualifier, 0, qualifier.length, timestamp);
  assertEquals(DeleteResult.FAMILY_DELETED, ret);
}
项目:IRIndex    文件:TestScanDeleteTracker.java   
public void testDelete_DeleteColumn() {
  byte [] qualifier = Bytes.toBytes("qualifier");
  deleteType = KeyValue.Type.Delete.getCode();

  sdt.add(qualifier, 0, qualifier.length, timestamp, deleteType);

  timestamp -= 5;
  deleteType = KeyValue.Type.DeleteColumn.getCode();
  sdt.add(qualifier, 0, qualifier.length, timestamp, deleteType);

  timestamp -= 5;
  DeleteResult ret = sdt.isDeleted(qualifier, 0, qualifier.length, timestamp);
  assertEquals(DeleteResult.COLUMN_DELETED, ret);
}
项目:IRIndex    文件:TestScanDeleteTracker.java   
public void testDeleteColumn_Delete() {
  byte [] qualifier = Bytes.toBytes("qualifier");
  deleteType = KeyValue.Type.DeleteColumn.getCode();

  sdt.add(qualifier, 0, qualifier.length, timestamp, deleteType);

  qualifier = Bytes.toBytes("qualifier1");
  deleteType = KeyValue.Type.Delete.getCode();
  sdt.add(qualifier, 0, qualifier.length, timestamp, deleteType);

  DeleteResult ret = sdt.isDeleted(qualifier, 0, qualifier.length, timestamp);
  assertEquals( DeleteResult.VERSION_DELETED, ret);
}
项目:IRIndex    文件:TestScanDeleteTracker.java   
public void testDelete_KeepVersionZero(){
  byte [] qualifier = Bytes.toBytes("qualifier");
  deleteType = KeyValue.Type.Delete.getCode();

  long deleteTimestamp = 10;
  long valueTimestamp = 0;

  sdt.reset();
  sdt.add(qualifier, 0, qualifier.length, deleteTimestamp, deleteType);
  DeleteResult ret = sdt.isDeleted(qualifier, 0, qualifier.length, valueTimestamp);
  assertEquals(DeleteResult.NOT_DELETED, ret);
}
项目:PyroDB    文件:TestScanDeleteTracker.java   
public void testDeletedBy_Delete() {
  KeyValue kv = new KeyValue(Bytes.toBytes("row"), Bytes.toBytes("f"),
      Bytes.toBytes("qualifier"), timestamp, KeyValue.Type.Delete);
  sdt.add(kv);
  DeleteResult ret = sdt.isDeleted(kv);
  assertEquals(DeleteResult.VERSION_DELETED, ret);
}
项目:PyroDB    文件:TestScanDeleteTracker.java   
public void testDeletedBy_DeleteColumn() {
  KeyValue kv = new KeyValue(Bytes.toBytes("row"), Bytes.toBytes("f"),
      Bytes.toBytes("qualifier"), timestamp, KeyValue.Type.DeleteColumn);
  sdt.add(kv);
  timestamp -= 5;
  kv = new KeyValue(Bytes.toBytes("row"), Bytes.toBytes("f"),
      Bytes.toBytes("qualifier"), timestamp , KeyValue.Type.DeleteColumn);
  DeleteResult ret = sdt.isDeleted(kv);
  assertEquals(DeleteResult.COLUMN_DELETED, ret);
}
项目:PyroDB    文件:TestScanDeleteTracker.java   
public void testDeletedBy_DeleteFamily() {
  KeyValue kv = new KeyValue(Bytes.toBytes("row"), Bytes.toBytes("f"),
      Bytes.toBytes("qualifier"), timestamp, KeyValue.Type.DeleteFamily);
  sdt.add(kv);
  timestamp -= 5;
  kv = new KeyValue(Bytes.toBytes("row"), Bytes.toBytes("f"),
      Bytes.toBytes("qualifier"), timestamp , KeyValue.Type.DeleteColumn);
  DeleteResult ret = sdt.isDeleted(kv);
  assertEquals(DeleteResult.FAMILY_DELETED, ret);
}
项目:c5    文件:TestScanDeleteTracker.java   
public void testDeletedBy_Delete() {
  byte [] qualifier = Bytes.toBytes("qualifier");
  deleteType = KeyValue.Type.Delete.getCode();

  sdt.add(qualifier, 0, qualifier.length, timestamp, deleteType);
  DeleteResult ret = sdt.isDeleted(qualifier, 0, qualifier.length, timestamp);
  assertEquals(DeleteResult.VERSION_DELETED, ret);
}
项目:c5    文件:TestScanDeleteTracker.java   
public void testDeletedBy_DeleteColumn() {
  byte [] qualifier = Bytes.toBytes("qualifier");
  deleteType = KeyValue.Type.DeleteColumn.getCode();

  sdt.add(qualifier, 0, qualifier.length, timestamp, deleteType);
  timestamp -= 5;
  DeleteResult ret = sdt.isDeleted(qualifier, 0, qualifier.length, timestamp);
  assertEquals(DeleteResult.COLUMN_DELETED, ret);
}
项目:c5    文件:TestScanDeleteTracker.java   
public void testDeletedBy_DeleteFamily() {
  byte [] qualifier = Bytes.toBytes("qualifier");
  deleteType = KeyValue.Type.DeleteFamily.getCode();

  sdt.add(qualifier, 0, qualifier.length, timestamp, deleteType);

  timestamp -= 5;
  DeleteResult ret = sdt.isDeleted(qualifier, 0, qualifier.length, timestamp);
  assertEquals(DeleteResult.FAMILY_DELETED, ret);
}
项目:c5    文件:TestScanDeleteTracker.java   
public void testDeletedBy_DeleteFamilyVersion() {
  byte [] qualifier1 = Bytes.toBytes("qualifier1");
  byte [] qualifier2 = Bytes.toBytes("qualifier2");
  byte [] qualifier3 = Bytes.toBytes("qualifier3");
  byte [] qualifier4 = Bytes.toBytes("qualifier4");
  deleteType = KeyValue.Type.DeleteFamilyVersion.getCode();

  sdt.add(null, 0, 0, timestamp, deleteType);

  DeleteResult ret = sdt.isDeleted(qualifier1, 0, qualifier1.length, timestamp);
  assertEquals(DeleteResult.FAMILY_VERSION_DELETED, ret);
  ret = sdt.isDeleted(qualifier2, 0, qualifier2.length, timestamp);
  assertEquals(DeleteResult.FAMILY_VERSION_DELETED, ret);
  ret = sdt.isDeleted(qualifier3, 0, qualifier3.length, timestamp);
  assertEquals(DeleteResult.FAMILY_VERSION_DELETED, ret);
  ret = sdt.isDeleted(qualifier4, 0, qualifier4.length, timestamp);
  assertEquals(DeleteResult.FAMILY_VERSION_DELETED, ret);

  ret = sdt.isDeleted(qualifier1, 0, qualifier1.length, timestamp + 3);
  assertEquals(DeleteResult.NOT_DELETED, ret);
  ret = sdt.isDeleted(qualifier2, 0, qualifier2.length, timestamp - 2);
  assertEquals(DeleteResult.NOT_DELETED, ret);
  ret = sdt.isDeleted(qualifier3, 0, qualifier3.length, timestamp - 5);
  assertEquals(DeleteResult.NOT_DELETED, ret);
  ret = sdt.isDeleted(qualifier4, 0, qualifier4.length, timestamp + 8);
  assertEquals(DeleteResult.NOT_DELETED, ret);
}
项目:c5    文件:TestScanDeleteTracker.java   
public void testDelete_DeleteColumn() {
  byte [] qualifier = Bytes.toBytes("qualifier");
  deleteType = KeyValue.Type.Delete.getCode();

  sdt.add(qualifier, 0, qualifier.length, timestamp, deleteType);

  timestamp -= 5;
  deleteType = KeyValue.Type.DeleteColumn.getCode();
  sdt.add(qualifier, 0, qualifier.length, timestamp, deleteType);

  timestamp -= 5;
  DeleteResult ret = sdt.isDeleted(qualifier, 0, qualifier.length, timestamp);
  assertEquals(DeleteResult.COLUMN_DELETED, ret);
}
项目:c5    文件:TestScanDeleteTracker.java   
public void testDeleteColumn_Delete() {
  byte [] qualifier = Bytes.toBytes("qualifier");
  deleteType = KeyValue.Type.DeleteColumn.getCode();

  sdt.add(qualifier, 0, qualifier.length, timestamp, deleteType);

  qualifier = Bytes.toBytes("qualifier1");
  deleteType = KeyValue.Type.Delete.getCode();
  sdt.add(qualifier, 0, qualifier.length, timestamp, deleteType);

  DeleteResult ret = sdt.isDeleted(qualifier, 0, qualifier.length, timestamp);
  assertEquals( DeleteResult.VERSION_DELETED, ret);
}
项目:c5    文件:TestScanDeleteTracker.java   
public void testDelete_KeepVersionZero(){
  byte [] qualifier = Bytes.toBytes("qualifier");
  deleteType = KeyValue.Type.Delete.getCode();

  long deleteTimestamp = 10;
  long valueTimestamp = 0;

  sdt.reset();
  sdt.add(qualifier, 0, qualifier.length, deleteTimestamp, deleteType);
  DeleteResult ret = sdt.isDeleted(qualifier, 0, qualifier.length, valueTimestamp);
  assertEquals(DeleteResult.NOT_DELETED, ret);
}
项目:HBase-Research    文件:TestScanDeleteTracker.java   
public void testDeletedBy_Delete() {
  byte [] qualifier = Bytes.toBytes("qualifier");
  deleteType = KeyValue.Type.Delete.getCode();

  sdt.add(qualifier, 0, qualifier.length, timestamp, deleteType);
  DeleteResult ret = sdt.isDeleted(qualifier, 0, qualifier.length, timestamp);
  assertEquals(DeleteResult.VERSION_DELETED, ret);
}
项目:HBase-Research    文件:TestScanDeleteTracker.java   
public void testDeletedBy_DeleteColumn() {
  byte [] qualifier = Bytes.toBytes("qualifier");
  deleteType = KeyValue.Type.DeleteColumn.getCode();

  sdt.add(qualifier, 0, qualifier.length, timestamp, deleteType);
  timestamp -= 5;
  DeleteResult ret = sdt.isDeleted(qualifier, 0, qualifier.length, timestamp);
  assertEquals(DeleteResult.COLUMN_DELETED, ret);
}