Package | Description |
---|---|
org.apache.flink.fs.s3.common | |
org.apache.flink.fs.s3.common.writer | |
org.apache.flink.fs.s3hadoop | |
org.apache.flink.fs.s3presto |
Modifier and Type | Method and Description |
---|---|
protected abstract S3AccessHelper |
AbstractS3FileSystemFactory.getS3AccessHelper(org.apache.hadoop.fs.FileSystem fs) |
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.
|
Modifier and Type | Method and Description |
---|---|
static S3RecoverableWriter |
S3RecoverableWriter.writer(org.apache.hadoop.fs.FileSystem fs,
FunctionWithException<File,RefCountedFileWithStream,IOException> tempFileCreator,
S3AccessHelper s3AccessHelper,
Executor uploadThreadPool,
long userDefinedMinPartSize,
int maxConcurrentUploadsPerStream) |
Modifier and Type | Class and Description |
---|---|
class |
HadoopS3AccessHelper
An implementation of the
S3AccessHelper for the Hadoop S3A filesystem. |
Modifier and Type | Method and Description |
---|---|
protected S3AccessHelper |
S3FileSystemFactory.getS3AccessHelper(org.apache.hadoop.fs.FileSystem fs) |
Modifier and Type | Method and Description |
---|---|
protected S3AccessHelper |
S3FileSystemFactory.getS3AccessHelper(org.apache.hadoop.fs.FileSystem fs) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.