Uses of Interface
org.apache.flink.fs.s3.common.writer.S3AccessHelper

Packages that use S3AccessHelper

Package	Description
org.apache.flink.fs.s3.common
org.apache.flink.fs.s3.common.writer

Uses of S3AccessHelper in org.apache.flink.fs.s3.common

Methods in org.apache.flink.fs.s3.common that return S3AccessHelper

Modifier and Type	Method and Description
protected abstract S3AccessHelper	AbstractS3FileSystemFactory.getS3AccessHelper(org.apache.hadoop.fs.FileSystem fs)

Constructors in org.apache.flink.fs.s3.common with parameters of type S3AccessHelper

Constructor and Description
FlinkS3FileSystem(org.apache.hadoop.fs.FileSystem hadoopS3FileSystem, String localTmpDirectory, String entropyInjectionKey, int entropyLength, S3AccessHelper s3UploadHelper, long s3uploadPartSize, int maxConcurrentUploadsPerStream) Creates a FlinkS3FileSystem based on the given Hadoop S3 file system.

Uses of S3AccessHelper in org.apache.flink.fs.s3.common.writer

Methods in org.apache.flink.fs.s3.common.writer with parameters of type S3AccessHelper

Modifier and Type	Method and Description
static S3RecoverableWriter	S3RecoverableWriter.writer(org.apache.hadoop.fs.FileSystem fs, org.apache.flink.util.function.FunctionWithException<File,RefCountedFile,IOException> tempFileCreator, S3AccessHelper s3AccessHelper, Executor uploadThreadPool, long userDefinedMinPartSize, int maxConcurrentUploadsPerStream)