Uses of Interface
org.apache.flink.streaming.api.functions.sink.filesystem.InProgressFileWriter.InProgressFileRecoverable

Packages that use InProgressFileWriter.InProgressFileRecoverable

Package	Description
org.apache.flink.connector.file.sink
org.apache.flink.connector.file.sink.writer
org.apache.flink.formats.hadoop.bulk
org.apache.flink.streaming.api.functions.sink.filesystem

Uses of InProgressFileWriter.InProgressFileRecoverable in org.apache.flink.connector.file.sink

Methods in org.apache.flink.connector.file.sink that return InProgressFileWriter.InProgressFileRecoverable

Modifier and Type	Method and Description
InProgressFileWriter.InProgressFileRecoverable	FileSinkCommittable.getInProgressFileToCleanup()

Constructors in org.apache.flink.connector.file.sink with parameters of type InProgressFileWriter.InProgressFileRecoverable

Constructor and Description
FileSinkCommittable(String bucketId, InProgressFileWriter.InProgressFileRecoverable inProgressFileToCleanup)

Constructor parameters in org.apache.flink.connector.file.sink with type arguments of type InProgressFileWriter.InProgressFileRecoverable

Constructor and Description
FileSinkCommittableSerializer(SimpleVersionedSerializer<InProgressFileWriter.PendingFileRecoverable> pendingFileSerializer, SimpleVersionedSerializer<InProgressFileWriter.InProgressFileRecoverable> inProgressFileSerializer)

Uses of InProgressFileWriter.InProgressFileRecoverable in org.apache.flink.connector.file.sink.writer

Constructors in org.apache.flink.connector.file.sink.writer with parameters of type InProgressFileWriter.InProgressFileRecoverable

Constructor and Description
FileWriterBucketState(String bucketId, Path bucketPath, long inProgressFileCreationTime, InProgressFileWriter.InProgressFileRecoverable inProgressFileRecoverable)
FileWriterBucketState(String bucketId, Path bucketPath, long inProgressFileCreationTime, InProgressFileWriter.InProgressFileRecoverable inProgressFileRecoverable, Map<Long,List<InProgressFileWriter.PendingFileRecoverable>> pendingFileRecoverablesPerCheckpoint)

Constructor parameters in org.apache.flink.connector.file.sink.writer with type arguments of type InProgressFileWriter.InProgressFileRecoverable

Constructor and Description
FileWriterBucketStateSerializer(SimpleVersionedSerializer<InProgressFileWriter.InProgressFileRecoverable> inProgressFileRecoverableSerializer, SimpleVersionedSerializer<InProgressFileWriter.PendingFileRecoverable> pendingFileRecoverableSerializer)

Uses of InProgressFileWriter.InProgressFileRecoverable in org.apache.flink.formats.hadoop.bulk

Methods in org.apache.flink.formats.hadoop.bulk that return InProgressFileWriter.InProgressFileRecoverable

Modifier and Type	Method and Description
InProgressFileWriter.InProgressFileRecoverable	HadoopPathBasedPartFileWriter.persist()

Methods in org.apache.flink.formats.hadoop.bulk with parameters of type InProgressFileWriter.InProgressFileRecoverable

Modifier and Type	Method and Description
boolean	HadoopPathBasedPartFileWriter.HadoopPathBasedBucketWriter.cleanupInProgressFileRecoverable(InProgressFileWriter.InProgressFileRecoverable inProgressFileRecoverable)
InProgressFileWriter<IN,BucketID>	HadoopPathBasedPartFileWriter.HadoopPathBasedBucketWriter.resumeInProgressFileFrom(BucketID bucketID, InProgressFileWriter.InProgressFileRecoverable inProgressFileSnapshot, long creationTime)

Uses of InProgressFileWriter.InProgressFileRecoverable in org.apache.flink.streaming.api.functions.sink.filesystem

Classes in org.apache.flink.streaming.api.functions.sink.filesystem that implement InProgressFileWriter.InProgressFileRecoverable

Modifier and Type	Class and Description
static class	OutputStreamBasedPartFileWriter.OutputStreamBasedInProgressFileRecoverable The InProgressFileRecoverable implementation for OutputStreamBasedBucketWriter.

Methods in org.apache.flink.streaming.api.functions.sink.filesystem that return InProgressFileWriter.InProgressFileRecoverable

Modifier and Type	Method and Description
InProgressFileWriter.InProgressFileRecoverable	OutputStreamBasedPartFileWriter.OutputStreamBasedInProgressFileRecoverableSerializer.deserialize(int version, byte[] serialized)
InProgressFileWriter.InProgressFileRecoverable	OutputStreamBasedPartFileWriter.persist()
InProgressFileWriter.InProgressFileRecoverable	InProgressFileWriter.persist()

Methods in org.apache.flink.streaming.api.functions.sink.filesystem that return types with arguments of type InProgressFileWriter.InProgressFileRecoverable

Modifier and Type	Method and Description
SimpleVersionedSerializer<InProgressFileWriter.InProgressFileRecoverable>	WriterProperties.getInProgressFileRecoverableSerializer()

Methods in org.apache.flink.streaming.api.functions.sink.filesystem with parameters of type InProgressFileWriter.InProgressFileRecoverable

Modifier and Type	Method and Description
boolean	BucketWriter.cleanupInProgressFileRecoverable(InProgressFileWriter.InProgressFileRecoverable inProgressFileRecoverable) Frees up any resources that were previously occupied in order to be able to recover from a (potential) failure.
InProgressFileWriter<IN,BucketID>	BucketWriter.resumeInProgressFileFrom(BucketID bucketID, InProgressFileWriter.InProgressFileRecoverable inProgressFileSnapshot, long creationTime) Used to resume a InProgressFileWriter from a InProgressFileWriter.InProgressFileRecoverable.
byte[]	OutputStreamBasedPartFileWriter.OutputStreamBasedInProgressFileRecoverableSerializer.serialize(InProgressFileWriter.InProgressFileRecoverable inProgressRecoverable)

Constructor parameters in org.apache.flink.streaming.api.functions.sink.filesystem with type arguments of type InProgressFileWriter.InProgressFileRecoverable

Constructor and Description
WriterProperties(SimpleVersionedSerializer<InProgressFileWriter.InProgressFileRecoverable> inProgressFileRecoverableSerializer, SimpleVersionedSerializer<InProgressFileWriter.PendingFileRecoverable> pendingFileRecoverableSerializer, boolean supportsResume)