Uses of Interface
org.apache.flink.streaming.api.functions.sink.filesystem.RollingPolicy

Packages that use RollingPolicy

Package	Description
org.apache.flink.connector.file.sink
org.apache.flink.connector.file.sink.writer
org.apache.flink.streaming.api.functions.sink.filesystem
org.apache.flink.streaming.api.functions.sink.filesystem.rollingpolicies
org.apache.flink.table.filesystem

Uses of RollingPolicy in org.apache.flink.connector.file.sink

Methods in org.apache.flink.connector.file.sink with parameters of type RollingPolicy

Modifier and Type	Method and Description
T	FileSink.RowFormatBuilder.withRollingPolicy(RollingPolicy<IN,String> policy)

Constructors in org.apache.flink.connector.file.sink with parameters of type RollingPolicy

Constructor and Description
RowFormatBuilder(Path basePath, long bucketCheckInterval, Encoder<IN> encoder, BucketAssigner<IN,String> assigner, RollingPolicy<IN,String> policy, FileWriterBucketFactory<IN> bucketFactory, OutputFileConfig outputFileConfig)

Uses of RollingPolicy in org.apache.flink.connector.file.sink.writer

Methods in org.apache.flink.connector.file.sink.writer with parameters of type RollingPolicy

Modifier and Type	Method and Description
org.apache.flink.connector.file.sink.writer.FileWriterBucket<IN>	FileWriterBucketFactory.getNewBucket(String bucketId, Path bucketPath, BucketWriter<IN,String> bucketWriter, RollingPolicy<IN,String> rollingPolicy, OutputFileConfig outputFileConfig)
org.apache.flink.connector.file.sink.writer.FileWriterBucket<IN>	DefaultFileWriterBucketFactory.getNewBucket(String bucketId, Path bucketPath, BucketWriter<IN,String> bucketWriter, RollingPolicy<IN,String> rollingPolicy, OutputFileConfig outputFileConfig)
org.apache.flink.connector.file.sink.writer.FileWriterBucket<IN>	FileWriterBucketFactory.restoreBucket(BucketWriter<IN,String> bucketWriter, RollingPolicy<IN,String> rollingPolicy, FileWriterBucketState bucketState, OutputFileConfig outputFileConfig)
org.apache.flink.connector.file.sink.writer.FileWriterBucket<IN>	DefaultFileWriterBucketFactory.restoreBucket(BucketWriter<IN,String> bucketWriter, RollingPolicy<IN,String> rollingPolicy, FileWriterBucketState bucketState, OutputFileConfig outputFileConfig)

Constructors in org.apache.flink.connector.file.sink.writer with parameters of type RollingPolicy

Constructor and Description
FileWriter(Path basePath, SinkWriterMetricGroup metricGroup, BucketAssigner<IN,String> bucketAssigner, FileWriterBucketFactory<IN> bucketFactory, BucketWriter<IN,String> bucketWriter, RollingPolicy<IN,String> rollingPolicy, OutputFileConfig outputFileConfig, Sink.ProcessingTimeService processingTimeService, long bucketCheckInterval) A constructor creating a new empty bucket manager.

Uses of RollingPolicy in org.apache.flink.streaming.api.functions.sink.filesystem

Methods in org.apache.flink.streaming.api.functions.sink.filesystem with parameters of type RollingPolicy

Modifier and Type	Method and Description
Bucket<IN,BucketID>	BucketFactory.getNewBucket(int subtaskIndex, BucketID bucketId, Path bucketPath, long initialPartCounter, BucketWriter<IN,BucketID> bucketWriter, RollingPolicy<IN,BucketID> rollingPolicy, FileLifeCycleListener<BucketID> fileListener, OutputFileConfig outputFileConfig)
Bucket<IN,BucketID>	DefaultBucketFactoryImpl.getNewBucket(int subtaskIndex, BucketID bucketId, Path bucketPath, long initialPartCounter, BucketWriter<IN,BucketID> bucketWriter, RollingPolicy<IN,BucketID> rollingPolicy, FileLifeCycleListener<BucketID> fileListener, OutputFileConfig outputFileConfig)
Bucket<IN,BucketID>	BucketFactory.restoreBucket(int subtaskIndex, long initialPartCounter, BucketWriter<IN,BucketID> bucketWriter, RollingPolicy<IN,BucketID> rollingPolicy, org.apache.flink.streaming.api.functions.sink.filesystem.BucketState<BucketID> bucketState, FileLifeCycleListener<BucketID> fileListener, OutputFileConfig outputFileConfig)
Bucket<IN,BucketID>	DefaultBucketFactoryImpl.restoreBucket(int subtaskIndex, long initialPartCounter, BucketWriter<IN,BucketID> bucketWriter, RollingPolicy<IN,BucketID> rollingPolicy, org.apache.flink.streaming.api.functions.sink.filesystem.BucketState<BucketID> bucketState, FileLifeCycleListener<BucketID> fileListener, OutputFileConfig outputFileConfig)
<ID> StreamingFileSink.RowFormatBuilder<IN,ID,? extends StreamingFileSink.RowFormatBuilder<IN,ID,?>>	StreamingFileSink.RowFormatBuilder.withNewBucketAssignerAndPolicy(BucketAssigner<IN,ID> assigner, RollingPolicy<IN,ID> policy)
T	StreamingFileSink.RowFormatBuilder.withRollingPolicy(RollingPolicy<IN,BucketID> policy)

Constructors in org.apache.flink.streaming.api.functions.sink.filesystem with parameters of type RollingPolicy

Constructor and Description
Buckets(Path basePath, BucketAssigner<IN,BucketID> bucketAssigner, BucketFactory<IN,BucketID> bucketFactory, BucketWriter<IN,BucketID> bucketWriter, RollingPolicy<IN,BucketID> rollingPolicy, int subtaskIndex, OutputFileConfig outputFileConfig) A constructor creating a new empty bucket manager.
RowFormatBuilder(Path basePath, Encoder<IN> encoder, BucketAssigner<IN,BucketID> assigner, RollingPolicy<IN,BucketID> policy, long bucketCheckInterval, BucketFactory<IN,BucketID> bucketFactory, OutputFileConfig outputFileConfig)

Uses of RollingPolicy in org.apache.flink.streaming.api.functions.sink.filesystem.rollingpolicies

Classes in org.apache.flink.streaming.api.functions.sink.filesystem.rollingpolicies that implement RollingPolicy

Modifier and Type	Class and Description
class	CheckpointRollingPolicy<IN,BucketID> An abstract RollingPolicy which rolls on every checkpoint.
class	DefaultRollingPolicy<IN,BucketID> The default implementation of the RollingPolicy.
class	OnCheckpointRollingPolicy<IN,BucketID> A RollingPolicy which rolls (ONLY) on every checkpoint.

Uses of RollingPolicy in org.apache.flink.table.filesystem

Classes in org.apache.flink.table.filesystem that implement RollingPolicy

Modifier and Type	Class and Description
static class	FileSystemTableSink.TableRollingPolicy Table RollingPolicy, it extends CheckpointRollingPolicy for bulk writers.