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.