Interface | Description |
---|---|
CommittableStateManager |
Helper interface for
CommitterOperator . |
Committer |
The
Committer is responsible for creating and committing an aggregated committable, which
we call committable (see Committer.combine(long, java.util.List<org.apache.flink.table.store.connector.sink.Committable>) ). |
Class | Description |
---|---|
BucketStreamPartitioner |
A
StreamPartitioner to partition records by bucket. |
Committable |
Committable produced by
PrepareCommitOperator . |
CommittableSerializer |
SimpleVersionedSerializer for Committable . |
CommittableTypeInfo |
Type information of
Committable . |
CommitterOperator |
Operator to commit
Committable s for each snapshot. |
CompactorSink |
FlinkSink for dedicated compact jobs. |
CompactorSinkBuilder |
Builder for
CompactorSink . |
FileStoreSink |
FlinkSink for writing records into table store. |
FlinkSink |
Abstract sink of table store.
|
FlinkSinkBuilder |
Builder for
FileStoreSink . |
FullChangelogStoreSinkWrite |
StoreSinkWrite for CoreOptions.ChangelogProducer#FULL_COMPACTION changelog
producer. |
LogOffsetCommittable |
Log offset committable for a bucket.
|
NoopCommittableStateManager |
A
CommittableStateManager which does nothing. |
OffsetRowDataHashStreamPartitioner | |
PrepareCommitOperator |
Prepare commit operator to emit
Committable s. |
RestoreAndFailCommittableStateManager |
A
CommittableStateManager which stores uncommitted ManifestCommittable s in state. |
StateUtils |
Utility class for sink state manipulation.
|
StoreCommitter |
Committer for dynamic store. |
StoreCompactOperator |
A dedicated operator for manual triggered compaction.
|
StoreSinkWriteImpl |
Default implementation of
StoreSinkWrite . |
StoreWriteOperator |
A
PrepareCommitOperator to write records. |
TableStoreSink |
Table sink to create
StoreSink . |
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.