Package org.apache.flink.streaming.api.functions.sink.filesystem
-
Interface Summary Interface Description BucketFactory<IN,BucketID> A factory able to createbucketsfor theStreamingFileSink.BucketLifeCycleListener<IN,BucketID> Listener about the status ofBucket.FileLifeCycleListener<BucketID> Listener about the status of file. -
Class Summary Class Description Bucket<IN,BucketID> A bucket is the directory organization of the output of theStreamingFileSink.Buckets<IN,BucketID> The manager of the different active buckets in theStreamingFileSink.DefaultBucketFactoryImpl<IN,BucketID> A factory returningbuckets.StreamingFileSink<IN> Deprecated. Useorg.apache.flink.connector.file.sink.FileSinkinstead.StreamingFileSink.BucketsBuilder<IN,BucketID,T extends StreamingFileSink.BucketsBuilder<IN,BucketID,T>> The base abstract class for theStreamingFileSink.RowFormatBuilderandStreamingFileSink.BulkFormatBuilder.StreamingFileSink.BulkFormatBuilder<IN,BucketID,T extends StreamingFileSink.BulkFormatBuilder<IN,BucketID,T>> A builder for configuring the sink for bulk-encoding formats, e.g.StreamingFileSink.DefaultBulkFormatBuilder<IN> Builder for the vanillaStreamingFileSinkusing a bulk format.StreamingFileSink.DefaultRowFormatBuilder<IN> Builder for the vanillaStreamingFileSinkusing a row format.StreamingFileSink.RowFormatBuilder<IN,BucketID,T extends StreamingFileSink.RowFormatBuilder<IN,BucketID,T>> A builder for configuring the sink for row-wise encoding formats.StreamingFileSinkHelper<IN> Helper forStreamingFileSink.