Package org.apache.flink.streaming.api.functions.sink.filesystem

Interface BucketFactory<IN,BucketID>

All Superinterfaces:

Serializable

All Known Implementing Classes:

DefaultBucketFactoryImpl

@Internal
public interface BucketFactory<IN,BucketID>
extends Serializable

A factory able to create buckets for the StreamingFileSink.

Method Summary

Modifier and Type	Method	Description
Bucket<IN,BucketID>	getNewBucket(int subtaskIndex, BucketID bucketId, org.apache.flink.core.fs.Path bucketPath, long initialPartCounter, org.apache.flink.streaming.api.functions.sink.filesystem.BucketWriter<IN,BucketID> bucketWriter, org.apache.flink.streaming.api.functions.sink.filesystem.RollingPolicy<IN,BucketID> rollingPolicy, FileLifeCycleListener<BucketID> fileListener, org.apache.flink.streaming.api.functions.sink.filesystem.OutputFileConfig outputFileConfig)
Bucket<IN,BucketID>	restoreBucket(int subtaskIndex, long initialPartCounter, org.apache.flink.streaming.api.functions.sink.filesystem.BucketWriter<IN,BucketID> bucketWriter, org.apache.flink.streaming.api.functions.sink.filesystem.RollingPolicy<IN,BucketID> rollingPolicy, org.apache.flink.streaming.api.functions.sink.filesystem.BucketState<BucketID> bucketState, FileLifeCycleListener<BucketID> fileListener, org.apache.flink.streaming.api.functions.sink.filesystem.OutputFileConfig outputFileConfig)

Method Detail

getNewBucket

Bucket<IN,BucketID> getNewBucket(int subtaskIndex,
                                       BucketID bucketId,
                                       org.apache.flink.core.fs.Path bucketPath,
                                       long initialPartCounter,
                                       org.apache.flink.streaming.api.functions.sink.filesystem.BucketWriter<IN,BucketID> bucketWriter,
                                       org.apache.flink.streaming.api.functions.sink.filesystem.RollingPolicy<IN,BucketID> rollingPolicy,
                                       @Nullable
                                       FileLifeCycleListener<BucketID> fileListener,
                                       org.apache.flink.streaming.api.functions.sink.filesystem.OutputFileConfig outputFileConfig)
                                throws IOException

Throws:

IOException

restoreBucket

Bucket<IN,BucketID> restoreBucket(int subtaskIndex,
                                        long initialPartCounter,
                                        org.apache.flink.streaming.api.functions.sink.filesystem.BucketWriter<IN,BucketID> bucketWriter,
                                        org.apache.flink.streaming.api.functions.sink.filesystem.RollingPolicy<IN,BucketID> rollingPolicy,
                                        org.apache.flink.streaming.api.functions.sink.filesystem.BucketState<BucketID> bucketState,
                                        @Nullable
                                        FileLifeCycleListener<BucketID> fileListener,
                                        org.apache.flink.streaming.api.functions.sink.filesystem.OutputFileConfig outputFileConfig)
                                 throws IOException

Throws:

IOException