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 and Description
DefaultBucketFactoryImpl()

Method Summary

Modifier and Type	Method and Description
Bucket<IN,BucketID>	getNewBucket(int subtaskIndex, BucketID bucketId, Path bucketPath, long initialPartCounter, BucketWriter<IN,BucketID> bucketWriter, RollingPolicy<IN,BucketID> rollingPolicy, OutputFileConfig outputFileConfig)
Bucket<IN,BucketID>	restoreBucket(int subtaskIndex, long initialPartCounter, BucketWriter<IN,BucketID> bucketWriter, RollingPolicy<IN,BucketID> rollingPolicy, org.apache.flink.streaming.api.functions.sink.filesystem.BucketState<BucketID> bucketState, 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,
                                        Path bucketPath,
                                        long initialPartCounter,
                                        BucketWriter<IN,BucketID> bucketWriter,
                                        RollingPolicy<IN,BucketID> rollingPolicy,
                                        OutputFileConfig outputFileConfig)

Specified by:

getNewBucket in interface BucketFactory<IN,BucketID>

restoreBucket

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

Specified by:

restoreBucket in interface BucketFactory<IN,BucketID>

Throws:

IOException