org.apache.hadoop.hbase.KeyValue.setTimestamp()方法的使用及代码示例

x33g5p2x  于2022-01-23 转载在 其他  
字(14.7k)|赞(0)|评价(0)|浏览(93)

本文整理了Java中org.apache.hadoop.hbase.KeyValue.setTimestamp()方法的一些代码示例，展示了KeyValue.setTimestamp()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。KeyValue.setTimestamp()方法的具体详情如下：
包路径：org.apache.hadoop.hbase.KeyValue
类名称：KeyValue
方法名：setTimestamp

KeyValue.setTimestamp介绍

暂无

代码示例

代码示例来源：origin: apache/hbase

@Test
public void testVersionsDelete() {
 NewVersionBehaviorTracker tracker =
   new NewVersionBehaviorTracker(null, comparator, 1, 3, 3, 10000);
 KeyValue put = new KeyValue(row, family, col1, 20000, KeyValue.Type.Put, value);
 KeyValue delete = new KeyValue(row, family, col1, 20000, KeyValue.Type.DeleteColumn, value);
 delete.setSequenceId(1000);
 delete.setTimestamp(20000);
 tracker.add(delete);
 put.setSequenceId(1001);
 put.setTimestamp(19999);
 assertEquals(DeleteResult.NOT_DELETED, tracker.isDeleted(put));
 put.setSequenceId(999);
 put.setTimestamp(19998);
 assertEquals(DeleteResult.COLUMN_DELETED, tracker.isDeleted(put));
 delete = new KeyValue(row, family, col2, 20000, KeyValue.Type.DeleteColumn, value);
 delete.setSequenceId(1002);
 delete.setTimestamp(20000);
 tracker.add(delete);
 put = new KeyValue(row, family, col2, 20000, KeyValue.Type.Put, value);
 put.setSequenceId(1001);
 put.setTimestamp(19999);
 assertEquals(DeleteResult.COLUMN_DELETED, tracker.isDeleted(put));
 put.setSequenceId(999);
 put.setTimestamp(19998);
 assertEquals(DeleteResult.COLUMN_DELETED, tracker.isDeleted(put));
}

代码示例来源：origin: apache/hbase

@Test
public void testFamilyVersionsDelete() {
 NewVersionBehaviorTracker tracker =
   new NewVersionBehaviorTracker(null, comparator, 1, 3, 3, 10000);
 KeyValue delete = new KeyValue(row, family, null, 20000, KeyValue.Type.DeleteFamily, value);
 delete.setSequenceId(1000);
 delete.setTimestamp(20000);
 KeyValue put = new KeyValue(row, family, col1, 20000, KeyValue.Type.Put, value);
 tracker.add(delete);
 put.setSequenceId(1001);
 put.setTimestamp(20000);
 assertEquals(DeleteResult.NOT_DELETED, tracker.isDeleted(put));
 put.setSequenceId(999);
 put.setTimestamp(19998);
 assertEquals(DeleteResult.COLUMN_DELETED, tracker.isDeleted(put));
 put = new KeyValue(row, family, col2, 20000, KeyValue.Type.Put, value);
 put.setSequenceId(998);
 put.setTimestamp(19999);
 assertEquals(DeleteResult.COLUMN_DELETED, tracker.isDeleted(put));
 put.setSequenceId(999);
 put.setTimestamp(19998);
 assertEquals(DeleteResult.COLUMN_DELETED, tracker.isDeleted(put));
}

代码示例来源：origin: apache/hbase

@Test
public void testFamilyVersionDelete() {
 NewVersionBehaviorTracker tracker =
   new NewVersionBehaviorTracker(null, comparator, 1, 3, 3, 10000);
 KeyValue delete = new KeyValue(row, family, null, 20000, KeyValue.Type.DeleteFamilyVersion,
   value);
 delete.setSequenceId(1000);
 delete.setTimestamp(20000);
 tracker.add(delete);
 KeyValue put = new KeyValue(row, family, col1, 20000, KeyValue.Type.Put, value);
 put.setSequenceId(1001);
 put.setTimestamp(20000);
 assertEquals(DeleteResult.NOT_DELETED, tracker.isDeleted(put));
 put.setSequenceId(999);
 put.setTimestamp(20000);
 assertEquals(DeleteResult.VERSION_DELETED, tracker.isDeleted(put));
 put = new KeyValue(row, family, col2, 20000, KeyValue.Type.Put, value);
 put.setSequenceId(1001);
 put.setTimestamp(20000);
 assertEquals(DeleteResult.NOT_DELETED, tracker.isDeleted(put));
 put.setSequenceId(999);
 put.setTimestamp(20000);
 assertEquals(DeleteResult.VERSION_DELETED, tracker.isDeleted(put));
 put.setSequenceId(1002);
 put.setTimestamp(19999);
 assertEquals(DeleteResult.NOT_DELETED, tracker.isDeleted(put));
 put.setSequenceId(998);
 put.setTimestamp(19999);
 assertEquals(DeleteResult.VERSION_MASKED, tracker.isDeleted(put));
}

代码示例来源：origin: apache/hbase

KeyValue delete = new KeyValue(row, family, col1, 20000, KeyValue.Type.Delete, value);
delete.setSequenceId(1000);
delete.setTimestamp(20000);
tracker.add(delete);
put.setSequenceId(1001);
put.setTimestamp(20000);
assertEquals(DeleteResult.NOT_DELETED, tracker.isDeleted(put));
put.setSequenceId(999);
put.setTimestamp(20000);
assertEquals(DeleteResult.VERSION_DELETED, tracker.isDeleted(put));
delete.setTimestamp(20000);
tracker.add(delete);
put = new KeyValue(row, family, col2, 20000, KeyValue.Type.Put, value);
put.setSequenceId(1001);
put.setTimestamp(20000);
assertEquals(DeleteResult.VERSION_DELETED, tracker.isDeleted(put));
put.setSequenceId(999);
put.setTimestamp(20000);
assertEquals(DeleteResult.VERSION_DELETED, tracker.isDeleted(put));
put.setSequenceId(1002);
put.setTimestamp(19999);
assertEquals(DeleteResult.NOT_DELETED, tracker.isDeleted(put));
put.setSequenceId(998);
put.setTimestamp(19999);
assertEquals(DeleteResult.VERSION_MASKED, tracker.isDeleted(put));

代码示例来源：origin: apache/hbase

keyValue.setTimestamp(20000);
keyValue.setSequenceId(1000);
assertEquals(DeleteResult.NOT_DELETED, tracker.isDeleted(keyValue));
keyValue.setTimestamp(19999);
keyValue.setSequenceId(999);
assertEquals(DeleteResult.NOT_DELETED, tracker.isDeleted(keyValue));
keyValue.setTimestamp(19999);
keyValue.setSequenceId(998);
assertEquals(DeleteResult.VERSION_MASKED, tracker.isDeleted(keyValue));
keyValue.setTimestamp(19998);
keyValue.setSequenceId(997);
assertEquals(DeleteResult.NOT_DELETED, tracker.isDeleted(keyValue));
keyValue.setTimestamp(19997);
keyValue.setSequenceId(996);
assertEquals(DeleteResult.VERSION_MASKED, tracker.isDeleted(keyValue));
keyValue.setTimestamp(20000);
keyValue.setSequenceId(1000);
assertEquals(DeleteResult.NOT_DELETED, tracker.isDeleted(keyValue));
keyValue.setTimestamp(19999);
keyValue.setSequenceId(1002);
assertEquals(DeleteResult.NOT_DELETED, tracker.isDeleted(keyValue));
keyValue.setTimestamp(19999);
keyValue.setSequenceId(1001);
assertEquals(DeleteResult.VERSION_MASKED, tracker.isDeleted(keyValue));
keyValue.setTimestamp(19998);
keyValue.setSequenceId(1003);
assertEquals(DeleteResult.NOT_DELETED, tracker.isDeleted(keyValue));
keyValue.setTimestamp(19997);

代码示例来源：origin: apache/hbase

keyValue.setTimestamp(20000);
keyValue.setSequenceId(1000);
assertEquals(DeleteResult.NOT_DELETED, tracker.isDeleted(keyValue));
assertEquals(MatchCode.INCLUDE_AND_SEEK_NEXT_COL,
  tracker.checkVersions(keyValue, keyValue.getTimestamp(), keyValue.getTypeByte(), false));
keyValue.setTimestamp(19999);
keyValue.setSequenceId(999);
assertEquals(DeleteResult.NOT_DELETED, tracker.isDeleted(keyValue));
  MatchCode.SEEK_NEXT_COL,
  tracker.checkVersions(keyValue, keyValue.getTimestamp(), keyValue.getTypeByte(), false));
keyValue.setTimestamp(19999);
keyValue.setSequenceId(998);
assertEquals(DeleteResult.VERSION_MASKED, tracker.isDeleted(keyValue));
assertEquals(MatchCode.SEEK_NEXT_COL,
  tracker.checkVersions(keyValue, keyValue.getTimestamp(), keyValue.getTypeByte(), false));
keyValue.setTimestamp(19998);
keyValue.setSequenceId(997);
assertEquals(DeleteResult.NOT_DELETED, tracker.isDeleted(keyValue));
assertEquals(MatchCode.SEEK_NEXT_COL,
  tracker.checkVersions(keyValue, keyValue.getTimestamp(), keyValue.getTypeByte(), false));
keyValue.setTimestamp(19997);
keyValue.setSequenceId(996);
assertEquals(DeleteResult.VERSION_MASKED, tracker.isDeleted(keyValue));
keyValue.setTimestamp(20000);
keyValue.setSequenceId(1000);
assertEquals(DeleteResult.NOT_DELETED, tracker.isDeleted(keyValue));
assertEquals(MatchCode.INCLUDE_AND_SEEK_NEXT_COL,

代码示例来源：origin: apache/phoenix

@Override
public Cell getNextCellHint(Cell currentKV) {
 // this might be a little excessive right now - better safe than sorry though, so we don't mess
 // with other filters too much.
 KeyValue kv = null;
 try {
   kv = PhoenixKeyValueUtil.maybeCopyCell(currentKV).clone();
 } catch (CloneNotSupportedException e) {
   // the exception should not happen at all
   throw new IllegalArgumentException(e);
 }
 kv.setTimestamp(ts);
 return kv;
}

代码示例来源：origin: org.apache.phoenix/phoenix-core

@Override
public Cell getNextCellHint(Cell currentKV) {
 // this might be a little excessive right now - better safe than sorry though, so we don't mess
 // with other filters too much.
 KeyValue kv = null;
 try {
   kv = PhoenixKeyValueUtil.maybeCopyCell(currentKV).clone();
 } catch (CloneNotSupportedException e) {
   // the exception should not happen at all
   throw new IllegalArgumentException(e);
 }
 kv.setTimestamp(ts);
 return kv;
}

代码示例来源：origin: com.aliyun.phoenix/ali-phoenix-core

@Override
public Cell getNextCellHint(Cell currentKV) {
 // this might be a little excessive right now - better safe than sorry though, so we don't mess
 // with other filters too much.
 KeyValue kv = null;
 try {
   kv = PhoenixKeyValueUtil.maybeCopyCell(currentKV).clone();
 } catch (CloneNotSupportedException e) {
   // the exception should not happen at all
   throw new IllegalArgumentException(e);
 }
 kv.setTimestamp(ts);
 return kv;
}

代码示例来源：origin: org.apache.hbase/hbase-server

@Test
public void testVersionsDelete() {
 NewVersionBehaviorTracker tracker =
   new NewVersionBehaviorTracker(null, comparator, 1, 3, 3, 10000);
 KeyValue put = new KeyValue(row, family, col1, 20000, KeyValue.Type.Put, value);
 KeyValue delete = new KeyValue(row, family, col1, 20000, KeyValue.Type.DeleteColumn, value);
 delete.setSequenceId(1000);
 delete.setTimestamp(20000);
 tracker.add(delete);
 put.setSequenceId(1001);
 put.setTimestamp(19999);
 assertEquals(DeleteResult.NOT_DELETED, tracker.isDeleted(put));
 put.setSequenceId(999);
 put.setTimestamp(19998);
 assertEquals(DeleteResult.COLUMN_DELETED, tracker.isDeleted(put));
 delete = new KeyValue(row, family, col2, 20000, KeyValue.Type.DeleteColumn, value);
 delete.setSequenceId(1002);
 delete.setTimestamp(20000);
 tracker.add(delete);
 put = new KeyValue(row, family, col2, 20000, KeyValue.Type.Put, value);
 put.setSequenceId(1001);
 put.setTimestamp(19999);
 assertEquals(DeleteResult.COLUMN_DELETED, tracker.isDeleted(put));
 put.setSequenceId(999);
 put.setTimestamp(19998);
 assertEquals(DeleteResult.COLUMN_DELETED, tracker.isDeleted(put));
}

代码示例来源：origin: org.apache.hbase/hbase-server

@Test
public void testFamilyVersionsDelete() {
 NewVersionBehaviorTracker tracker =
   new NewVersionBehaviorTracker(null, comparator, 1, 3, 3, 10000);
 KeyValue delete = new KeyValue(row, family, null, 20000, KeyValue.Type.DeleteFamily, value);
 delete.setSequenceId(1000);
 delete.setTimestamp(20000);
 KeyValue put = new KeyValue(row, family, col1, 20000, KeyValue.Type.Put, value);
 tracker.add(delete);
 put.setSequenceId(1001);
 put.setTimestamp(20000);
 assertEquals(DeleteResult.NOT_DELETED, tracker.isDeleted(put));
 put.setSequenceId(999);
 put.setTimestamp(19998);
 assertEquals(DeleteResult.COLUMN_DELETED, tracker.isDeleted(put));
 put = new KeyValue(row, family, col2, 20000, KeyValue.Type.Put, value);
 put.setSequenceId(998);
 put.setTimestamp(19999);
 assertEquals(DeleteResult.COLUMN_DELETED, tracker.isDeleted(put));
 put.setSequenceId(999);
 put.setTimestamp(19998);
 assertEquals(DeleteResult.COLUMN_DELETED, tracker.isDeleted(put));
}

代码示例来源：origin: org.apache.hbase/hbase-server

keyValue.setTimestamp(20000);
keyValue.setSequenceId(1000);
assertEquals(DeleteResult.NOT_DELETED, tracker.isDeleted(keyValue));
keyValue.setTimestamp(19999);
keyValue.setSequenceId(999);
assertEquals(DeleteResult.NOT_DELETED, tracker.isDeleted(keyValue));
keyValue.setTimestamp(19999);
keyValue.setSequenceId(998);
assertEquals(DeleteResult.VERSION_MASKED, tracker.isDeleted(keyValue));
keyValue.setTimestamp(19998);
keyValue.setSequenceId(997);
assertEquals(DeleteResult.NOT_DELETED, tracker.isDeleted(keyValue));
keyValue.setTimestamp(19997);
keyValue.setSequenceId(996);
assertEquals(DeleteResult.VERSION_MASKED, tracker.isDeleted(keyValue));
keyValue.setTimestamp(20000);
keyValue.setSequenceId(1000);
assertEquals(DeleteResult.NOT_DELETED, tracker.isDeleted(keyValue));
keyValue.setTimestamp(19999);
keyValue.setSequenceId(1002);
assertEquals(DeleteResult.NOT_DELETED, tracker.isDeleted(keyValue));
keyValue.setTimestamp(19999);
keyValue.setSequenceId(1001);
assertEquals(DeleteResult.VERSION_MASKED, tracker.isDeleted(keyValue));
keyValue.setTimestamp(19998);
keyValue.setSequenceId(1003);
assertEquals(DeleteResult.NOT_DELETED, tracker.isDeleted(keyValue));
keyValue.setTimestamp(19997);

代码示例来源：origin: org.apache.hbase/hbase-server

@Test
public void testFamilyVersionDelete() {
 NewVersionBehaviorTracker tracker =
   new NewVersionBehaviorTracker(null, comparator, 1, 3, 3, 10000);
 KeyValue delete = new KeyValue(row, family, null, 20000, KeyValue.Type.DeleteFamilyVersion,
   value);
 delete.setSequenceId(1000);
 delete.setTimestamp(20000);
 tracker.add(delete);
 KeyValue put = new KeyValue(row, family, col1, 20000, KeyValue.Type.Put, value);
 put.setSequenceId(1001);
 put.setTimestamp(20000);
 assertEquals(DeleteResult.NOT_DELETED, tracker.isDeleted(put));
 put.setSequenceId(999);
 put.setTimestamp(20000);
 assertEquals(DeleteResult.VERSION_DELETED, tracker.isDeleted(put));
 put = new KeyValue(row, family, col2, 20000, KeyValue.Type.Put, value);
 put.setSequenceId(1001);
 put.setTimestamp(20000);
 assertEquals(DeleteResult.NOT_DELETED, tracker.isDeleted(put));
 put.setSequenceId(999);
 put.setTimestamp(20000);
 assertEquals(DeleteResult.VERSION_DELETED, tracker.isDeleted(put));
 put.setSequenceId(1002);
 put.setTimestamp(19999);
 assertEquals(DeleteResult.NOT_DELETED, tracker.isDeleted(put));
 put.setSequenceId(998);
 put.setTimestamp(19999);
 assertEquals(DeleteResult.VERSION_MASKED, tracker.isDeleted(put));
}

代码示例来源：origin: org.apache.hbase/hbase-server

KeyValue delete = new KeyValue(row, family, col1, 20000, KeyValue.Type.Delete, value);
delete.setSequenceId(1000);
delete.setTimestamp(20000);
tracker.add(delete);
put.setSequenceId(1001);
put.setTimestamp(20000);
assertEquals(DeleteResult.NOT_DELETED, tracker.isDeleted(put));
put.setSequenceId(999);
put.setTimestamp(20000);
assertEquals(DeleteResult.VERSION_DELETED, tracker.isDeleted(put));
delete.setTimestamp(20000);
tracker.add(delete);
put = new KeyValue(row, family, col2, 20000, KeyValue.Type.Put, value);
put.setSequenceId(1001);
put.setTimestamp(20000);
assertEquals(DeleteResult.VERSION_DELETED, tracker.isDeleted(put));
put.setSequenceId(999);
put.setTimestamp(20000);
assertEquals(DeleteResult.VERSION_DELETED, tracker.isDeleted(put));
put.setSequenceId(1002);
put.setTimestamp(19999);
assertEquals(DeleteResult.NOT_DELETED, tracker.isDeleted(put));
put.setSequenceId(998);
put.setTimestamp(19999);
assertEquals(DeleteResult.VERSION_MASKED, tracker.isDeleted(put));

代码示例来源：origin: org.apache.hbase/hbase-server

keyValue.setTimestamp(20000);
keyValue.setSequenceId(1000);
assertEquals(DeleteResult.NOT_DELETED, tracker.isDeleted(keyValue));
assertEquals(MatchCode.INCLUDE_AND_SEEK_NEXT_COL,
  tracker.checkVersions(keyValue, keyValue.getTimestamp(), keyValue.getTypeByte(), false));
keyValue.setTimestamp(19999);
keyValue.setSequenceId(999);
assertEquals(DeleteResult.NOT_DELETED, tracker.isDeleted(keyValue));
  MatchCode.SEEK_NEXT_COL,
  tracker.checkVersions(keyValue, keyValue.getTimestamp(), keyValue.getTypeByte(), false));
keyValue.setTimestamp(19999);
keyValue.setSequenceId(998);
assertEquals(DeleteResult.VERSION_MASKED, tracker.isDeleted(keyValue));
assertEquals(MatchCode.SEEK_NEXT_COL,
  tracker.checkVersions(keyValue, keyValue.getTimestamp(), keyValue.getTypeByte(), false));
keyValue.setTimestamp(19998);
keyValue.setSequenceId(997);
assertEquals(DeleteResult.NOT_DELETED, tracker.isDeleted(keyValue));
assertEquals(MatchCode.SEEK_NEXT_COL,
  tracker.checkVersions(keyValue, keyValue.getTimestamp(), keyValue.getTypeByte(), false));
keyValue.setTimestamp(19997);
keyValue.setSequenceId(996);
assertEquals(DeleteResult.VERSION_MASKED, tracker.isDeleted(keyValue));
keyValue.setTimestamp(20000);
keyValue.setSequenceId(1000);
assertEquals(DeleteResult.NOT_DELETED, tracker.isDeleted(keyValue));
assertEquals(MatchCode.INCLUDE_AND_SEEK_NEXT_COL,

内容来源于网络，如有侵权，请联系作者删除！

KeyValue

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多

    KeyValue类方法

    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com