Java 类org.apache.hadoop.fs.s3native.NativeS3FileSystem 实例源码

private boolean directWriteEnabled(JobConf conf) throws IOException {
    Path p;
    if((p = FileOutputFormat.getOutputPath(conf)) == null) {
        return false;
    } else {
        return p.getFileSystem(conf) instanceof NativeS3FileSystem;
    }
}

public IxS3FileSystem(NativeS3FileSystem fileSystem) {
    nativeFS = fileSystem;
}

public IxS3FileSystem() {
    nativeFS = new NativeS3FileSystem();
}

public S3NativeFS(URI theUri, Configuration conf) throws IOException, URISyntaxException {
    super(theUri, new NativeS3FileSystem(), conf, "s3n", false);
}

private boolean isDirectWrite(JobContext jc, Path outputPath) throws IOException {
    return outputPath.getFileSystem(jc.getConfiguration()) instanceof NativeS3FileSystem;
}

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