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

x33g5p2x  于2022-01-19 转载在 其他  
字(3.5k)|赞(0)|评价(0)|浏览(145)

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

Get.toString介绍

暂无

代码示例

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

if (LOG.isTraceEnabled()) LOG.trace(get.toString());
try {
 if (opts.multiGet > 0) {

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

if (LOG.isTraceEnabled()) LOG.trace(get.toString());
if (opts.multiGet > 0) {
 this.gets.add(get);

代码示例来源:origin: co.cask.cdap/cdap-hbase-compat-base

@Override
 public String toString() {
  return get.toString();
 }
}

代码示例来源:origin: cdapio/cdap

@Override
 public String toString() {
  return get.toString();
 }
}

代码示例来源:origin: altamiracorp/honeycomb

/**
 * Execute get on a list of {@link Get}
 *
 * @param hTable HTable
 * @param get    {@link Get}
 * @return {@link Result} from the get call
 */
public static Result performGet(HTableInterface hTable, Get get) {
  try {
    return hTable.get(get);
  } catch (IOException e) {
    String msg = String.format("HBase table get failed for get %s", get.toString());
    throw createException(msg, e, hTable);
  }
}

代码示例来源:origin: jrkinley/storm-hbase

/**
 * Get the latest txid to successfully update the given counter
 * @param row The row key
 * @param fam The column family
 * @param qual The column qualifier of the txid (e.g. the counters qualifier + "_txid")
 * @return The latest txid
 */
private BigInteger getLatestTxid(byte[] row, byte[] fam, byte[] qual) {
 Get getTxid = new Get(row);
 getTxid.addColumn(fam, qual);
 BigInteger latestTxid = null;
 try {
  Result res = connector.getTable().get(getTxid);
  if (!res.isEmpty()) {
   latestTxid = new BigInteger(res.getValue(fam, qual));
  }
 } catch (IOException e) {
  throw new RuntimeException("Unable to get txid for " + getTxid.toString(), e);
 }
 return latestTxid;
}

代码示例来源:origin: stackoverflow.com

.get(spreadsheetId, range);
System.out.println("Get respuesta --> " +respuesta.toString());
System.out.println("Exe respuesta --> " +respuesta.execute());

代码示例来源:origin: OpenSOC/opensoc-streaming

/**
 * Executes the given Get request.
 * 
 * @param table
 *          hbase table
 * @param get
 *          Get
 * @return List<Cell>
 * @throws IOException
 *           Signals that an I/O exception has occurred.
 */
private List<Cell> executeGetRequest(HTable table, Get get)
  throws IOException {
 LOGGER.info("Get :" + get.toString());
 table = (HTable) HBaseConfigurationUtil.getConnection().getTable(
   ConfigurationUtil.getTableName());
 Result result = table.get(get);
 List<Cell> cells = result.getColumnCells(
   ConfigurationUtil.getColumnFamily(),
   ConfigurationUtil.getColumnQualifier());
 return cells;
}

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

if (LOG.isTraceEnabled()) LOG.trace(get.toString());
try {
 if (opts.multiGet > 0) {

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

if (LOG.isTraceEnabled()) LOG.trace(get.toString());
if (opts.multiGet > 0) {
 this.gets.add(get);

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

if (LOG.isTraceEnabled()) LOG.trace(get.toString());
try {
 if (opts.multiGet > 0) {

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

@Override
void testRow(final int i) throws IOException, InterruptedException {
 if (opts.randomSleep > 0) {
  Thread.sleep(rd.nextInt(opts.randomSleep));
 }
 Get get = new Get(getRandomRow(this.rand, opts.totalRows));
 if (opts.addColumns) {
  get.addColumn(FAMILY_NAME, QUALIFIER_NAME);
 } else {
  get.addFamily(FAMILY_NAME);
 }
 if (opts.filterAll) {
  get.setFilter(new FilterAllFilter());
 }
 get.setConsistency(consistency);
 if (LOG.isTraceEnabled()) LOG.trace(get.toString());
 if (opts.multiGet > 0) {
  this.gets.add(get);
  if (this.gets.size() == opts.multiGet) {
   Result [] rs = this.table.get(this.gets);
   updateValueSize(rs);
   this.gets.clear();
  }
 } else {
  updateValueSize(this.table.get(get));
 }
}

相关文章