Java 类org.apache.hadoop.hbase.regionserver.StoreFile.Writer 实例源码

private StripeMultiFileWriter.WriterFactory createWriterFactory(final TimeRangeTracker tracker,
    final long kvCount) {
  return new StripeMultiFileWriter.WriterFactory() {
    @Override
    public Writer createWriter() throws IOException {
      StoreFile.Writer writer =
          store.createWriterInTmp(kvCount, store.getFamily().getCompression(),
          /* isCompaction = */false,
          /* includeMVCCReadpoint = */true,
          /* includesTags = */true,
          /* shouldDropBehind = */false);
      writer.setTimeRangeTracker(tracker);
      return writer;
    }
  };
}

private StripeMultiFileWriter.WriterFactory createWriterFactory(
    final TimeRangeTracker tracker, final long kvCount) {
  return new StripeMultiFileWriter.WriterFactory() {
    @Override
    public Writer createWriter() throws IOException {
      StoreFile.Writer writer = store.createWriterInTmp(
          kvCount, store.getFamily().getCompression(), false, true, true);
      writer.setTimeRangeTracker(tracker);
      return writer;
    }
  };
}

private StripeMultiFileWriter.WriterFactory createWriterFactory(
    final TimeRangeTracker tracker, final long kvCount) {
  return new StripeMultiFileWriter.WriterFactory() {
    @Override
    public Writer createWriter() throws IOException {
      StoreFile.Writer writer = store.createWriterInTmp(
          kvCount, store.getFamily().getCompression(), false, true, true);
      writer.setTimeRangeTracker(tracker);
      return writer;
    }
  };
}

private StripeMultiFileWriter.WriterFactory createWriterFactory(
    final TimeRangeTracker tracker, final long kvCount) {
  return new StripeMultiFileWriter.WriterFactory() {
    @Override
    public Writer createWriter() throws IOException {
      StoreFile.Writer writer = store.createWriterInTmp(
          kvCount, store.getFamily().getCompression(), false, true, true);
      writer.setTimeRangeTracker(tracker);
      return writer;
    }
  };
}