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

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

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

Get.getMaxResultsPerColumnFamily介绍

[英]Method for retrieving the get's maximum number of values to return per Column Family
[中]用于检索每个列族要返回的get最大值数的方法

代码示例

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

this.storeLimit = get.getMaxResultsPerColumnFamily();
this.storeOffset = get.getRowOffsetPerColumnFamily();
this.tr = get.getTimeRange();

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

this.cacheBlocks = get.getCacheBlocks();
this.maxVersions = get.getMaxVersions();
this.storeLimit = get.getMaxResultsPerColumnFamily();
this.storeOffset = get.getRowOffsetPerColumnFamily();
this.tr = get.getTimeRange();

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

out.setTargetReplicaId(in.getReplicaId());
out.setCacheBlocks(in.getCacheBlocks());
out.setStoreLimit(in.getMaxResultsPerColumnFamily());
out.setStoreOffset(in.getRowOffsetPerColumnFamily());
out.setExistence_only(in.isCheckExistenceOnly());

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

if (get.getMaxResultsPerColumnFamily() >= 0) {
 builder.setStoreLimit(get.getMaxResultsPerColumnFamily());

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

if (get.getMaxResultsPerColumnFamily() >= 0) {
 builder.setStoreLimit(get.getMaxResultsPerColumnFamily());

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

assertEquals(get.getIsolationLevel(), scan.getIsolationLevel());
assertEquals(get.getLoadColumnFamiliesOnDemandValue(), scan.getLoadColumnFamiliesOnDemandValue());
assertEquals(get.getMaxResultsPerColumnFamily(), scan.getMaxResultsPerColumnFamily());
assertEquals(get.getMaxVersions(), scan.getMaxVersions());
assertEquals(get.getRowOffsetPerColumnFamily(), scan.getRowOffsetPerColumnFamily());

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

assertTrue(get.getTimeRange().equals(copyGet.getTimeRange()));
assertEquals(get.getMaxVersions(), copyGet.getMaxVersions());
assertEquals(get.getMaxResultsPerColumnFamily(), copyGet.getMaxResultsPerColumnFamily());
assertEquals(get.getRowOffsetPerColumnFamily(), copyGet.getRowOffsetPerColumnFamily());
assertEquals(get.getCacheBlocks(), copyGet.getCacheBlocks());

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

this.storeLimit = get.getMaxResultsPerColumnFamily();
this.storeOffset = get.getRowOffsetPerColumnFamily();
this.tr = get.getTimeRange();

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

this.cacheBlocks = get.getCacheBlocks();
this.maxVersions = get.getMaxVersions();
this.storeLimit = get.getMaxResultsPerColumnFamily();
this.storeOffset = get.getRowOffsetPerColumnFamily();
this.tr = get.getTimeRange();

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

if (get.getMaxResultsPerColumnFamily() >= 0) {
 builder.setStoreLimit(get.getMaxResultsPerColumnFamily());

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

if (get.getMaxResultsPerColumnFamily() >= 0) {
 builder.setStoreLimit(get.getMaxResultsPerColumnFamily());

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

assertEquals(get.getIsolationLevel(), scan.getIsolationLevel());
assertEquals(get.getLoadColumnFamiliesOnDemandValue(), scan.getLoadColumnFamiliesOnDemandValue());
assertEquals(get.getMaxResultsPerColumnFamily(), scan.getMaxResultsPerColumnFamily());
assertEquals(get.getMaxVersions(), scan.getMaxVersions());
assertEquals(get.getRowOffsetPerColumnFamily(), scan.getRowOffsetPerColumnFamily());

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

assertTrue(get.getTimeRange().equals(copyGet.getTimeRange()));
assertEquals(get.getMaxVersions(), copyGet.getMaxVersions());
assertEquals(get.getMaxResultsPerColumnFamily(), copyGet.getMaxResultsPerColumnFamily());
assertEquals(get.getRowOffsetPerColumnFamily(), copyGet.getRowOffsetPerColumnFamily());
assertEquals(get.getCacheBlocks(), copyGet.getCacheBlocks());

代码示例来源:origin: rayokota/hgraphdb

List<Cell> kvs = new ArrayList<>();
Filter filter = get.getFilter();
int maxResults = get.getMaxResultsPerColumnFamily();

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

/**
 * Builds a scan object with the same specs as get.
 * @param get get to model scan after
 */
public Scan(Get get) {
 this.startRow = get.getRow();
 this.stopRow = get.getRow();
 this.filter = get.getFilter();
 this.cacheBlocks = get.getCacheBlocks();
 this.maxVersions = get.getMaxVersions();
 this.storeLimit = get.getMaxResultsPerColumnFamily();
 this.storeOffset = get.getRowOffsetPerColumnFamily();
 this.tr = get.getTimeRange();
 this.familyMap = get.getFamilyMap();
 this.getScan = true;
 this.consistency = get.getConsistency();
 this.setIsolationLevel(get.getIsolationLevel());
 for (Map.Entry<String, byte[]> attr : get.getAttributesMap().entrySet()) {
  setAttribute(attr.getKey(), attr.getValue());
 }
 for (Map.Entry<byte[], TimeRange> entry : get.getColumnFamilyTimeRange().entrySet()) {
  TimeRange tr = entry.getValue();
  setColumnFamilyTimeRange(entry.getKey(), tr.getMin(), tr.getMax());
 }
}

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

this.storeLimit = get.getMaxResultsPerColumnFamily();
this.storeOffset = get.getRowOffsetPerColumnFamily();
this.tr = get.getTimeRange();

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

this.storeLimit = get.getMaxResultsPerColumnFamily();
this.storeOffset = get.getRowOffsetPerColumnFamily();
this.tr = get.getTimeRange();

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

/**
 * Builds a scan object with the same specs as get.
 * @param get get to model scan after
 */
public Scan(Get get) {
 this.startRow = get.getRow();
 this.includeStartRow = true;
 this.stopRow = get.getRow();
 this.includeStopRow = true;
 this.filter = get.getFilter();
 this.cacheBlocks = get.getCacheBlocks();
 this.maxVersions = get.getMaxVersions();
 this.storeLimit = get.getMaxResultsPerColumnFamily();
 this.storeOffset = get.getRowOffsetPerColumnFamily();
 this.tr = get.getTimeRange();
 this.familyMap = get.getFamilyMap();
 this.asyncPrefetch = false;
 this.consistency = get.getConsistency();
 this.setIsolationLevel(get.getIsolationLevel());
 this.loadColumnFamiliesOnDemand = get.getLoadColumnFamiliesOnDemandValue();
 for (Map.Entry<String, byte[]> attr : get.getAttributesMap().entrySet()) {
  setAttribute(attr.getKey(), attr.getValue());
 }
 for (Map.Entry<byte[], TimeRange> entry : get.getColumnFamilyTimeRange().entrySet()) {
  TimeRange tr = entry.getValue();
  setColumnFamilyTimeRange(entry.getKey(), tr.getMin(), tr.getMax());
 }
 this.mvccReadPoint = -1L;
 setPriority(get.getPriority());
}

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

if (get.getMaxResultsPerColumnFamily() >= 0) {
 builder.setStoreLimit(get.getMaxResultsPerColumnFamily());

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

if (get.getMaxResultsPerColumnFamily() >= 0) {
 builder.setStoreLimit(get.getMaxResultsPerColumnFamily());

相关文章