Java 类org.apache.hadoop.fs.s3a.S3AFileSystem 实例源码

@Before
public void setup() throws Exception {
  super.setup();
  String key = String.format(AbstractBondedFSContract.FSNAME_OPTION, "s3a");
  Configuration conf = createConfiguration();
  String fsVal = conf.getTrimmed(key);
  assertFalse("No FS set in " + key, StringUtils.isEmpty(fsVal));
  URI fsURI = new URI(fsVal);
  assertEquals("Not an S3A Filesystem: " + fsURI,
      "s3a", fsURI.getScheme());
  fileSystem = (S3AFileSystem) FileSystem.get(fsURI, conf);
  root = new Path(getFileSystem().getUri());
}

@Override
public S3AFileSystem getFileSystem() {
  return fileSystem;
}