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

下面列出了怎么用org.apache.hadoop.fs.s3a.S3AFileSystem的API类实例代码及写法,或者点击链接到github查看源代码。

源代码1 项目: Flink-CEPplus   文件: HadoopS3AccessHelper.java
public HadoopS3AccessHelper(S3AFileSystem s3a, Configuration conf) {
	this.s3accessHelper = new InternalWriteOperationHelper(
			checkNotNull(s3a),
			checkNotNull(conf)
	);
	this.s3a = s3a;
}
 
源代码2 项目: flink   文件: HadoopS3AccessHelper.java
public HadoopS3AccessHelper(S3AFileSystem s3a, Configuration conf) {
	this.s3accessHelper = new InternalWriteOperationHelper(
			checkNotNull(s3a),
			checkNotNull(conf)
	);
	this.s3a = s3a;
}
 
源代码3 项目: flink   文件: HadoopS3AccessHelper.java
public HadoopS3AccessHelper(S3AFileSystem s3a, Configuration conf) {
	this.s3accessHelper = new InternalWriteOperationHelper(
			checkNotNull(s3a),
			checkNotNull(conf)
	);
	this.s3a = s3a;
}
 
源代码4 项目: Flink-CEPplus   文件: HadoopS3AccessHelper.java
InternalWriteOperationHelper(S3AFileSystem owner, Configuration conf) {
	super(owner, conf);
}
 
源代码5 项目: Flink-CEPplus   文件: S3FileSystemFactory.java
@Override
protected org.apache.hadoop.fs.FileSystem createHadoopFileSystem() {
	return new S3AFileSystem();
}
 
源代码6 项目: Flink-CEPplus   文件: S3FileSystemFactory.java
@Nullable
@Override
protected S3AccessHelper getS3AccessHelper(FileSystem fs) {
	final S3AFileSystem s3Afs = (S3AFileSystem) fs;
	return new HadoopS3AccessHelper(s3Afs, s3Afs.getConf());
}
 
源代码7 项目: flink   文件: HadoopS3AccessHelper.java
InternalWriteOperationHelper(S3AFileSystem owner, Configuration conf) {
	super(owner, conf);
}
 
源代码8 项目: flink   文件: S3FileSystemFactory.java
@Override
protected org.apache.hadoop.fs.FileSystem createHadoopFileSystem() {
	return new S3AFileSystem();
}
 
源代码9 项目: flink   文件: S3FileSystemFactory.java
@Nullable
@Override
protected S3AccessHelper getS3AccessHelper(FileSystem fs) {
	final S3AFileSystem s3Afs = (S3AFileSystem) fs;
	return new HadoopS3AccessHelper(s3Afs, s3Afs.getConf());
}
 
源代码10 项目: flink   文件: HadoopS3AccessHelper.java
InternalWriteOperationHelper(S3AFileSystem owner, Configuration conf) {
	super(owner, conf);
}
 
源代码11 项目: flink   文件: S3FileSystemFactory.java
@Override
protected org.apache.hadoop.fs.FileSystem createHadoopFileSystem() {
	return new S3AFileSystem();
}
 
源代码12 项目: flink   文件: S3FileSystemFactory.java
@Nullable
@Override
protected S3AccessHelper getS3AccessHelper(FileSystem fs) {
	final S3AFileSystem s3Afs = (S3AFileSystem) fs;
	return new HadoopS3AccessHelper(s3Afs, s3Afs.getConf());
}
 
 类所在包
 同包方法