Package | Description |
---|---|
org.apache.flink.streaming.api.functions.sink.filesystem.rollingpolicies |
Modifier and Type | Method and Description |
---|---|
static DefaultRollingPolicy.PolicyBuilder |
DefaultRollingPolicy.builder()
Creates a new
DefaultRollingPolicy.PolicyBuilder that is used to configure and build an instance of DefaultRollingPolicy . |
static DefaultRollingPolicy.PolicyBuilder |
DefaultRollingPolicy.create()
Deprecated.
|
DefaultRollingPolicy.PolicyBuilder |
DefaultRollingPolicy.PolicyBuilder.withInactivityInterval(java.time.Duration interval)
Sets the interval of allowed inactivity after which a part file will have to roll.
|
DefaultRollingPolicy.PolicyBuilder |
DefaultRollingPolicy.PolicyBuilder.withInactivityInterval(long interval)
Deprecated.
Use
withInactivityInterval(Duration) instead. |
DefaultRollingPolicy.PolicyBuilder |
DefaultRollingPolicy.PolicyBuilder.withMaxPartSize(long size)
Deprecated.
Use
withMaxPartSize(MemorySize) instead. |
DefaultRollingPolicy.PolicyBuilder |
DefaultRollingPolicy.PolicyBuilder.withMaxPartSize(MemorySize size)
Sets the part size above which a part file will have to roll.
|
DefaultRollingPolicy.PolicyBuilder |
DefaultRollingPolicy.PolicyBuilder.withRolloverInterval(java.time.Duration interval)
Sets the max time a part file can stay open before having to roll.
|
DefaultRollingPolicy.PolicyBuilder |
DefaultRollingPolicy.PolicyBuilder.withRolloverInterval(long interval)
Deprecated.
Use
withRolloverInterval(Duration) instead. |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.