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

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

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

KeyValue.getTypeByte介绍

暂无

代码示例

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

@Override
public byte getTypeByte() {
 return this.kv.getTypeByte();
}

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

protected static String getTypeString(final KeyValue kv) {
 return KeyValue.Type.codeToType(kv.getTypeByte()).toString();
}

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

@Test
public void testColumns() throws IOException {
 TreeSet<byte[]> trackedColumns = new TreeSet<byte[]>(Bytes.BYTES_COMPARATOR);
 trackedColumns.add(col1);
 trackedColumns.add(col3);
 NewVersionBehaviorTracker tracker =
   new NewVersionBehaviorTracker(trackedColumns, comparator, 1, 3, 3, 10000);
 KeyValue keyValue = new KeyValue(row, family, col0, 20000, KeyValue.Type.Put, value);
 assertEquals(DeleteResult.NOT_DELETED, tracker.isDeleted(keyValue));
 assertEquals(MatchCode.SEEK_NEXT_COL, tracker.checkColumn(keyValue, keyValue.getTypeByte()));
 keyValue = new KeyValue(row, family, col1, 20000, KeyValue.Type.Put, value);
 assertEquals(DeleteResult.NOT_DELETED, tracker.isDeleted(keyValue));
 assertEquals(MatchCode.INCLUDE, tracker.checkColumn(keyValue, keyValue.getTypeByte()));
 keyValue = new KeyValue(row, family, col2, 20000, KeyValue.Type.Put, value);
 assertEquals(DeleteResult.NOT_DELETED, tracker.isDeleted(keyValue));
 assertEquals(MatchCode.SEEK_NEXT_COL, tracker.checkColumn(keyValue, keyValue.getTypeByte()));
 keyValue = new KeyValue(row, family, col3, 20000, KeyValue.Type.Put, value);
 assertEquals(DeleteResult.NOT_DELETED, tracker.isDeleted(keyValue));
 assertEquals(MatchCode.INCLUDE, tracker.checkColumn(keyValue, keyValue.getTypeByte()));
 keyValue = new KeyValue(row, family, col4, 20000, KeyValue.Type.Put, value);
 assertEquals(DeleteResult.NOT_DELETED, tracker.isDeleted(keyValue));
 assertEquals(MatchCode.SEEK_NEXT_ROW, tracker.checkColumn(keyValue, keyValue.getTypeByte()));
}

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

private void updateMutationAddingTags(final Mutation m) {
 byte[] attribute = m.getAttribute("visibility");
 byte[] cf = null;
 List<Cell> updatedCells = new ArrayList<>();
 if (attribute != null) {
  for (List<? extends Cell> edits : m.getFamilyCellMap().values()) {
   for (Cell cell : edits) {
    KeyValue kv = KeyValueUtil.ensureKeyValue(cell);
    if (cf == null) {
     cf = CellUtil.cloneFamily(kv);
    }
    Tag tag = new ArrayBackedTag((byte) 1, attribute);
    List<Tag> tagList = new ArrayList<>();
    tagList.add(tag);
    KeyValue newKV = new KeyValue(CellUtil.cloneRow(kv), 0, kv.getRowLength(),
      CellUtil.cloneFamily(kv), 0, kv.getFamilyLength(), CellUtil.cloneQualifier(kv), 0,
      kv.getQualifierLength(), kv.getTimestamp(),
      KeyValue.Type.codeToType(kv.getTypeByte()), CellUtil.cloneValue(kv), 0,
      kv.getValueLength(), tagList);
    ((List<Cell>) updatedCells).add(newKV);
   }
  }
  m.getFamilyCellMap().remove(cf);
  // Update the family map
  m.getFamilyCellMap().put(cf, updatedCells);
 }
}

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

@Override
 public void prePut(final ObserverContext<RegionCoprocessorEnvironment> e, final Put put,
   final WALEdit edit, final Durability durability) throws IOException {
  byte[] attribute = put.getAttribute("visibility");
  byte[] cf = null;
  List<Cell> updatedCells = new ArrayList<>();
  if (attribute != null) {
   for (List<? extends Cell> edits : put.getFamilyCellMap().values()) {
    for (Cell cell : edits) {
     KeyValue kv = KeyValueUtil.ensureKeyValue(cell);
     if (cf == null) {
      cf = CellUtil.cloneFamily(kv);
     }
     Tag tag = new ArrayBackedTag(TAG_TYPE, attribute);
     List<Tag> tagList = new ArrayList<>(1);
     tagList.add(tag);
     KeyValue newKV = new KeyValue(CellUtil.cloneRow(kv), 0, kv.getRowLength(),
       CellUtil.cloneFamily(kv), 0, kv.getFamilyLength(), CellUtil.cloneQualifier(kv), 0,
       kv.getQualifierLength(), kv.getTimestamp(),
       KeyValue.Type.codeToType(kv.getTypeByte()), CellUtil.cloneValue(kv), 0,
       kv.getValueLength(), tagList);
     ((List<Cell>) updatedCells).add(newKV);
    }
   }
   put.getFamilyCellMap().remove(cf);
   // Update the family map
   put.getFamilyCellMap().put(cf, updatedCells);
  }
 }
}

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

kv1.getFamilyOffset() - KeyValue.ROW_OFFSET, kv1.getFamilyLength(),
kv1.getQualifierOffset() - KeyValue.ROW_OFFSET, kv1.getQualifierLength(),
kv1.getTimestamp(), kv1.getTypeByte(), kv1.getValueArray(), kv1.getValueOffset(),
kv1.getValueLength(), kv1.getSequenceId(), kv1.getTagsArray(), kv1.getTagsOffset(),
kv1.getTagsLength());
kv2.getFamilyOffset() - KeyValue.ROW_OFFSET, kv2.getFamilyLength(),
kv2.getQualifierOffset() - KeyValue.ROW_OFFSET, kv2.getQualifierLength(),
kv2.getTimestamp(), kv2.getTypeByte(), kv2.getValueArray(), kv2.getValueOffset(),
kv2.getValueLength(), kv2.getSequenceId(), kv2.getTagsArray(), kv2.getTagsOffset(),
kv2.getTagsLength());
kv2.getRowLength(), kv2.getFamilyOffset() - KeyValue.ROW_OFFSET, kv2.getFamilyLength(),
kv2.getQualifierOffset() - KeyValue.ROW_OFFSET, kv2.getQualifierLength(),
kv2.getTimestamp(), kv2.getTypeByte(), ByteBuffer.wrap(kv2.getValueArray()),
kv2.getValueOffset(), kv2.getValueLength(), kv2.getSequenceId(),
ByteBuffer.wrap(kv2.getTagsArray()), kv2.getTagsOffset(), kv2.getTagsLength());

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

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(
  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));
assertEquals(MatchCode.SEEK_NEXT_COL,
  tracker.checkVersions(keyValue, keyValue.getTimestamp(), keyValue.getTypeByte(), false));
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);

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

.getTimestamp());
assertTrue(KeyOnlyKeyValue.getTypeByte() == keyOnlyCell.getTypeByte());
assertTrue(KeyOnlyKeyValue.getTypeByte() == keyOnlyByteBufferedCell
  .getTypeByte());

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

private int compareType(KeyValue l, KeyValue r) {
 return (int) r.getTypeByte() - (int) l.getTypeByte();
}

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

if (newKeyValue != null) {
  sizeBytes += newKeyValue.getLength();
  if (KeyValue.Type.codeToType(newKeyValue.getTypeByte()) == KeyValue.Type.Put) {
    put.add(newKeyValue);
    mutations.add(put);
  } else if (KeyValue.Type.codeToType(newKeyValue.getTypeByte()) == KeyValue.Type.Delete){

代码示例来源：origin: harbby/presto-connectors

/**
 * @return Type of this KeyValue.
 */
@Deprecated
public byte getType() {
 return getTypeByte();
}

代码示例来源：origin: com.aliyun.hbase/alihbase-common

/**
 * @return KeyValue.TYPE byte representation
 */
@Override
public byte getTypeByte() {
 return this.kv.getTypeByte();
}

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

@Override
public byte getTypeByte() {
 return this.kv.getTypeByte();
}

代码示例来源：origin: com.aliyun.hbase/alihbase-common

@Override
public byte getTypeByte() {
 return this.kv.getTypeByte();
}

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

protected static String getTypeString(final KeyValue kv) {
 return KeyValue.Type.codeToType(kv.getTypeByte()).toString();
}

代码示例来源：origin: com.aliyun.hbase/alihbase-common

protected static String getTypeString(final KeyValue kv) {
 return KeyValue.Type.codeToType(kv.getTypeByte()).toString();
}

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

.getTimestamp());
assertTrue(KeyOnlyKeyValue.getTypeByte() == keyOnlyCell.getTypeByte());
assertTrue(KeyOnlyKeyValue.getTypeByte() == keyOnlyByteBufferedCell
  .getTypeByte());

代码示例来源：origin: NGDATA/hbase-indexer

private void handleDelete(String documentId, KeyValue deleteKeyValue, SolrUpdateCollector updateCollector,
             UniqueKeyFormatter uniqueKeyFormatter) {
  byte deleteType = deleteKeyValue.getTypeByte();
  if (deleteType == KeyValue.Type.DeleteColumn.getCode()) {
    updateCollector.deleteById(documentId);
  } else if (deleteType == KeyValue.Type.DeleteFamily.getCode()) {
    if (uniqueKeyFormatter instanceof UniqueTableKeyFormatter) {
      deleteFamily(deleteKeyValue, updateCollector, uniqueKeyFormatter,
          ((UniqueTableKeyFormatter) uniqueKeyFormatter).unformatTable(documentId));
    } else {
      deleteFamily(deleteKeyValue, updateCollector, uniqueKeyFormatter, null);
    }
  } else if (deleteType == KeyValue.Type.Delete.getCode()) {
    if (uniqueKeyFormatter instanceof UniqueTableKeyFormatter) {
      deleteRow(deleteKeyValue, updateCollector, uniqueKeyFormatter,
          ((UniqueTableKeyFormatter) uniqueKeyFormatter).unformatTable(documentId));
    } else {
      deleteRow(deleteKeyValue, updateCollector, uniqueKeyFormatter, null);
    }
  } else {
    log.error(String.format("Unknown delete type %d for document %s, not doing anything", deleteType, documentId));
  }
}

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

@Test
public void testColumns() throws IOException {
 TreeSet<byte[]> trackedColumns = new TreeSet<byte[]>(Bytes.BYTES_COMPARATOR);
 trackedColumns.add(col1);
 trackedColumns.add(col3);
 NewVersionBehaviorTracker tracker =
   new NewVersionBehaviorTracker(trackedColumns, comparator, 1, 3, 3, 10000);
 KeyValue keyValue = new KeyValue(row, family, col0, 20000, KeyValue.Type.Put, value);
 assertEquals(DeleteResult.NOT_DELETED, tracker.isDeleted(keyValue));
 assertEquals(MatchCode.SEEK_NEXT_COL, tracker.checkColumn(keyValue, keyValue.getTypeByte()));
 keyValue = new KeyValue(row, family, col1, 20000, KeyValue.Type.Put, value);
 assertEquals(DeleteResult.NOT_DELETED, tracker.isDeleted(keyValue));
 assertEquals(MatchCode.INCLUDE, tracker.checkColumn(keyValue, keyValue.getTypeByte()));
 keyValue = new KeyValue(row, family, col2, 20000, KeyValue.Type.Put, value);
 assertEquals(DeleteResult.NOT_DELETED, tracker.isDeleted(keyValue));
 assertEquals(MatchCode.SEEK_NEXT_COL, tracker.checkColumn(keyValue, keyValue.getTypeByte()));
 keyValue = new KeyValue(row, family, col3, 20000, KeyValue.Type.Put, value);
 assertEquals(DeleteResult.NOT_DELETED, tracker.isDeleted(keyValue));
 assertEquals(MatchCode.INCLUDE, tracker.checkColumn(keyValue, keyValue.getTypeByte()));
 keyValue = new KeyValue(row, family, col4, 20000, KeyValue.Type.Put, value);
 assertEquals(DeleteResult.NOT_DELETED, tracker.isDeleted(keyValue));
 assertEquals(MatchCode.SEEK_NEXT_ROW, tracker.checkColumn(keyValue, keyValue.getTypeByte()));
}

代码示例来源：origin: Merck/Halyard

@Test
public void testToKeyValuesDelete() throws Exception {
  IRI res = SimpleValueFactory.getInstance().createIRI("http://testiri");
  KeyValue kvs[] = HalyardTableUtils.toKeyValues(res, res, res, res, true, 0);
  assertEquals(6, kvs.length);
  for (KeyValue kv : kvs) {
    assertEquals(KeyValue.Type.DeleteColumn, KeyValue.Type.codeToType(kv.getTypeByte()));
  }
}

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

KeyValue

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

    更多

    KeyValue类方法

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