本文整理了Java中org.apache.hadoop.hbase.client.Get.toString()
方法的一些代码示例,展示了Get.toString()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Get.toString()
方法的具体详情如下:
包路径:org.apache.hadoop.hbase.client.Get
类名称: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));
}
}
内容来源于网络,如有侵权,请联系作者删除!