Package | Description |
---|---|
org.apache.flink.core.fs | |
org.apache.flink.fs.osshadoop.writer | |
org.apache.flink.fs.s3.common.writer |
Modifier and Type | Method and Description |
---|---|
RefCountedFileWithStream |
RefCountedTmpFileCreator.apply(File file)
Gets the next temp file and stream to temp file.
|
static RefCountedFileWithStream |
RefCountedFileWithStream.newFile(File file,
OutputStream currentOut) |
static RefCountedFileWithStream |
RefCountedFileWithStream.restoredFile(File file,
OutputStream currentOut,
long bytesInCurrentPart) |
Modifier and Type | Method and Description |
---|---|
static RefCountedBufferingFileStream |
RefCountedBufferingFileStream.openNew(FunctionWithException<File,RefCountedFileWithStream,IOException> tmpFileProvider) |
static RefCountedBufferingFileStream |
RefCountedBufferingFileStream.restore(FunctionWithException<File,RefCountedFileWithStream,IOException> tmpFileProvider,
File initialTmpFile) |
Constructor and Description |
---|
RefCountedBufferingFileStream(RefCountedFileWithStream file,
int bufferSize) |
Constructor and Description |
---|
OSSRecoverableFsDataOutputStream(long ossUploadPartSize,
FunctionWithException<File,RefCountedFileWithStream,IOException> cachedFileCreator,
OSSRecoverableMultipartUpload upload,
long sizeBeforeCurrentPart) |
OSSRecoverableWriter(OSSAccessor ossAccessor,
long ossUploadPartSize,
int streamConcurrentUploads,
Executor executor,
FunctionWithException<File,RefCountedFileWithStream,IOException> cachedFileCreator) |
Modifier and Type | Method and Description |
---|---|
static S3RecoverableFsDataOutputStream |
S3RecoverableFsDataOutputStream.newStream(org.apache.flink.fs.s3.common.writer.RecoverableMultiPartUpload upload,
FunctionWithException<File,RefCountedFileWithStream,IOException> tmpFileCreator,
long userDefinedMinPartSize) |
static S3RecoverableFsDataOutputStream |
S3RecoverableFsDataOutputStream.recoverStream(org.apache.flink.fs.s3.common.writer.RecoverableMultiPartUpload upload,
FunctionWithException<File,RefCountedFileWithStream,IOException> tmpFileCreator,
long userDefinedMinPartSize,
long bytesBeforeCurrentPart) |
static S3RecoverableWriter |
S3RecoverableWriter.writer(org.apache.hadoop.fs.FileSystem fs,
FunctionWithException<File,RefCountedFileWithStream,IOException> tempFileCreator,
S3AccessHelper s3AccessHelper,
Executor uploadThreadPool,
long userDefinedMinPartSize,
int maxConcurrentUploadsPerStream) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.