| Package | Description |
|---|---|
| org.apache.paimon.flink | |
| org.apache.paimon.flink.sink | |
| org.apache.paimon.manifest | |
| org.apache.paimon.table.sink |
| Constructor and Description |
|---|
VersionedSerializerWrapper(VersionedSerializer<T> serializer) |
| Modifier and Type | Class and Description |
|---|---|
class |
WrappedManifestCommittableSerializer
|
| Constructor and Description |
|---|
RestoreAndFailCommittableStateManager(SerializableSupplier<VersionedSerializer<GlobalCommitT>> committableSerializer) |
| Modifier and Type | Class and Description |
|---|---|
class |
ManifestCommittableSerializer
|
| Modifier and Type | Class and Description |
|---|---|
class |
CommitMessageSerializer
|
class |
CompactionTaskSerializer
Serializer for
UnawareAppendCompactionTask. |
class |
MultiTableCompactionTaskSerializer
Serializer for
MultiTableUnawareAppendCompactionTask. |
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.