Uses of Class
org.apache.flink.streaming.api.functions.sink.filesystem.Buckets
-
Packages that use Buckets Package Description org.apache.flink.streaming.api.functions.sink.filesystem org.apache.flink.streaming.api.functions.sink.filesystem.legacy -
-
Uses of Buckets in org.apache.flink.streaming.api.functions.sink.filesystem
Constructors in org.apache.flink.streaming.api.functions.sink.filesystem with parameters of type Buckets Constructor Description StreamingFileSinkHelper(Buckets<IN,?> buckets, boolean isRestored, org.apache.flink.api.common.state.OperatorStateStore stateStore, org.apache.flink.streaming.runtime.tasks.ProcessingTimeService procTimeService, long bucketCheckInterval) -
Uses of Buckets in org.apache.flink.streaming.api.functions.sink.filesystem.legacy
Methods in org.apache.flink.streaming.api.functions.sink.filesystem.legacy that return Buckets Modifier and Type Method Description abstract Buckets<IN,BucketID>StreamingFileSink.BucketsBuilder. createBuckets(int subtaskIndex)Buckets<IN,BucketID>StreamingFileSink.BulkFormatBuilder. createBuckets(int subtaskIndex)Buckets<IN,BucketID>StreamingFileSink.RowFormatBuilder. createBuckets(int subtaskIndex)
-