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 file sink to determine the bucket each incoming element should be
put into.
|
InProgressFileWriter.InProgressFileRecoverable
A handle can be used to recover in-progress file..
|
InProgressFileWriter.PendingFileRecoverable
The handle can be used to recover pending file.
|
OutputFileConfig
Part file name configuration.
|
RollingPolicy
The policy based on which a
Bucket in the Filesystem Sink rolls its currently
open part file and opens a new one. |
Class and Description |
---|
BucketWriter
An interface for factories that create the different
writers . |
Class and Description |
---|
BucketAssigner
A BucketAssigner is used with a file sink to determine the bucket each incoming element should be
put into.
|
BucketWriter
An interface for factories that create the different
writers . |
InProgressFileWriter.InProgressFileRecoverable
A handle can be used to recover in-progress file..
|
InProgressFileWriter.PendingFileRecoverable
The handle can be used to recover pending file.
|
OutputFileConfig
Part file name configuration.
|
RollingPolicy
The policy based on which a
Bucket in the Filesystem Sink rolls its currently
open part file and opens a new one. |
Class and Description |
---|
AbstractPartFileWriter
An abstract writer for the currently open part file in a specific
Bucket . |
BucketWriter
An interface for factories that create the different
writers . |
BucketWriter.PendingFile
This represents the file that can not write any data to.
|
InProgressFileWriter
The
Bucket uses the InProgressFileWriter to write element to a part file. |
InProgressFileWriter.InProgressFileRecoverable
A handle can be used to recover in-progress file..
|
InProgressFileWriter.PendingFileRecoverable
The handle can be used to recover pending file.
|
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. |
WriterProperties
This class describes the property of the
BucketWriter . |
Class and Description |
---|
BucketAssigner
A BucketAssigner is used with a file sink 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 |
---|
AbstractPartFileWriter
An abstract writer for the currently open part file in a specific
Bucket . |
Bucket
A bucket is the directory organization of the output of the
StreamingFileSink . |
BucketAssigner
A BucketAssigner is used with a file sink 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. |
BucketFactory
A factory able to create
buckets for the StreamingFileSink . |
BucketLifeCycleListener
Listener about the status of
Bucket . |
Buckets
The manager of the different active buckets in the
StreamingFileSink . |
BucketWriter
An interface for factories that create the different
writers . |
BucketWriter.PendingFile
This represents the file that can not write any data to.
|
FileLifeCycleListener
Listener about the status of file.
|
HadoopPathBasedBulkFormatBuilder
Buckets builder to create buckets that use
HadoopPathBasedPartFileWriter . |
InProgressFileWriter
The
Bucket uses the InProgressFileWriter to write element to a part file. |
InProgressFileWriter.InProgressFileRecoverable
A handle can be used to recover in-progress file..
|
InProgressFileWriter.PendingFileRecoverable
The handle can be used to recover pending file.
|
OutputFileConfig
Part file name configuration.
|
OutputFileConfig.OutputFileConfigBuilder
A builder to create the part file configuration.
|
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 Filesystem Sink rolls its currently
open part file and opens a new one. |
StreamingFileSink
Sink that emits its input elements to
FileSystem files within buckets. |
StreamingFileSink.BucketsBuilder
The base abstract class for the
StreamingFileSink.RowFormatBuilder and StreamingFileSink.BulkFormatBuilder . |
StreamingFileSink.BulkFormatBuilder
A builder for configuring the sink for bulk-encoding formats, e.g.
|
StreamingFileSink.DefaultBulkFormatBuilder
Builder for the vanilla
StreamingFileSink using a bulk format. |
StreamingFileSink.DefaultRowFormatBuilder
Builder for the vanilla
StreamingFileSink using a row format. |
StreamingFileSink.RowFormatBuilder
A builder for configuring the sink for row-wise encoding formats.
|
WriterProperties
This class describes the property of the
BucketWriter . |
Class and Description |
---|
BucketAssigner
A BucketAssigner is used with a file sink 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 Filesystem Sink rolls its currently
open part file and opens a new one. |
Class and Description |
---|
BucketAssigner
A BucketAssigner is used with a file sink 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. |
OutputFileConfig
Part file name configuration.
|
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 Filesystem Sink rolls its currently
open part file and opens a new one. |
Class and Description |
---|
StreamingFileSink.BucketsBuilder
The base abstract class for the
StreamingFileSink.RowFormatBuilder and StreamingFileSink.BulkFormatBuilder . |
Class and Description |
---|
BucketWriter
An interface for factories that create the different
writers . |
StreamingFileSink.BucketsBuilder
The base abstract class for the
StreamingFileSink.RowFormatBuilder and StreamingFileSink.BulkFormatBuilder . |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.