Uses of Class
org.apache.flink.streaming.api.functions.sink.filesystem.StreamingFileSink.BucketsBuilder

Packages that use StreamingFileSink.BucketsBuilder

Package	Description
org.apache.flink.streaming.api.functions.sink.filesystem
org.apache.flink.table.filesystem.stream
org.apache.flink.table.filesystem.stream.compact

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

Classes in org.apache.flink.streaming.api.functions.sink.filesystem with type parameters of type StreamingFileSink.BucketsBuilder

Modifier and Type	Class and Description
static class	StreamingFileSink.BucketsBuilder<IN,BucketID,T extends StreamingFileSink.BucketsBuilder<IN,BucketID,T>> The base abstract class for the StreamingFileSink.RowFormatBuilder and StreamingFileSink.BulkFormatBuilder.

Subclasses of StreamingFileSink.BucketsBuilder in org.apache.flink.streaming.api.functions.sink.filesystem

Modifier and Type	Class and Description
class	HadoopPathBasedBulkFormatBuilder<IN,BucketID,T extends HadoopPathBasedBulkFormatBuilder<IN,BucketID,T>> Buckets builder to create buckets that use HadoopPathBasedPartFileWriter.
static class	StreamingFileSink.BulkFormatBuilder<IN,BucketID,T extends StreamingFileSink.BulkFormatBuilder<IN,BucketID,T>> A builder for configuring the sink for bulk-encoding formats, e.g.
static class	StreamingFileSink.DefaultBulkFormatBuilder<IN> Builder for the vanilla StreamingFileSink using a bulk format.
static class	StreamingFileSink.DefaultRowFormatBuilder<IN> Builder for the vanilla StreamingFileSink using a row format.
static class	StreamingFileSink.RowFormatBuilder<IN,BucketID,T extends StreamingFileSink.RowFormatBuilder<IN,BucketID,T>> A builder for configuring the sink for row-wise encoding formats.

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

Constructor and Description
StreamingFileSink(StreamingFileSink.BucketsBuilder<IN,?,? extends StreamingFileSink.BucketsBuilder<IN,?,?>> bucketsBuilder, long bucketCheckInterval) Creates a new StreamingFileSink that writes files to the given base directory with the give buckets properties.

Constructor parameters in org.apache.flink.streaming.api.functions.sink.filesystem with type arguments of type StreamingFileSink.BucketsBuilder

Constructor and Description
StreamingFileSink(StreamingFileSink.BucketsBuilder<IN,?,? extends StreamingFileSink.BucketsBuilder<IN,?,?>> bucketsBuilder, long bucketCheckInterval) Creates a new StreamingFileSink that writes files to the given base directory with the give buckets properties.

Uses of StreamingFileSink.BucketsBuilder in org.apache.flink.table.filesystem.stream

Methods in org.apache.flink.table.filesystem.stream with parameters of type StreamingFileSink.BucketsBuilder

Modifier and Type	Method and Description
static <T> DataStream<PartitionCommitInfo>	StreamingSink.compactionWriter(DataStream<T> inputStream, long bucketCheckInterval, StreamingFileSink.BucketsBuilder<T,String,? extends StreamingFileSink.BucketsBuilder<T,String,?>> bucketsBuilder, FileSystemFactory fsFactory, Path path, CompactReader.Factory<T> readFactory, long targetFileSize) Create a file writer with compaction operators by input stream.
static <T> DataStream<PartitionCommitInfo>	StreamingSink.writer(DataStream<T> inputStream, long bucketCheckInterval, StreamingFileSink.BucketsBuilder<T,String,? extends StreamingFileSink.BucketsBuilder<T,String,?>> bucketsBuilder) Create a file writer by input stream.

Method parameters in org.apache.flink.table.filesystem.stream with type arguments of type StreamingFileSink.BucketsBuilder

Modifier and Type	Method and Description
static <T> DataStream<PartitionCommitInfo>	StreamingSink.compactionWriter(DataStream<T> inputStream, long bucketCheckInterval, StreamingFileSink.BucketsBuilder<T,String,? extends StreamingFileSink.BucketsBuilder<T,String,?>> bucketsBuilder, FileSystemFactory fsFactory, Path path, CompactReader.Factory<T> readFactory, long targetFileSize) Create a file writer with compaction operators by input stream.
static <T> DataStream<PartitionCommitInfo>	StreamingSink.writer(DataStream<T> inputStream, long bucketCheckInterval, StreamingFileSink.BucketsBuilder<T,String,? extends StreamingFileSink.BucketsBuilder<T,String,?>> bucketsBuilder) Create a file writer by input stream.

Constructors in org.apache.flink.table.filesystem.stream with parameters of type StreamingFileSink.BucketsBuilder

Constructor and Description
AbstractStreamingWriter(long bucketCheckInterval, StreamingFileSink.BucketsBuilder<IN,String,? extends StreamingFileSink.BucketsBuilder<IN,String,?>> bucketsBuilder)
StreamingFileWriter(long bucketCheckInterval, StreamingFileSink.BucketsBuilder<IN,String,? extends StreamingFileSink.BucketsBuilder<IN,String,?>> bucketsBuilder)

Constructor parameters in org.apache.flink.table.filesystem.stream with type arguments of type StreamingFileSink.BucketsBuilder

Constructor and Description
AbstractStreamingWriter(long bucketCheckInterval, StreamingFileSink.BucketsBuilder<IN,String,? extends StreamingFileSink.BucketsBuilder<IN,String,?>> bucketsBuilder)
StreamingFileWriter(long bucketCheckInterval, StreamingFileSink.BucketsBuilder<IN,String,? extends StreamingFileSink.BucketsBuilder<IN,String,?>> bucketsBuilder)

Uses of StreamingFileSink.BucketsBuilder in org.apache.flink.table.filesystem.stream.compact

Constructors in org.apache.flink.table.filesystem.stream.compact with parameters of type StreamingFileSink.BucketsBuilder

Constructor and Description
CompactFileWriter(long bucketCheckInterval, StreamingFileSink.BucketsBuilder<T,String,? extends StreamingFileSink.BucketsBuilder<T,String,?>> bucketsBuilder)

Constructor parameters in org.apache.flink.table.filesystem.stream.compact with type arguments of type StreamingFileSink.BucketsBuilder

Constructor and Description
CompactFileWriter(long bucketCheckInterval, StreamingFileSink.BucketsBuilder<T,String,? extends StreamingFileSink.BucketsBuilder<T,String,?>> bucketsBuilder)