Package | Description |
---|---|
org.apache.flink.fs.s3.common.writer |
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) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.