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

Class DefaultBucketFactoryImpl<IN,BucketID>

java.lang.Object

org.apache.flink.streaming.api.functions.sink.filesystem.DefaultBucketFactoryImpl<IN,BucketID>

All Implemented Interfaces:

Serializable, BucketFactory<IN,BucketID>

@Internal
public class DefaultBucketFactoryImpl<IN,BucketID>
extends Object
implements BucketFactory<IN,BucketID>

A factory returning buckets.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
DefaultBucketFactoryImpl()

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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DefaultBucketFactoryImpl

public DefaultBucketFactoryImpl()

Method Detail

getNewBucket

public 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)

Specified by:

getNewBucket in interface BucketFactory<IN,BucketID>

restoreBucket

public 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

Specified by:

restoreBucket in interface BucketFactory<IN,BucketID>

Throws:

IOException