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 and Description
org.apache.flink.connector.file.sink.writer.FileWriterBucket<IN>	getNewBucket(String bucketId, Path bucketPath, BucketWriter<IN,String> bucketWriter, RollingPolicy<IN,String> rollingPolicy, OutputFileConfig outputFileConfig)
org.apache.flink.connector.file.sink.writer.FileWriterBucket<IN>	restoreBucket(BucketWriter<IN,String> bucketWriter, RollingPolicy<IN,String> rollingPolicy, FileWriterBucketState bucketState, OutputFileConfig outputFileConfig)

Method Detail

getNewBucket

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

Throws:

IOException

restoreBucket

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

Throws:

IOException