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

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

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

Get.getCacheBlocks介绍

[英]Get whether blocks should be cached for this Get.
[中]获取是否应为此Get缓存块。

代码示例

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

this.setConsistency(get.getConsistency());
this.cacheBlocks = get.getCacheBlocks();
this.maxVersions = get.getMaxVersions();
this.storeLimit = get.getMaxResultsPerColumnFamily();

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

this.includeStopRow = true;
this.filter = get.getFilter();
this.cacheBlocks = get.getCacheBlocks();
this.maxVersions = get.getMaxVersions();
this.storeLimit = get.getMaxResultsPerColumnFamily();

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

out.setCacheBlocks(in.getCacheBlocks());
out.setStoreLimit(in.getMaxResultsPerColumnFamily());
out.setStoreOffset(in.getRowOffsetPerColumnFamily());

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

ClientProtos.Get.newBuilder();
builder.setRow(ByteStringer.wrap(get.getRow()));
builder.setCacheBlocks(get.getCacheBlocks());
builder.setMaxVersions(get.getMaxVersions());
if (get.getFilter() != null) {

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

ClientProtos.Get.newBuilder();
builder.setRow(UnsafeByteOperations.unsafeWrap(get.getRow()));
builder.setCacheBlocks(get.getCacheBlocks());
builder.setMaxVersions(get.getMaxVersions());
if (get.getFilter() != null) {

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

assertEquals(get.getCacheBlocks(), scan.getCacheBlocks());
assertEquals(get.getConsistency(), scan.getConsistency());
assertEquals(get.getFilter(), scan.getFilter());

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

assertEquals(get.getMaxResultsPerColumnFamily(), copyGet.getMaxResultsPerColumnFamily());
assertEquals(get.getRowOffsetPerColumnFamily(), copyGet.getRowOffsetPerColumnFamily());
assertEquals(get.getCacheBlocks(), copyGet.getCacheBlocks());
assertEquals(get.getId(), copyGet.getId());

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

this.setConsistency(get.getConsistency());
this.cacheBlocks = get.getCacheBlocks();
this.maxVersions = get.getMaxVersions();
this.storeLimit = get.getMaxResultsPerColumnFamily();

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

this.includeStopRow = true;
this.filter = get.getFilter();
this.cacheBlocks = get.getCacheBlocks();
this.maxVersions = get.getMaxVersions();
this.storeLimit = get.getMaxResultsPerColumnFamily();

代码示例来源:origin: XiaoMi/themis

@Override
public boolean getCacheBlocks() {
 return get.getCacheBlocks();
}

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

ClientProtos.Get.newBuilder();
builder.setRow(ByteStringer.wrap(get.getRow()));
builder.setCacheBlocks(get.getCacheBlocks());
builder.setMaxVersions(get.getMaxVersions());
if (get.getFilter() != null) {

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

ClientProtos.Get.newBuilder();
builder.setRow(UnsafeByteOperations.unsafeWrap(get.getRow()));
builder.setCacheBlocks(get.getCacheBlocks());
builder.setMaxVersions(get.getMaxVersions());
if (get.getFilter() != null) {

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

assertEquals(get.getCacheBlocks(), scan.getCacheBlocks());
assertEquals(get.getConsistency(), scan.getConsistency());
assertEquals(get.getFilter(), scan.getFilter());

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

assertEquals(get.getMaxResultsPerColumnFamily(), copyGet.getMaxResultsPerColumnFamily());
assertEquals(get.getRowOffsetPerColumnFamily(), copyGet.getRowOffsetPerColumnFamily());
assertEquals(get.getCacheBlocks(), copyGet.getCacheBlocks());
assertEquals(get.getId(), copyGet.getId());

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

/**
 * 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.tr = get.getTimeRange();
 this.familyMap = get.getFamilyMap();
}

代码示例来源: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.setConsistency(get.getConsistency());
this.cacheBlocks = get.getCacheBlocks();
this.maxVersions = get.getMaxVersions();
this.storeLimit = get.getMaxResultsPerColumnFamily();

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

this.setConsistency(get.getConsistency());
this.cacheBlocks = get.getCacheBlocks();
this.maxVersions = get.getMaxVersions();
this.storeLimit = get.getMaxResultsPerColumnFamily();

代码示例来源: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.moz.fiji.schema/fiji-schema

/**
 * Constructs an HBase Scan that describes the data requested in the FijiDataRequest.
 *
 * @param tableLayout The layout of the Fiji table to read from.  This is required for
 *     determining the mapping between Fiji columns and HBase columns.
 * @param scanOptions Custom options for this scan.
 * @return An HBase Scan descriptor.
 * @throws IOException If there is an error.
 */
public Scan toScan(
  final FijiTableLayout tableLayout,
  final HBaseScanOptions scanOptions
) throws IOException {
 // Unfortunately in HBase 95+, we can no longer create empty gets.
 // So create a fake one for this table and fill in the fields of a new scan.
 final Get tempGet = toGet(HBaseEntityId.fromHBaseRowKey(new byte[1]), tableLayout);
 final Scan scan = new Scan();
 scan.setFilter(tempGet.getFilter());
 scan.setCacheBlocks(tempGet.getCacheBlocks());
 scan.setMaxVersions(tempGet.getMaxVersions());
 scan.setTimeRange(tempGet.getTimeRange().getMin(), tempGet.getTimeRange().getMax());
 scan.setFamilyMap(tempGet.getFamilyMap());
 configureScan(scan, scanOptions);
 return scan;
}

相关文章