Java源码示例:org.apache.hadoop.fs.s3.S3FileSystem
示例1public 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);
}