Uses of Interface
org.apache.flink.streaming.api.functions.sink.filesystem.InProgressFileWriter.InProgressFileRecoverable
-
-
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 Description InProgressFileWriter.InProgressFileRecoverable
FileSinkCommittable. getInProgressFileToCleanup()
Constructors in org.apache.flink.connector.file.sink with parameters of type InProgressFileWriter.InProgressFileRecoverable Constructor Description FileSinkCommittable(String bucketId, InProgressFileWriter.InProgressFileRecoverable inProgressFileToCleanup)
-
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 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 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 Description InProgressFileWriter.InProgressFileRecoverable
HadoopPathBasedPartFileWriter. persist()
Methods in org.apache.flink.formats.hadoop.bulk with parameters of type InProgressFileWriter.InProgressFileRecoverable Modifier and Type Method 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 Description static class
OutputStreamBasedPartFileWriter.OutputStreamBasedInProgressFileRecoverable
TheInProgressFileWriter.InProgressFileRecoverable
implementation forOutputStreamBasedPartFileWriter.OutputStreamBasedBucketWriter
.Methods in org.apache.flink.streaming.api.functions.sink.filesystem that return InProgressFileWriter.InProgressFileRecoverable Modifier and Type Method Description InProgressFileWriter.InProgressFileRecoverable
OutputStreamBasedPartFileWriter.OutputStreamBasedInProgressFileRecoverableSerializer. deserialize(int version, byte[] serialized)
InProgressFileWriter.InProgressFileRecoverable
InProgressFileWriter. persist()
InProgressFileWriter.InProgressFileRecoverable
OutputStreamBasedPartFileWriter. persist()
Methods in org.apache.flink.streaming.api.functions.sink.filesystem that return types with arguments of type InProgressFileWriter.InProgressFileRecoverable Modifier and Type Method 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 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 aInProgressFileWriter
from aInProgressFileWriter.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 Description WriterProperties(SimpleVersionedSerializer<InProgressFileWriter.InProgressFileRecoverable> inProgressFileRecoverableSerializer, SimpleVersionedSerializer<InProgressFileWriter.PendingFileRecoverable> pendingFileRecoverableSerializer, boolean supportsResume)
-