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); }
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); }
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); }
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); }
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); }
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); }
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); }
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); }
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); }
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); }
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); }
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); }
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); }