Package | Description |
---|---|
org.apache.flink.table.store.connector.sink |
Class and Description |
---|
Committable
Committable produced by
PrepareCommitOperator . |
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>) ). |
CompactorSinkBuilder
Builder for
CompactorSink . |
FlinkSink
Abstract sink of table store.
|
FlinkSinkBuilder
Builder for
FileStoreSink . |
LogOffsetCommittable
Log offset committable for a bucket.
|
PrepareCommitOperator
Prepare commit operator to emit
Committable s. |
StoreSinkWriteImpl
Default implementation of
StoreSinkWrite . |
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.