Interface | Description |
---|---|
CdcMetadataConverter |
A functional interface for converting CDC metadata.
|
Expression |
Produce a computation result for computed column.
|
Expression.ExpressionCreator |
Expression creator.
|
JdbcToPaimonTypeVisitor |
jdbc to paimon data type visitor.
|
MessageQueueSchemaUtils.ConsumerWrapper |
Wrap the consumer for different message queues.
|
Class | Description |
---|---|
CdcActionCommonUtils |
Common utils for CDC Action.
|
CdcMetadataConverter.DatabaseNameConverter |
Name of the database that contain the row.
|
CdcMetadataConverter.OpTsConverter |
It indicates the time that the change was made in the database.
|
CdcMetadataConverter.SchemaNameConverter |
Name of the schema that contain the row.
|
CdcMetadataConverter.TableNameConverter |
Name of the table that contain the row.
|
CdcSourceRecord |
A data change record from the CDC source.
|
ComputedColumn |
A Computed column's value is computed from input columns.
|
ComputedColumnUtils |
Utility methods for
ComputedColumn , such as build. |
Expression.CastExpression |
Get constant value.
|
Expression.DateFormat |
Convert the temporal value to desired formatted string.
|
Expression.ReferencedField |
Referenced field in expression input parameters.
|
Expression.Substring |
Get substring using
String.substring(int) . |
Expression.TemporalExpressionBase<T> |
Expression to handle temporal value.
|
Expression.TemporalToIntConverter |
Convert the temporal value to an integer.
|
Expression.TruncateComputer |
Truncate numeric/decimal/string value.
|
MessageQueueSchemaUtils |
Utility class to build schema by trying to read and parse records from message queue.
|
MessageQueueSyncTableActionBase |
Base
Action for synchronizing one message queue topic into one Paimon table. |
SyncDatabaseActionBase |
Base
Action for synchronizing into one Paimon database. |
SyncDatabaseActionFactoryBase<T extends SyncDatabaseActionBase> |
Base
ActionFactory for synchronizing into database. |
SynchronizationActionBase |
Base
Action for table/database synchronizing job. |
SynchronizationActionFactoryBase<T extends SynchronizationActionBase> |
Base
ActionFactory for table/database synchronizing job. |
SyncJobHandler |
Provide different function according to CDC source type.
|
SyncTableActionBase |
Base
Action for synchronizing into one Paimon table. |
SyncTableActionFactoryBase |
Base
ActionFactory for synchronizing into one Paimon table. |
TableNameConverter |
Used to convert a MySQL source table name to corresponding Paimon table name.
|
TypeMapping |
Utility that holds data type mapping options.
|
Enum | Description |
---|---|
CdcMetadataProcessor |
Enumerates the metadata processing behaviors for CDC related data.
|
Expression.ExpressionFunction |
Expression function.
|
SyncJobHandler.SourceType |
CDC source type.
|
TypeMapping.TypeMappingMode |
Describe how to map MySQL data type to Paimon data type.
|
Exception | Description |
---|---|
SyncTableActionBase.SchemaRetrievalException |
Custom exception to indicate issues with schema retrieval.
|
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.