Modifier and Type | Class and Description |
---|---|
class |
CompressWriterFactory<IN>
A factory that creates for
bulk writers that, when provided
with a CompressionCodec , they compress the data they write. |
Modifier and Type | Class and Description |
---|---|
class |
ParquetWriterFactory<T>
A factory that creates a Parquet
BulkWriter . |
Modifier and Type | Class and Description |
---|---|
class |
SequenceFileWriterFactory<K extends org.apache.hadoop.io.Writable,V extends org.apache.hadoop.io.Writable>
A factory that creates a SequenceFile
BulkWriter . |
Modifier and Type | Method and Description |
---|---|
static <IN> StreamingFileSink.DefaultBulkFormatBuilder<IN> |
StreamingFileSink.forBulkFormat(Path basePath,
BulkWriter.Factory<IN> writerFactory)
Creates the builder for a
StreamingFileSink with row-encoding format. |
Constructor and Description |
---|
BulkFormatBuilder(Path basePath,
BulkWriter.Factory<IN> writerFactory,
BucketAssigner<IN,BucketID> assigner) |
BulkFormatBuilder(Path basePath,
BulkWriter.Factory<IN> writerFactory,
BucketAssigner<IN,BucketID> assigner,
CheckpointRollingPolicy<IN,BucketID> policy,
long bucketCheckInterval,
org.apache.flink.streaming.api.functions.sink.filesystem.BucketFactory<IN,BucketID> bucketFactory,
OutputFileConfig outputFileConfig) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.