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

HStore.getFileSystem介绍

暂无

代码示例

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

@Override
 protected void abortWriter(T writer) throws IOException {
  FileSystem fs = store.getFileSystem();
  for (Path leftoverFile : writer.abortWriters()) {
   try {
    fs.delete(leftoverFile, false);
   } catch (IOException e) {
    LOG.warn(
     "Failed to delete the leftover file " + leftoverFile + " after an unfinished compaction.",
     e);
   }
  }
 }
}

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

@Override
 protected void abortWriter(StoreFileWriter writer) throws IOException {
  Path leftoverFile = writer.getPath();
  try {
   writer.close();
  } catch (IOException e) {
   LOG.warn("Failed to close the writer after an unfinished compaction.", e);
  }
  try {
   store.getFileSystem().delete(leftoverFile, false);
  } catch (IOException e) {
   LOG.warn(
    "Failed to delete the leftover file " + leftoverFile + " after an unfinished compaction.",
    e);
  }
 }
}

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

public DefaultMobStoreFlusher(Configuration conf, HStore store) throws IOException {
 super(conf, store);
 if (!(store instanceof HMobStore)) {
  throw new IllegalArgumentException("The store " + store + " is not a HMobStore");
 }
 mobCellValueSizeThreshold = store.getColumnFamilyDescriptor().getMobThreshold();
 this.targetPath = MobUtils.getMobFamilyPath(conf, store.getTableName(),
   store.getColumnFamilyName());
 if (!this.store.getFileSystem().exists(targetPath)) {
  this.store.getFileSystem().mkdirs(targetPath);
 }
 this.mobStore = (HMobStore) store;
}

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

@VisibleForTesting
protected HStoreFile createStoreFileAndReader(final Path p) throws IOException {
 StoreFileInfo info = new StoreFileInfo(conf, this.getFileSystem(), p);
 return createStoreFileAndReader(info);
}

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

private HStoreFile createStoreFileAndReader(StoreFileInfo info) throws IOException {
 info.setRegionCoprocessorHost(this.region.getCoprocessorHost());
 HStoreFile storeFile = new HStoreFile(this.getFileSystem(), info, this.conf, this.cacheConf,
   this.family.getBloomFilterType(), isPrimaryReplicaStore());
 storeFile.initReader();
 return storeFile;
}

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

when(store.getScanInfo()).thenReturn(si);
when(store.areWritesEnabled()).thenReturn(true);
when(store.getFileSystem()).thenReturn(mock(FileSystem.class));
when(store.getRegionInfo()).thenReturn(new HRegionInfo(TABLE_NAME));
when(store.createWriterInTmp(anyLong(), any(), anyBoolean(),

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

for (Path leftoverFile : mw.abortWriters()) {
 try {
  store.getFileSystem().delete(leftoverFile, false);
 } catch (Exception e) {
  LOG.error("Failed to delete a file after failed flush: " + e);

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

when(store.getScanInfo()).thenReturn(si);
when(store.areWritesEnabled()).thenReturn(true);
when(store.getFileSystem()).thenReturn(mock(FileSystem.class));
when(store.getRegionInfo()).thenReturn(new HRegionInfo(TABLE_NAME));
when(store.createWriterInTmp(anyLong(), any(), anyBoolean(),

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

FileSystem fs = store.getFileSystem();

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

mobFileWriter.close();
 store.getFileSystem().delete(mobFileWriter.getPath(), true);
} catch (IOException e) {
 LOG.error("Failed to delete the temp mob file", e);

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

Path familyTempDir = new Path(fs.getTempDir(), family.getNameAsString());
StoreFileWriter.Builder builder = new StoreFileWriter.Builder(conf, writerCacheConf,
  this.getFileSystem())
    .withOutputDir(familyTempDir)
    .withComparator(comparator)

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

private StoreFile createStoreFileAndReader(final Path p) throws IOException {
 StoreFileInfo info = new StoreFileInfo(conf, this.getFileSystem(), p);
 return createStoreFileAndReader(info);
}

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

private StoreFile createStoreFileAndReader(final StoreFileInfo info)
  throws IOException {
 info.setRegionCoprocessorHost(this.region.getCoprocessorHost());
 StoreFile storeFile = new StoreFile(this.getFileSystem(), info, this.conf, this.cacheConf,
  this.family.getBloomFilterType());
 StoreFile.Reader r = storeFile.createReader();
 r.setReplicaStoreFile(isPrimaryReplicaStore());
 return storeFile;
}

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

when(store.getScanInfo()).thenReturn(si);
when(store.areWritesEnabled()).thenReturn(true);
when(store.getFileSystem()).thenReturn(mock(FileSystem.class));
when(store.getRegionInfo()).thenReturn(new HRegionInfo(TABLE_NAME));
when(store.createWriterInTmp(anyLong(), any(), anyBoolean(),

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

when(store.getScanInfo()).thenReturn(si);
when(store.areWritesEnabled()).thenReturn(true);
when(store.getFileSystem()).thenReturn(mock(FileSystem.class));
when(store.getRegionInfo()).thenReturn(new HRegionInfo(TABLE_NAME));
when(store.createWriterInTmp(anyLong(), any(), anyBoolean(),

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

FileSystem fs = store.getFileSystem();

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

cryptoContext);
StoreFile.Writer w = new StoreFile.WriterBuilder(conf, writerCacheConf,
  this.getFileSystem())
    .withFilePath(fs.createTempName())
    .withComparator(comparator)