Package org.apache.flink.connector.file.sink.writer

Interface FileWriterBucketFactory<IN>

All Superinterfaces:

Serializable

All Known Implementing Classes:

DefaultFileWriterBucketFactory

@Internal
public interface FileWriterBucketFactory<IN>
extends Serializable

A factory able to create FileWriterBucket for the FileSink.

Method Summary

Modifier and Type	Method	Description
org.apache.flink.connector.file.sink.writer.FileWriterBucket<IN>	getNewBucket(String bucketId, org.apache.flink.core.fs.Path bucketPath, org.apache.flink.streaming.api.functions.sink.filesystem.BucketWriter<IN,String> bucketWriter, org.apache.flink.streaming.api.functions.sink.filesystem.RollingPolicy<IN,String> rollingPolicy, org.apache.flink.streaming.api.functions.sink.filesystem.OutputFileConfig outputFileConfig)
org.apache.flink.connector.file.sink.writer.FileWriterBucket<IN>	restoreBucket(org.apache.flink.streaming.api.functions.sink.filesystem.BucketWriter<IN,String> bucketWriter, org.apache.flink.streaming.api.functions.sink.filesystem.RollingPolicy<IN,String> rollingPolicy, FileWriterBucketState bucketState, org.apache.flink.streaming.api.functions.sink.filesystem.OutputFileConfig outputFileConfig)

Method Detail

getNewBucket

org.apache.flink.connector.file.sink.writer.FileWriterBucket<IN> getNewBucket(String bucketId,
                                                                              org.apache.flink.core.fs.Path bucketPath,
                                                                              org.apache.flink.streaming.api.functions.sink.filesystem.BucketWriter<IN,String> bucketWriter,
                                                                              org.apache.flink.streaming.api.functions.sink.filesystem.RollingPolicy<IN,String> rollingPolicy,
                                                                              org.apache.flink.streaming.api.functions.sink.filesystem.OutputFileConfig outputFileConfig)
                                                                       throws IOException

Throws:

IOException

restoreBucket

org.apache.flink.connector.file.sink.writer.FileWriterBucket<IN> restoreBucket(org.apache.flink.streaming.api.functions.sink.filesystem.BucketWriter<IN,String> bucketWriter,
                                                                               org.apache.flink.streaming.api.functions.sink.filesystem.RollingPolicy<IN,String> rollingPolicy,
                                                                               FileWriterBucketState bucketState,
                                                                               org.apache.flink.streaming.api.functions.sink.filesystem.OutputFileConfig outputFileConfig)
                                                                        throws IOException

Throws:

IOException