Package org.apache.flink.connector.file.table

Class FileSystemTableSink.TableRollingPolicy

java.lang.Object

org.apache.flink.streaming.api.functions.sink.filesystem.rollingpolicies.CheckpointRollingPolicy<org.apache.flink.table.data.RowData,String>

org.apache.flink.connector.file.table.FileSystemTableSink.TableRollingPolicy

All Implemented Interfaces:

Serializable, org.apache.flink.streaming.api.functions.sink.filesystem.RollingPolicy<org.apache.flink.table.data.RowData,String>

Enclosing class:

FileSystemTableSink

public static class FileSystemTableSink.TableRollingPolicy
extends org.apache.flink.streaming.api.functions.sink.filesystem.rollingpolicies.CheckpointRollingPolicy<org.apache.flink.table.data.RowData,String>

Table RollingPolicy, it extends CheckpointRollingPolicy for bulk writers.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.flink.streaming.api.functions.sink.filesystem.rollingpolicies.CheckpointRollingPolicy

org.apache.flink.streaming.api.functions.sink.filesystem.rollingpolicies.CheckpointRollingPolicy.PolicyBuilder<IN extends Object,BucketID extends Object,T extends org.apache.flink.streaming.api.functions.sink.filesystem.rollingpolicies.CheckpointRollingPolicy.PolicyBuilder<IN,BucketID,T>>

Constructor Summary

Constructors

Constructor	Description
TableRollingPolicy(boolean rollOnCheckpoint, long rollingFileSize, long rollingTimeInterval, long inactivityInterval)

Method Summary

Modifier and Type	Method	Description
boolean	shouldRollOnCheckpoint(org.apache.flink.streaming.api.functions.sink.filesystem.PartFileInfo<String> partFileState)
boolean	shouldRollOnEvent(org.apache.flink.streaming.api.functions.sink.filesystem.PartFileInfo<String> partFileState, org.apache.flink.table.data.RowData element)
boolean	shouldRollOnProcessingTime(org.apache.flink.streaming.api.functions.sink.filesystem.PartFileInfo<String> partFileState, long currentTime)

Methods inherited from class java.lang.Object

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

Constructor Detail

TableRollingPolicy

public TableRollingPolicy(boolean rollOnCheckpoint,
                          long rollingFileSize,
                          long rollingTimeInterval,
                          long inactivityInterval)

Method Detail

shouldRollOnCheckpoint

public boolean shouldRollOnCheckpoint(org.apache.flink.streaming.api.functions.sink.filesystem.PartFileInfo<String> partFileState)

Specified by:

shouldRollOnCheckpoint in interface org.apache.flink.streaming.api.functions.sink.filesystem.RollingPolicy<org.apache.flink.table.data.RowData,String>

Overrides:

shouldRollOnCheckpoint in class org.apache.flink.streaming.api.functions.sink.filesystem.rollingpolicies.CheckpointRollingPolicy<org.apache.flink.table.data.RowData,String>

shouldRollOnEvent

public boolean shouldRollOnEvent(org.apache.flink.streaming.api.functions.sink.filesystem.PartFileInfo<String> partFileState,
                                 org.apache.flink.table.data.RowData element)
                          throws IOException

Specified by:

shouldRollOnEvent in interface org.apache.flink.streaming.api.functions.sink.filesystem.RollingPolicy<org.apache.flink.table.data.RowData,String>

Specified by:

shouldRollOnEvent in class org.apache.flink.streaming.api.functions.sink.filesystem.rollingpolicies.CheckpointRollingPolicy<org.apache.flink.table.data.RowData,String>

Throws:

IOException

shouldRollOnProcessingTime

public boolean shouldRollOnProcessingTime(org.apache.flink.streaming.api.functions.sink.filesystem.PartFileInfo<String> partFileState,
                                          long currentTime)

Specified by:

shouldRollOnProcessingTime in interface org.apache.flink.streaming.api.functions.sink.filesystem.RollingPolicy<org.apache.flink.table.data.RowData,String>

Specified by:

shouldRollOnProcessingTime in class org.apache.flink.streaming.api.functions.sink.filesystem.rollingpolicies.CheckpointRollingPolicy<org.apache.flink.table.data.RowData,String>