Java 类org.apache.hadoop.fs.s3.S3FileSystem 实例源码

项目：incubator-tajo 文件：TestFileSystems.java

public TestFileSystems(FileSystem fs) throws IOException {
  conf = new TajoConf();

  if(fs instanceof S3FileSystem){
    conf.set(DFSConfigKeys.DFS_BLOCK_SIZE_KEY, "10");
    fs.initialize(URI.create(fs.getScheme() + ":///"), conf);
  }
  this.fs = fs;
  sm = StorageManagerFactory.getStorageManager(conf);
  testDir = getTestDir(this.fs, TEST_PATH);
}

项目：tajo-cdh 文件：TestFileSystems.java

public TestFileSystems(FileSystem fs) throws IOException {
  conf = new TajoConf();

  if(fs instanceof S3FileSystem){
    conf.set(DFSConfigKeys.DFS_BLOCK_SIZE_KEY, "10");
    fs.initialize(URI.create(fs.getScheme() + ":///"), conf);
  }
  this.fs = fs;
  sm = StorageManagerFactory.getStorageManager(conf);
  testDir = getTestDir(this.fs, TEST_PATH);
}

项目：dfs-datastores 文件：Pail.java

@Override
protected boolean isS3Root() {
    return _fs instanceof NativeS3FileSystem || _fs instanceof S3FileSystem;
}