Modifier and Type | Method and Description |
---|---|
static <IN,OUT,E extends Throwable> |
ConfigUtils.decodeListFromConfig(ReadableConfig configuration,
ConfigOption<List<IN>> key,
FunctionWithException<IN,OUT,E> mapper)
Gets a
List of values of type IN from a ReadableConfig and transforms
it to a List of type OUT based on the provided mapper 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,RefCountedFileWithStream,IOException> tmpFileProvider) |
static RefCountedBufferingFileStream |
RefCountedBufferingFileStream.restore(FunctionWithException<File,RefCountedFileWithStream,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,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) |
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.
|
SourceOperator(FunctionWithException<SourceReaderContext,SourceReader<OUT,SplitT>,Exception> readerFactory,
OperatorEventGateway operatorEventGateway,
SimpleVersionedSerializer<SplitT> splitSerializer,
WatermarkStrategy<OUT> watermarkStrategy,
ProcessingTimeService timeService,
Configuration configuration,
String localHostname,
boolean emitProgressiveWatermarks) |
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–2022 The Apache Software Foundation. All rights reserved.