Package | Description |
---|---|
org.apache.flink.fs.s3.common.utils | |
org.apache.flink.fs.s3.common.writer | |
org.apache.flink.util.function |
Modifier and Type | Class and Description |
---|---|
class |
RefCountedTmpFileCreator
A utility class that creates local
reference counted files that serve as temporary files. |
Modifier and Type | Method and Description |
---|---|
static RefCountedBufferingFileStream |
RefCountedBufferingFileStream.openNew(FunctionWithException<File,RefCountedFile,IOException> tmpFileProvider) |
static RefCountedBufferingFileStream |
RefCountedBufferingFileStream.restore(FunctionWithException<File,RefCountedFile,IOException> tmpFileProvider,
File initialTmpFile) |
Modifier and Type | Method and Description |
---|---|
static S3RecoverableFsDataOutputStream |
S3RecoverableFsDataOutputStream.newStream(org.apache.flink.fs.s3.common.writer.RecoverableMultiPartUpload upload,
FunctionWithException<File,RefCountedFile,IOException> tmpFileCreator,
long userDefinedMinPartSize) |
static S3RecoverableFsDataOutputStream |
S3RecoverableFsDataOutputStream.recoverStream(org.apache.flink.fs.s3.common.writer.RecoverableMultiPartUpload upload,
FunctionWithException<File,RefCountedFile,IOException> tmpFileCreator,
long userDefinedMinPartSize,
long bytesBeforeCurrentPart) |
static S3RecoverableWriter |
S3RecoverableWriter.writer(org.apache.hadoop.fs.FileSystem fs,
FunctionWithException<File,RefCountedFile,IOException> tempFileCreator,
S3AccessHelper s3AccessHelper,
Executor uploadThreadPool,
long userDefinedMinPartSize,
int maxConcurrentUploadsPerStream) |
Modifier and Type | Method and Description |
---|---|
static <A,B> java.util.function.Function<A,B> |
FunctionUtils.uncheckedFunction(FunctionWithException<A,B,?> functionWithException)
Convert at
FunctionWithException into a Function . |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.