org.apache.hadoop.hbase.client.Put.createPutKeyValue()方法的使用及代码示例

x33g5p2x  于2022-01-26 转载在 其他  
字(9.4k)|赞(0)|评价(0)|浏览(167)

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

Put.createPutKeyValue介绍

暂无

代码示例

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

/**
 * Add the specified column and value, with the specified timestamp as
 * its version to this Put operation.
 * @param family family name
 * @param qualifier column qualifier
 * @param ts version timestamp
 * @param value column value
 * @return this
 */
public Put addColumn(byte [] family, byte [] qualifier, long ts, byte [] value) {
 if (ts < 0) {
  throw new IllegalArgumentException("Timestamp cannot be negative. ts=" + ts);
 }
 List<Cell> list = getCellList(family);
 KeyValue kv = createPutKeyValue(family, qualifier, ts, value);
 list.add(kv);
 return this;
}

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

/**
 * Add the specified column and value, with the specified timestamp as
 * its version to this Put operation.
 * @param family family name
 * @param qualifier column qualifier
 * @param ts version timestamp
 * @param value column value
 * @return this
 */
public Put addColumn(byte[] family, ByteBuffer qualifier, long ts, ByteBuffer value) {
 if (ts < 0) {
  throw new IllegalArgumentException("Timestamp cannot be negative. ts=" + ts);
 }
 List<Cell> list = getCellList(family);
 KeyValue kv = createPutKeyValue(family, qualifier, ts, value, null);
 list.add(kv);
 return this;
}

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

/**
 * See {@link #addColumn(byte[], ByteBuffer, long, ByteBuffer)}. This version expects
 * that the underlying arrays won't change. It's intended
 * for usage internal HBase to and for advanced client applications.
 * @deprecated As of release 2.0.0, this will be removed in HBase 3.0.0.
 *             Use {@link #add(Cell)} and {@link org.apache.hadoop.hbase.CellBuilder} instead
 */
@Deprecated
public Put addImmutable(byte[] family, ByteBuffer qualifier, long ts, ByteBuffer value) {
 if (ts < 0) {
  throw new IllegalArgumentException("Timestamp cannot be negative. ts=" + ts);
 }
 List<Cell> list = getCellList(family);
 KeyValue kv = createPutKeyValue(family, qualifier, ts, value, null);
 list.add(kv);
 return this;
}

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

/**
 * See {@link #addColumn(byte[], ByteBuffer, long, ByteBuffer)}. This version expects
 * that the underlying arrays won't change. It's intended
 * for usage internal HBase to and for advanced client applications.
 * @deprecated As of release 2.0.0, this will be removed in HBase 3.0.0.
 *             Use {@link #add(Cell)} and {@link org.apache.hadoop.hbase.CellBuilder} instead
 */
@Deprecated
public Put addImmutable(byte[] family, ByteBuffer qualifier, long ts, ByteBuffer value) {
 if (ts < 0) {
  throw new IllegalArgumentException("Timestamp cannot be negative. ts=" + ts);
 }
 List<Cell> list = getCellList(family);
 KeyValue kv = createPutKeyValue(family, qualifier, ts, value, null);
 list.add(kv);
 return this;
}

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

/**
 * Add the specified column and value, with the specified timestamp as
 * its version to this Put operation.
 * @param family family name
 * @param qualifier column qualifier
 * @param ts version timestamp
 * @param value column value
 * @return this
 */
public Put addColumn(byte[] family, ByteBuffer qualifier, long ts, ByteBuffer value) {
 if (ts < 0) {
  throw new IllegalArgumentException("Timestamp cannot be negative. ts=" + ts);
 }
 List<Cell> list = getCellList(family);
 KeyValue kv = createPutKeyValue(family, qualifier, ts, value, null);
 list.add(kv);
 return this;
}

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

/**
 * Add the specified column and value, with the specified timestamp as
 * its version to this Put operation.
 * @param family family name
 * @param qualifier column qualifier
 * @param ts version timestamp
 * @param value column value
 * @return this
 */
public Put addColumn(byte [] family, byte [] qualifier, long ts, byte [] value) {
 if (ts < 0) {
  throw new IllegalArgumentException("Timestamp cannot be negative. ts=" + ts);
 }
 List<Cell> list = getCellList(family);
 KeyValue kv = createPutKeyValue(family, qualifier, ts, value);
 list.add(kv);
 return this;
}

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

/**
 * See {@link #add(byte[], ByteBuffer, long, ByteBuffer)}. This version expects
 * that the underlying arrays won't change. It's intended
 * for usage internal HBase to and for advanced client applications.
 */
public Put addImmutable(byte[] family, ByteBuffer qualifier, long ts, ByteBuffer value) {
 if (ts < 0) {
  throw new IllegalArgumentException("Timestamp cannot be negative. ts=" + ts);
 }
 List<Cell> list = getCellList(family);
 KeyValue kv = createPutKeyValue(family, qualifier, ts, value, null);
 list.add(kv);
 familyMap.put(family, list);
 return this;
}

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

/**
 * See {@link #add(byte[], byte[], long, byte[])}. This version expects
 * that the underlying arrays won't change. It's intended
 * for usage internal HBase to and for advanced client applications.
 */
public Put addImmutable(byte [] family, byte [] qualifier, long ts, byte [] value) {
 if (ts < 0) {
  throw new IllegalArgumentException("Timestamp cannot be negative. ts=" + ts);
 }
 List<Cell> list = getCellList(family);
 KeyValue kv = createPutKeyValue(family, qualifier, ts, value);
 list.add(kv);
 familyMap.put(family, list);
 return this;
}

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

/**
 * Add the specified column and value, with the specified timestamp as
 * its version to this Put operation.
 * @param family family name
 * @param qualifier column qualifier
 * @param ts version timestamp
 * @param value column value
 * @return this
 */
public Put addColumn(byte [] family, byte [] qualifier, long ts, byte [] value) {
 if (ts < 0) {
  throw new IllegalArgumentException("Timestamp cannot be negative. ts=" + ts);
 }
 List<Cell> list = getCellList(family);
 KeyValue kv = createPutKeyValue(family, qualifier, ts, value);
 list.add(kv);
 return this;
}

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

/**
 * Add the specified column and value, with the specified timestamp as
 * its version to this Put operation.
 * @param family family name
 * @param qualifier column qualifier
 * @param ts version timestamp
 * @param value column value
 * @return this
 */
public Put addColumn(byte[] family, ByteBuffer qualifier, long ts, ByteBuffer value) {
 if (ts < 0) {
  throw new IllegalArgumentException("Timestamp cannot be negative. ts=" + ts);
 }
 List<Cell> list = getCellList(family);
 KeyValue kv = createPutKeyValue(family, qualifier, ts, value, null);
 list.add(kv);
 return this;
}

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

/**
 * See {@link #addColumn(byte[], ByteBuffer, long, ByteBuffer)}. This version expects
 * that the underlying arrays won't change. It's intended
 * for usage internal HBase to and for advanced client applications.
 * @deprecated As of release 2.0.0, this will be removed in HBase 3.0.0.
 *             Use {@link #add(Cell)} and {@link org.apache.hadoop.hbase.CellBuilder} instead
 */
@Deprecated
public Put addImmutable(byte[] family, ByteBuffer qualifier, long ts, ByteBuffer value) {
 if (ts < 0) {
  throw new IllegalArgumentException("Timestamp cannot be negative. ts=" + ts);
 }
 List<Cell> list = getCellList(family);
 KeyValue kv = createPutKeyValue(family, qualifier, ts, value, null);
 list.add(kv);
 return this;
}

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

/**
 * This expects that the underlying arrays won't change. It's intended
 * for usage internal HBase to and for advanced client applications.
 * <p>Marked as audience Private as of 1.2.0. {@link Tag} is an internal implementation detail
 * that should not be exposed publicly.
 */
@InterfaceAudience.Private
public Put addImmutable(byte[] family, byte[] qualifier, long ts, byte[] value, Tag[] tag) {
 List<Cell> list = getCellList(family);
 KeyValue kv = createPutKeyValue(family, qualifier, ts, value, tag);
 list.add(kv);
 familyMap.put(family, list);
 return this;
}

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

/**
 * Add the specified column and value, with the specified timestamp as
 * its version to this Put operation.
 * @param family family name
 * @param qualifier column qualifier
 * @param ts version timestamp
 * @param value column value
 * @return this
 */
public Put addColumn(byte[] family, ByteBuffer qualifier, long ts, ByteBuffer value) {
 if (ts < 0) {
  throw new IllegalArgumentException("Timestamp cannot be negative. ts=" + ts);
 }
 List<Cell> list = getCellList(family);
 KeyValue kv = createPutKeyValue(family, qualifier, ts, value, null);
 list.add(kv);
 familyMap.put(CellUtil.cloneFamily(kv), list);
 return this;
}

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

/**
 * Add the specified column and value, with the specified timestamp as
 * its version to this Put operation.
 * @param family family name
 * @param qualifier column qualifier
 * @param ts version timestamp
 * @param value column value
 * @return this
 */
public Put add(byte [] family, byte [] qualifier, long ts, byte [] value) {
 List<KeyValue> list = getKeyValueList(family);
 KeyValue kv = createPutKeyValue(family, qualifier, ts, value);
 list.add(kv);
 familyMap.put(kv.getFamily(), list);
 return this;
}

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

/**
 * This expects that the underlying arrays won't change. It's intended
 * for usage internal HBase to and for advanced client applications.
 * <p>Marked as audience Private as of 1.2.0. {@link Tag} is an internal implementation detail
 * that should not be exposed publicly.
 */
@InterfaceAudience.Private
public Put addImmutable(byte[] family, ByteBuffer qualifier, long ts, ByteBuffer value,
            Tag[] tag) {
 if (ts < 0) {
  throw new IllegalArgumentException("Timestamp cannot be negative. ts=" + ts);
 }
 List<Cell> list = getCellList(family);
 KeyValue kv = createPutKeyValue(family, qualifier, ts, value, tag);
 list.add(kv);
 familyMap.put(family, list);
 return this;
}

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

/**
 * Add the specified column and value, with the specified timestamp as
 * its version to this Put operation.
 * @param family family name
 * @param qualifier column qualifier
 * @param ts version timestamp
 * @param value column value
 * @return this
 */
public Put addColumn(byte [] family, byte [] qualifier, long ts, byte [] value) {
 if (ts < 0) {
  throw new IllegalArgumentException("Timestamp cannot be negative. ts=" + ts);
 }
 List<Cell> list = getCellList(family);
 KeyValue kv = createPutKeyValue(family, qualifier, ts, value);
 list.add(kv);
 familyMap.put(CellUtil.cloneFamily(kv), list);
 return this;
}

相关文章