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.StreamingFileSinkHelper<IN> Helper forStreamingFileSink.