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

Append.getFamilyMap介绍

暂无

代码示例

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

public Append dropSequence(long timestamp) {
  byte[] key = SchemaUtil.getSequenceKey(this.key.getTenantId(), this.key.getSchemaName(), this.key.getSequenceName());
  Append append = new Append(key);
  append.setAttribute(SequenceRegionObserver.OPERATION_ATTRIB, new byte[] {(byte)SequenceRegionObserver.Op.DROP_SEQUENCE.ordinal()});
  if (timestamp != HConstants.LATEST_TIMESTAMP) {
    append.setAttribute(SequenceRegionObserver.MAX_TIMERANGE_ATTRIB, Bytes.toBytes(timestamp));
  }
  Map<byte[], List<KeyValue>> familyMap = append.getFamilyMap();
  familyMap.put(PhoenixDatabaseMetaData.SEQUENCE_FAMILY_BYTES, Arrays.<KeyValue>asList(
      KeyValueUtil.newKeyValue(key, PhoenixDatabaseMetaData.SEQUENCE_FAMILY_BYTES, QueryConstants.EMPTY_COLUMN_BYTES, timestamp, ByteUtil.EMPTY_BYTE_ARRAY)));
  return append;
}

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

private Append newReturn(SequenceValue value) {
  byte[] key = SchemaUtil.getSequenceKey(this.key.getTenantId(), this.key.getSchemaName(), this.key.getSequenceName());
  Append append = new Append(key);
  byte[] opBuf = new byte[] {(byte)SequenceRegionObserver.Op.RETURN_SEQUENCE.ordinal()};
  append.setAttribute(SequenceRegionObserver.OPERATION_ATTRIB, opBuf);
  append.setAttribute(SequenceRegionObserver.CURRENT_VALUE_ATTRIB, PDataType.LONG.toBytes(value.nextValue));
  Map<byte[], List<KeyValue>> familyMap = append.getFamilyMap();
  familyMap.put(PhoenixDatabaseMetaData.SEQUENCE_FAMILY_BYTES, Arrays.<KeyValue>asList(
      KeyValueUtil.newKeyValue(key, PhoenixDatabaseMetaData.SEQUENCE_FAMILY_BYTES, PhoenixDatabaseMetaData.CURRENT_VALUE_BYTES, value.timestamp, PDataType.LONG.toBytes(value.currentValue))
      ));
  return append;
}

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

public Append createSequence(long startWith, long incrementBy, int cacheSize, long timestamp) {
  byte[] key = SchemaUtil.getSequenceKey(this.key.getTenantId(), this.key.getSchemaName(), this.key.getSequenceName());
  Append append = new Append(key);
  append.setAttribute(SequenceRegionObserver.OPERATION_ATTRIB, new byte[] {(byte)SequenceRegionObserver.Op.CREATE_SEQUENCE.ordinal()});
  if (timestamp != HConstants.LATEST_TIMESTAMP) {
    append.setAttribute(SequenceRegionObserver.MAX_TIMERANGE_ATTRIB, Bytes.toBytes(timestamp));
  }
  Map<byte[], List<KeyValue>> familyMap = append.getFamilyMap();
  byte[] startWithBuf = PDataType.LONG.toBytes(startWith);
  familyMap.put(PhoenixDatabaseMetaData.SEQUENCE_FAMILY_BYTES, Arrays.<KeyValue>asList(
      KeyValueUtil.newKeyValue(key, PhoenixDatabaseMetaData.SEQUENCE_FAMILY_BYTES, QueryConstants.EMPTY_COLUMN_BYTES, timestamp, ByteUtil.EMPTY_BYTE_ARRAY),
      KeyValueUtil.newKeyValue(key, PhoenixDatabaseMetaData.SEQUENCE_FAMILY_BYTES, PhoenixDatabaseMetaData.CURRENT_VALUE_BYTES, timestamp, startWithBuf),
      KeyValueUtil.newKeyValue(key, PhoenixDatabaseMetaData.SEQUENCE_FAMILY_BYTES, PhoenixDatabaseMetaData.START_WITH_BYTES, timestamp, startWithBuf),
      KeyValueUtil.newKeyValue(key, PhoenixDatabaseMetaData.SEQUENCE_FAMILY_BYTES, PhoenixDatabaseMetaData.INCREMENT_BY_BYTES, timestamp, PDataType.LONG.toBytes(incrementBy)),
      KeyValueUtil.newKeyValue(key, PhoenixDatabaseMetaData.SEQUENCE_FAMILY_BYTES, PhoenixDatabaseMetaData.CACHE_SIZE_BYTES, timestamp, PDataType.INTEGER.toBytes(cacheSize))
      ));
  return append;
}

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

KeyValue keyValue = append.getFamilyMap().values().iterator().next().iterator().next();
      m.getFamilyMap().putAll(append.getFamilyMap());
      break;
    case DROP_SEQUENCE:
    case CREATE_SEQUENCE:
      m = new Put(row, clientTimestamp);
      m.getFamilyMap().putAll(append.getFamilyMap());
      break;

代码示例来源：origin: co.cask.hbase/hbase

long now = EnvironmentEdgeManager.currentTimeMillis();
  for (Map.Entry<byte[], List<KeyValue>> family : append.getFamilyMap()
    .entrySet()) {
this.opMetrics.updateAppendMetrics(append.getFamilyMap().keySet(), after - before);