下面列出了怎么用org.apache.hadoop.fs.s3a.S3AFileSystem的API类实例代码及写法,或者点击链接到github查看源代码。
public HadoopS3AccessHelper(S3AFileSystem s3a, Configuration conf) {
this.s3accessHelper = new InternalWriteOperationHelper(
checkNotNull(s3a),
checkNotNull(conf)
);
this.s3a = s3a;
}
public HadoopS3AccessHelper(S3AFileSystem s3a, Configuration conf) {
this.s3accessHelper = new InternalWriteOperationHelper(
checkNotNull(s3a),
checkNotNull(conf)
);
this.s3a = s3a;
}
public HadoopS3AccessHelper(S3AFileSystem s3a, Configuration conf) {
this.s3accessHelper = new InternalWriteOperationHelper(
checkNotNull(s3a),
checkNotNull(conf)
);
this.s3a = s3a;
}
InternalWriteOperationHelper(S3AFileSystem owner, Configuration conf) {
super(owner, conf);
}
@Override
protected org.apache.hadoop.fs.FileSystem createHadoopFileSystem() {
return new S3AFileSystem();
}
@Nullable
@Override
protected S3AccessHelper getS3AccessHelper(FileSystem fs) {
final S3AFileSystem s3Afs = (S3AFileSystem) fs;
return new HadoopS3AccessHelper(s3Afs, s3Afs.getConf());
}
InternalWriteOperationHelper(S3AFileSystem owner, Configuration conf) {
super(owner, conf);
}
@Override
protected org.apache.hadoop.fs.FileSystem createHadoopFileSystem() {
return new S3AFileSystem();
}
@Nullable
@Override
protected S3AccessHelper getS3AccessHelper(FileSystem fs) {
final S3AFileSystem s3Afs = (S3AFileSystem) fs;
return new HadoopS3AccessHelper(s3Afs, s3Afs.getConf());
}
InternalWriteOperationHelper(S3AFileSystem owner, Configuration conf) {
super(owner, conf);
}
@Override
protected org.apache.hadoop.fs.FileSystem createHadoopFileSystem() {
return new S3AFileSystem();
}
@Nullable
@Override
protected S3AccessHelper getS3AccessHelper(FileSystem fs) {
final S3AFileSystem s3Afs = (S3AFileSystem) fs;
return new HadoopS3AccessHelper(s3Afs, s3Afs.getConf());
}