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

Packages that use InProgressFileWriter

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

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

Classes in org.apache.flink.formats.hadoop.bulk that implement InProgressFileWriter

Modifier and Type	Class and Description
class	HadoopPathBasedPartFileWriter<IN,BucketID> The part-file writer that writes to the specified hadoop path.

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

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

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

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

Modifier and Type	Class and Description
class	AbstractPartFileWriter<IN,BucketID> An abstract writer for the currently open part file in a specific Bucket.
class	OutputStreamBasedPartFileWriter<IN,BucketID> The base class for all the part file writer that use RecoverableFsDataOutputStream.

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

Modifier and Type	Method and Description
InProgressFileWriter<IN,BucketID>	BulkBucketWriter.openNew(BucketID bucketId, RecoverableFsDataOutputStream stream, Path path, long creationTime)
InProgressFileWriter<IN,BucketID>	RowWiseBucketWriter.openNew(BucketID bucketId, RecoverableFsDataOutputStream stream, Path path, long creationTime)
InProgressFileWriter<IN,BucketID>	BucketWriter.openNewInProgressFile(BucketID bucketID, Path path, long creationTime) Used to create a new InProgressFileWriter.
InProgressFileWriter<IN,BucketID>	BulkBucketWriter.resumeFrom(BucketID bucketId, RecoverableFsDataOutputStream stream, RecoverableWriter.ResumeRecoverable resumable, long creationTime)
InProgressFileWriter<IN,BucketID>	RowWiseBucketWriter.resumeFrom(BucketID bucketId, RecoverableFsDataOutputStream stream, RecoverableWriter.ResumeRecoverable resumable, long creationTime)
InProgressFileWriter<IN,BucketID>	BucketWriter.resumeInProgressFileFrom(BucketID bucketID, InProgressFileWriter.InProgressFileRecoverable inProgressFileSnapshot, long creationTime) Used to resume a InProgressFileWriter from a InProgressFileWriter.InProgressFileRecoverable.