Class | Description |
---|---|
FileSink<IN> |
A unified sink that emits its input elements to
FileSystem files within buckets. |
FileSink.BulkFormatBuilder<IN,T extends FileSink.BulkFormatBuilder<IN,T>> |
A builder for configuring the sink for bulk-encoding formats, e.g.
|
FileSink.DefaultBulkFormatBuilder<IN> |
Builder for the vanilla
FileSink using a bulk format. |
FileSink.DefaultRowFormatBuilder<IN> |
Builder for the vanilla
FileSink using a row format. |
FileSink.RowFormatBuilder<IN,T extends FileSink.RowFormatBuilder<IN,T>> |
A builder for configuring the sink for row-wise encoding formats.
|
FileSinkCommittable |
Wrapper class for both type of committables in
FileSink . |
FileSinkCommittableSerializer |
Versioned serializer for
FileSinkCommittable . |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.