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 . |
FileSinkProgram.Generator |
Data-generating source function.
|
FileSinkProgram.KeyBucketAssigner |
Use first field for buckets.
|
Enum | Description |
---|---|
FileSinkProgram |
Test program for the
StreamingFileSink and FileSink . |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.