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

Class DefaultRollingPolicy.PolicyBuilder

java.lang.Object

org.apache.flink.streaming.api.functions.sink.filesystem.rollingpolicies.DefaultRollingPolicy.PolicyBuilder

Enclosing class:

DefaultRollingPolicy<IN,BucketID>

@PublicEvolving
public static final class DefaultRollingPolicy.PolicyBuilder
extends Object

A helper class that holds the configuration properties for the DefaultRollingPolicy. The build() method must be called to instantiate the policy.

Method Summary

Modifier and Type	Method and Description
<IN,BucketID> DefaultRollingPolicy<IN,BucketID>	build() Creates the actual policy.
DefaultRollingPolicy.PolicyBuilder	withInactivityInterval(long interval) Sets the interval of allowed inactivity after which a part file will have to roll.
DefaultRollingPolicy.PolicyBuilder	withMaxPartSize(long size) Sets the part size above which a part file will have to roll.
DefaultRollingPolicy.PolicyBuilder	withRolloverInterval(long interval) Sets the max time a part file can stay open before having to roll.

Methods inherited from class java.lang.Object

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

Method Detail

withMaxPartSize

public DefaultRollingPolicy.PolicyBuilder withMaxPartSize(long size)

Sets the part size above which a part file will have to roll.

Parameters:

size - the allowed part size.

withInactivityInterval

public DefaultRollingPolicy.PolicyBuilder withInactivityInterval(long interval)

Sets the interval of allowed inactivity after which a part file will have to roll. The frequency at which this is checked is controlled by the StreamingFileSink.RowFormatBuilder.withBucketCheckInterval(long) setting.

Parameters:

interval - the allowed inactivity interval.

withRolloverInterval

public DefaultRollingPolicy.PolicyBuilder withRolloverInterval(long interval)

Sets the max time a part file can stay open before having to roll. The frequency at which this is checked is controlled by the StreamingFileSink.RowFormatBuilder.withBucketCheckInterval(long) setting.

Parameters:

interval - the desired rollover interval.

build

public <IN,BucketID> DefaultRollingPolicy<IN,BucketID> build()

Creates the actual policy.