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 |
---|---|
ResultPartition |
ResultPartitionFactory.create(String taskNameWithSubtaskAndId,
ResultPartitionID id,
ResultPartitionType type,
int numberOfSubpartitions,
int maxParallelism,
FunctionWithException<BufferPoolOwner,BufferPool,IOException> bufferPoolFactory) |
Constructor and Description |
---|
ResultPartition(String owningTaskName,
ResultPartitionID partitionId,
ResultPartitionType partitionType,
ResultSubpartition[] subpartitions,
int numTargetKeyGroups,
ResultPartitionManager partitionManager,
FunctionWithException<BufferPoolOwner,BufferPool,IOException> bufferPoolFactory) |
Constructor and Description |
---|
BackendRestorerProcedure(FunctionWithException<Collection<S>,T,Exception> instanceSupplier,
CloseableRegistry backendCloseableRegistry,
String logDescription)
Creates a new backend restorer using the given backend supplier and the closeable registry.
|
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.