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

Range.bound介绍

[英]Creates a new range that is bounded by the columns passed in. The start key in the returned range will have a column >= to the minimum column. The end key in the returned range will have a column <= the max column.
[中]创建一个以传入的列为边界的新范围。返回范围内的开始键将有一列>=至最小列。返回范围中的结束键将有一列<=最大列。

代码示例

代码示例来源：origin: apache/accumulo

ArrayList<Range> ranges2 = new ArrayList<>(ranges.size());
for (Range range : ranges) {
 ranges2.add(range.bound(options.fetchedColumns.first(), options.fetchedColumns.last()));

代码示例来源：origin: apache/accumulo

ScannerIterator(ClientContext context, Table.ID tableId, Authorizations authorizations,
  Range range, int size, long timeOut, ScannerOptions options, boolean isolated,
  long readaheadThreshold, ScannerImpl.Reporter reporter) {
 this.timeOut = timeOut;
 this.readaheadThreshold = readaheadThreshold;
 this.options = new ScannerOptions(options);
 this.reporter = reporter;
 if (this.options.fetchedColumns.size() > 0) {
  range = range.bound(this.options.fetchedColumns.first(), this.options.fetchedColumns.last());
 }
 scanState = new ScanState(context, tableId, authorizations, new Range(range),
   options.fetchedColumns, size, options.serverSideIteratorList,
   options.serverSideIteratorOptions, isolated, readaheadThreshold,
   options.getSamplerConfiguration(), options.batchTimeOut, options.classLoaderContext,
   options.executionHints);
 // If we want to start readahead immediately, don't wait for hasNext to be called
 if (readaheadThreshold == 0L) {
  initiateReadAhead();
 }
 iter = null;
}

代码示例来源：origin: apache/accumulo

public OfflineIterator(ScannerOptions options, ClientContext context,
  Authorizations authorizations, Text table, Range range) {
 this.options = new ScannerOptions(options);
 this.context = context;
 this.range = range;
 if (this.options.fetchedColumns.size() > 0) {
  this.range = range.bound(this.options.fetchedColumns.first(),
    this.options.fetchedColumns.last());
 }
 this.tableId = Table.ID.of(table.toString());
 this.authorizations = authorizations;
 this.readers = new ArrayList<>();
 try {
  config = new ConfigurationCopy(context.instanceOperations().getSiteConfiguration());
  nextTablet();
  while (iter != null && !iter.hasTop())
   nextTablet();
 } catch (Exception e) {
  if (e instanceof RuntimeException)
   throw (RuntimeException) e;
  throw new RuntimeException(e);
 }
}

代码示例来源：origin: org.apache.accumulo/accumulo-core

ArrayList<Range> ranges2 = new ArrayList<>(ranges.size());
for (Range range : ranges) {
 ranges2.add(range.bound(options.fetchedColumns.first(), options.fetchedColumns.last()));

代码示例来源：origin: org.apache.accumulo/accumulo-core

ScannerIterator(ClientContext context, String tableId, Authorizations authorizations, Range range,
  int size, int timeOut, ScannerOptions options, boolean isolated, long readaheadThreshold) {
 this.timeOut = timeOut;
 this.readaheadThreshold = readaheadThreshold;
 this.options = new ScannerOptions(options);
 synchQ = new ArrayBlockingQueue<>(1);
 if (this.options.fetchedColumns.size() > 0) {
  range = range.bound(this.options.fetchedColumns.first(), this.options.fetchedColumns.last());
 }
 scanState = new ScanState(context, tableId, authorizations, new Range(range),
   options.fetchedColumns, size, options.serverSideIteratorList,
   options.serverSideIteratorOptions, isolated, readaheadThreshold,
   options.getSamplerConfiguration(), options.batchTimeOut, options.classLoaderContext);
 // If we want to start readahead immediately, don't wait for hasNext to be called
 if (0l == readaheadThreshold) {
  initiateReadAhead();
 }
 iter = null;
}

代码示例来源：origin: org.apache.accumulo/accumulo-core

public OfflineIterator(ScannerOptions options, Instance instance, Credentials credentials,
  Authorizations authorizations, Text table, Range range) {
 this.options = new ScannerOptions(options);
 this.instance = instance;
 this.range = range;
 if (this.options.fetchedColumns.size() > 0) {
  this.range = range.bound(this.options.fetchedColumns.first(),
    this.options.fetchedColumns.last());
 }
 this.tableId = table.toString();
 this.authorizations = authorizations;
 this.readers = new ArrayList<>();
 try {
  conn = instance.getConnector(credentials.getPrincipal(), credentials.getToken());
  config = new ConfigurationCopy(conn.instanceOperations().getSiteConfiguration());
  nextTablet();
  while (iter != null && !iter.hasTop())
   nextTablet();
 } catch (Exception e) {
  if (e instanceof RuntimeException)
   throw (RuntimeException) e;
  throw new RuntimeException(e);
 }
}

代码示例来源：origin: org.apache.rya/accumulo.rya

rangeMapRange = range.bound(new Column(contextBytes, new byte[] { (byte) 0x00 }, new byte[] { (byte) 0x00 }),
    new Column(contextBytes, new byte[] { (byte) 0xff }, new byte[] { (byte) 0xff }));

代码示例来源：origin: apache/incubator-rya

rangeMapRange = range.bound(new Column(contextBytes, new byte[] { (byte) 0x00 }, new byte[] { (byte) 0x00 }),
    new Column(contextBytes, new byte[] { (byte) 0xff }, new byte[] { (byte) 0xff }));