Package | Description |
---|---|
org.apache.flink.formats.hadoop.bulk | |
org.apache.flink.streaming.api.functions.sink.filesystem |
Modifier and Type | Method and Description |
---|---|
InProgressFileWriter.PendingFileRecoverable |
HadoopPathBasedPartFileWriter.closeForCommit() |
Modifier and Type | Method and Description |
---|---|
BucketWriter.PendingFile |
HadoopPathBasedPartFileWriter.HadoopPathBasedBucketWriter.recoverPendingFile(InProgressFileWriter.PendingFileRecoverable pendingFileRecoverable) |
Modifier and Type | Interface and Description |
---|---|
static interface |
InProgressFileWriter.InProgressFileRecoverable
A handle can be used to recover in-progress file..
|
Modifier and Type | Method and Description |
---|---|
InProgressFileWriter.PendingFileRecoverable |
OutputStreamBasedPartFileWriter.closeForCommit() |
InProgressFileWriter.PendingFileRecoverable |
InProgressFileWriter.closeForCommit() |
Modifier and Type | Method and Description |
---|---|
BucketWriter.PendingFile |
BucketWriter.recoverPendingFile(InProgressFileWriter.PendingFileRecoverable pendingFileRecoverable)
Recovers a pending file for finalizing and committing.
|
Constructor and Description |
---|
WriterProperties(SimpleVersionedSerializer<InProgressFileWriter.InProgressFileRecoverable> inProgressFileRecoverableSerializer,
SimpleVersionedSerializer<InProgressFileWriter.PendingFileRecoverable> pendingFileRecoverableSerializer,
boolean supportsResume) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.