Class and Description |
---|
BucketAssigner.Context
Context that the
BucketAssigner can use for getting additional data about
an input record. |
Class and Description |
---|
BucketAssigner
A BucketAssigner is used with a
StreamingFileSink to determine the Bucket each incoming element
should be put into. |
BucketAssigner.Context
Context that the
BucketAssigner can use for getting additional data about
an input record. |
PartFileInfo
An interface exposing the information concerning the current (open) part file
that is necessary to the
RollingPolicy in order to determine if it
should roll the part file or not. |
RollingPolicy
The policy based on which a
Bucket in the StreamingFileSink
rolls its currently open part file and opens a new one. |
StreamingFileSink
Sink that emits its input elements to
FileSystem files within buckets. |
StreamingFileSink.BulkFormatBuilder
A builder for configuring the sink for bulk-encoding formats, e.g.
|
StreamingFileSink.RowFormatBuilder
A builder for configuring the sink for row-wise encoding formats.
|
Class and Description |
---|
BucketAssigner
A BucketAssigner is used with a
StreamingFileSink to determine the Bucket each incoming element
should be put into. |
BucketAssigner.Context
Context that the
BucketAssigner can use for getting additional data about
an input record. |
Class and Description |
---|
PartFileInfo
An interface exposing the information concerning the current (open) part file
that is necessary to the
RollingPolicy in order to determine if it
should roll the part file or not. |
RollingPolicy
The policy based on which a
Bucket in the StreamingFileSink
rolls its currently open part file and opens a new one. |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.