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

HStore.getComparator介绍

暂无

代码示例

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

@Override
 public StripeMultiFileWriter createWriter(InternalScanner scanner, FileDetails fd,
   boolean shouldDropBehind) throws IOException {
  StripeMultiFileWriter writer = new StripeMultiFileWriter.BoundaryMultiWriter(
    store.getComparator(), targetBoundaries, majorRangeFromRow, majorRangeToRow);
  initMultiWriter(writer, scanner, fd, shouldDropBehind);
  return writer;
 }
}, throughputController, user);

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

@Override
 public StripeMultiFileWriter createWriter(InternalScanner scanner, FileDetails fd,
   boolean shouldDropBehind) throws IOException {
  StripeMultiFileWriter writer = new StripeMultiFileWriter.SizeMultiWriter(
    store.getComparator(), targetCount, targetSize, left, right);
  initMultiWriter(writer, scanner, fd, shouldDropBehind);
  return writer;
 }
}, throughputController, user);

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

resetKVHeap(this.currentScanners, store.getComparator());
resetQueryMatcher(lastTop);
if (heap.peek() == null || store.getComparator().compareRows(lastTop, this.heap.peek()) != 0) {
 LOG.info("Storescanner.peek() is changed where before = " + lastTop.toString() +
   ",and after = " + heap.peek());

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

when(store.createWriterInTmp(anyLong(), any(), anyBoolean(),
 anyBoolean(), anyBoolean(), anyBoolean())).thenAnswer(writers);
when(store.getComparator()).thenReturn(CellComparatorImpl.COMPARATOR);

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

StripeFlushRequest req = this.policy.selectFlush(store.getComparator(), this.stripes,
 cellsCount);

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

when(store.createWriterInTmp(anyLong(), any(), anyBoolean(),
 anyBoolean(), anyBoolean(), anyBoolean())).thenAnswer(writers);
when(store.getComparator()).thenReturn(CellComparatorImpl.COMPARATOR);
OptionalLong maxSequenceId = StoreUtils.getMaxSequenceIdInList(storefiles);
when(store.getMaxSequenceId()).thenReturn(maxSequenceId);

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

/**
 * Do a specific Get on passed <code>columnFamily</code> and column qualifiers.
 * @param mutation Mutation we are doing this Get for.
 * @param store Which column family on row (TODO: Go all Gets in one go)
 * @param coordinates Cells from <code>mutation</code> used as coordinates applied to Get.
 * @return Return list of Cells found.
 */
private List<Cell> get(Mutation mutation, HStore store, List<Cell> coordinates,
  IsolationLevel isolation, TimeRange tr) throws IOException {
 // Sort the cells so that they match the order that they appear in the Get results. Otherwise,
 // we won't be able to find the existing values if the cells are not specified in order by the
 // client since cells are in an array list.
 // TODO: I don't get why we are sorting. St.Ack 20150107
 sort(coordinates, store.getComparator());
 Get get = new Get(mutation.getRow());
 if (isolation != null) {
  get.setIsolationLevel(isolation);
 }
 for (Cell cell: coordinates) {
  get.addColumn(store.getColumnFamilyDescriptor().getName(), CellUtil.cloneQualifier(cell));
 }
 // Increments carry time range. If an Increment instance, put it on the Get.
 if (tr != null) {
  get.setTimeRange(tr.getMin(), tr.getMax());
 }
 return get(get, false);
}

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

when(store.createWriterInTmp(anyLong(), any(), anyBoolean(),
 anyBoolean(), anyBoolean(), anyBoolean())).thenAnswer(writers);
when(store.getComparator()).thenReturn(CellComparatorImpl.COMPARATOR);

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

when(store.createWriterInTmp(anyLong(), any(), anyBoolean(),
 anyBoolean(), anyBoolean(), anyBoolean())).thenAnswer(writers);
when(store.getComparator()).thenReturn(CellComparatorImpl.COMPARATOR);
OptionalLong maxSequenceId = StoreUtils.getMaxSequenceIdInList(storefiles);
when(store.getMaxSequenceId()).thenReturn(maxSequenceId);