Constant Field Values

Contents

• io.debezium.*
• org.apache.*

io.debezium.*

io.debezium.connector.mysql.MySqlConnection.MySqlConnectionConfiguration

Modifier and Type	Constant Field	Value
protected static final String	JDBC_PROPERTY_CONNECTION_TIME_ZONE	"connectionTimeZone"
protected static final String	JDBC_PROPERTY_LEGACY_DATETIME	"useLegacyDatetimeCode"
protected static final String	JDBC_PROPERTY_LEGACY_SERVER_TIME_ZONE	"serverTimezone"

io.debezium.connector.mysql.converters.MysqlDebeziumTimeConverter

Modifier and Type	Constant Field	Value
protected static final String	DATE_FORMAT	"yyyy-MM-dd"
protected static final String	DATETIME_FORMAT	"yyyy-MM-dd HH:mm:ss"
protected static final String	DEFAULT_DATE_FORMAT_PATTERN	"1970-01-01 00:00:00"
protected static final String	TIME_FORMAT	"yyyy-MM-dd HH:mm:ss"

io.debezium.connector.oracle.logminer.LogMinerAdapter

Modifier and Type	Constant Field	Value
public static final String	TYPE	"logminer"

io.debezium.connector.postgresql.connection.PostgresConnection

Modifier and Type	Constant Field	Value
public static final String	CONNECTION_DROP_SLOT	"Debezium Drop Slot"
public static final String	CONNECTION_GENERAL	"Debezium General"
public static final String	CONNECTION_HEARTBEAT	"Debezium Heartbeat"
public static final String	CONNECTION_SLOT_INFO	"Debezium Slot Info"
public static final String	CONNECTION_STREAMING	"Debezium Streaming"
public static final String	CONNECTION_VALIDATE_CONNECTION	"Debezium Validate Connection"

io.debezium.relational.HistorizedRelationalDatabaseConnectorConfig

Modifier and Type	Constant Field	Value
protected static final int	DEFAULT_SNAPSHOT_FETCH_SIZE	2000

io.debezium.relational.RelationalChangeRecordEmitter<P extends io.debezium.pipeline.spi.Partition>

Modifier and Type	Constant Field	Value
public static final String	PK_UPDATE_NEWKEY_FIELD	"__debezium.newkey"
public static final String	PK_UPDATE_OLDKEY_FIELD	"__debezium.oldkey"

org.apache.*

org.apache.calcite.sql.type.SqlTypeName

Modifier and Type	Constant Field	Value
public static final int	DEFAULT_INTERVAL_FRACTIONAL_SECOND_PRECISION	6
public static final int	DEFAULT_INTERVAL_START_PRECISION	2
public static final int	MAX_DATETIME_PRECISION	3
public static final int	MAX_INTERVAL_FRACTIONAL_SECOND_PRECISION	9
public static final int	MAX_INTERVAL_START_PRECISION	10
public static final int	MIN_INTERVAL_FRACTIONAL_SECOND_PRECISION	1
public static final int	MIN_INTERVAL_START_PRECISION	1

org.apache.flink.cdc.cli.parser.YamlPipelineDefinitionParser

Modifier and Type	Constant Field	Value
public static final String	TRANSFORM_PARTITION_KEY_KEY	"partition-keys"
public static final String	TRANSFORM_PRIMARY_KEY_KEY	"primary-keys"
public static final String	TRANSFORM_TABLE_OPTION_DELIMITER_KEY	"table-options.delimiter"
public static final String	TRANSFORM_TABLE_OPTION_KEY	"table-options"

org.apache.flink.cdc.common.data.binary.BinaryFormat

Modifier and Type	Constant Field	Value
public static final long	HIGHEST_FIRST_BIT	-9223372036854775808L
public static final long	HIGHEST_SECOND_TO_EIGHTH_BIT	9151314442816847872L
public static final int	MAX_FIX_PART_DATA_SIZE	7

org.apache.flink.cdc.common.data.binary.BinaryRecordData

Modifier and Type	Constant Field	Value
public static final int	HEADER_SIZE_IN_BITS	8
public static final String	TIMESTAMP_DELIMITER	"//"

org.apache.flink.cdc.common.schema.Column

Modifier and Type	Constant Field	Value
protected static final String	FIELD_FORMAT_NO_DESCRIPTION_NO_DEFAULT_VALUE_EXPRESSION	"%s %s"
protected static final String	FIELD_FORMAT_NO_DESCRIPTION_WITH_DEFAULT_VALUE_EXPRESSION	"%s %s \'%s\'"
protected static final String	FIELD_FORMAT_WITH_DESCRIPTION_NO_DEFAULT_VALUE_EXPRESSION	"%s %s \'%s\'"
protected static final String	FIELD_FORMAT_WITH_DESCRIPTION_WITH_DEFAULT_VALUE_EXPRESSION	"%s %s \'%s\' \'%s\'"

org.apache.flink.cdc.common.source.discover.JdbcTableDiscovererFactory

Modifier and Type	Constant Field	Value
public static final String	TYPE	"jdbc"

org.apache.flink.cdc.common.text.TokenStream

Modifier and Type	Constant Field	Value
public static final int	ANY_TYPE	-2147483648
public static final String	ANY_VALUE	"any value"

org.apache.flink.cdc.common.types.ArrayType

Modifier and Type	Constant Field	Value
public static final String	FORMAT	"ARRAY<%s>"

org.apache.flink.cdc.common.types.BinaryType

Modifier and Type	Constant Field	Value
public static final int	DEFAULT_LENGTH	1
public static final int	EMPTY_LITERAL_LENGTH	0
public static final int	MAX_LENGTH	2147483647
public static final int	MIN_LENGTH	1

org.apache.flink.cdc.common.types.CharType

Modifier and Type	Constant Field	Value
public static final int	DEFAULT_LENGTH	1
public static final int	EMPTY_LITERAL_LENGTH	0
public static final int	MAX_LENGTH	2147483647
public static final int	MIN_LENGTH	1

org.apache.flink.cdc.common.types.DataField

Modifier and Type	Constant Field	Value
public static final String	FIELD_FORMAT_NO_DESCRIPTION	"%s %s"
public static final String	FIELD_FORMAT_WITH_DESCRIPTION	"%s %s \'%s\'"

org.apache.flink.cdc.common.types.DecimalType

Modifier and Type	Constant Field	Value
public static final int	DEFAULT_PRECISION	10
public static final int	DEFAULT_SCALE	0
public static final int	MAX_PRECISION	38
public static final int	MIN_PRECISION	1
public static final int	MIN_SCALE	0

org.apache.flink.cdc.common.types.LocalZonedTimestampType

Modifier and Type	Constant Field	Value
public static final int	DEFAULT_PRECISION	6
public static final int	MAX_PRECISION	9
public static final int	MIN_PRECISION	0

org.apache.flink.cdc.common.types.MapType

Modifier and Type	Constant Field	Value
public static final String	FORMAT	"MAP<%s, %s>"

org.apache.flink.cdc.common.types.RowType

Modifier and Type	Constant Field	Value
public static final String	FORMAT	"ROW<%s>"

org.apache.flink.cdc.common.types.TimestampType

Modifier and Type	Constant Field	Value
public static final int	DEFAULT_PRECISION	6
public static final int	MAX_PRECISION	9
public static final int	MIN_PRECISION	0

org.apache.flink.cdc.common.types.TimeType

Modifier and Type	Constant Field	Value
public static final int	DEFAULT_PRECISION	0
public static final int	MAX_PRECISION	9
public static final int	MIN_PRECISION	0

org.apache.flink.cdc.common.types.VarBinaryType

Modifier and Type	Constant Field	Value
public static final int	DEFAULT_LENGTH	1
public static final int	MAX_LENGTH	2147483647
public static final int	MIN_LENGTH	1

org.apache.flink.cdc.common.types.VarCharType

Modifier and Type	Constant Field	Value
public static final int	DEFAULT_LENGTH	1
public static final int	MAX_LENGTH	2147483647
public static final int	MIN_LENGTH	1

org.apache.flink.cdc.common.types.ZonedTimestampType

Modifier and Type	Constant Field	Value
public static final int	DEFAULT_PRECISION	6
public static final int	MAX_PRECISION	9
public static final int	MIN_PRECISION	0

org.apache.flink.cdc.common.types.variant.BinaryVariantUtil

Modifier and Type	Constant Field	Value
public static final int	ARRAY	3
public static final int	BASIC_TYPE_BITS	2
public static final int	BASIC_TYPE_MASK	3
public static final int	BINARY	15
public static final int	BINARY_SEARCH_THRESHOLD	32
public static final int	DATE	11
public static final int	DECIMAL16	10
public static final int	DECIMAL4	8
public static final int	DECIMAL8	9
public static final int	DOUBLE	7
public static final int	FALSE	2
public static final int	FLOAT	14
public static final int	INT1	3
public static final int	INT2	4
public static final int	INT4	5
public static final int	INT8	6
public static final int	LONG_STR	16
public static final int	MAX_DECIMAL16_PRECISION	38
public static final int	MAX_DECIMAL4_PRECISION	9
public static final int	MAX_DECIMAL8_PRECISION	18
public static final int	MAX_SHORT_STR_SIZE	63
public static final int	NULL	0
public static final int	OBJECT	2
public static final int	PRIMITIVE	0
public static final int	SHORT_STR	1
public static final int	SIZE_LIMIT	16777216
public static final int	TIMESTAMP	13
public static final int	TIMESTAMP_LTZ	12
public static final int	TRUE	1
public static final int	TYPE_INFO_MASK	63
public static final int	U16_MAX	65535
public static final int	U24_MAX	16777215
public static final int	U24_SIZE	3
public static final int	U32_SIZE	4
public static final int	U8_MAX	255
public static final byte	VERSION	1
public static final byte	VERSION_MASK	15

org.apache.flink.cdc.common.utils.DateTimeUtils

Modifier and Type	Constant Field	Value
public static final int	EPOCH_JULIAN	2440588
public static final long	MILLIS_PER_DAY	86400000L

org.apache.flink.cdc.composer.flink.translator.TransformTranslator

Modifier and Type	Constant Field	Value
public static final String	PREFIX_CLASSPATH_BUILT_IN_MODEL	"org.apache.flink.cdc.runtime.model."

org.apache.flink.cdc.connectors.base.relational.JdbcSourceEventDispatcher<P extends io.debezium.pipeline.spi.Partition>

Modifier and Type	Constant Field	Value
public static final String	HISTORY_RECORD_FIELD	"historyRecord"

org.apache.flink.cdc.connectors.base.relational.connection.JdbcConnectionPoolFactory

Modifier and Type	Constant Field	Value
public static final String	CONNECTION_POOL_PREFIX	"connection-pool-"
public static final int	MINIMUM_POOL_SIZE	1
public static final String	SERVER_TIMEZONE_KEY	"serverTimezone"

org.apache.flink.cdc.connectors.base.source.EmbeddedFlinkDatabaseHistory

Modifier and Type	Constant Field	Value
public static final String	DATABASE_HISTORY_INSTANCE_NAME	"database.history.instance.name"

org.apache.flink.cdc.connectors.base.source.meta.events.StreamSplitMetaAssembledEvent

Modifier and Type	Constant Field	Value
public static final int	COMPLETE_WITHOUT_META_GENERATION	-1

org.apache.flink.cdc.connectors.base.source.meta.split.StreamSplit

Modifier and Type	Constant Field	Value
public static final String	STREAM_SPLIT_ID	"stream-split"

org.apache.flink.cdc.connectors.base.source.meta.wartermark.WatermarkEvent

Modifier and Type	Constant Field	Value
public static final String	SIGNAL_EVENT_KEY_SCHEMA_NAME	"io.debezium.connector.flink.cdc.embedded.watermark.key"
public static final String	SIGNAL_EVENT_VALUE_SCHEMA_NAME	"io.debezium.connector.flink.cdc.embedded.watermark.value"
public static final String	SPLIT_ID_KEY	"split_id"
public static final String	WATERMARK_KIND	"watermark_kind"
public static final String	WATERMARK_SIGNAL	"_split_watermark_signal_"

org.apache.flink.cdc.connectors.base.source.metrics.SourceEnumeratorMetrics

Modifier and Type	Constant Field	Value
public static final String	IS_SNAPSHOTTING	"isSnapshotting"
public static final String	IS_STREAM_READING	"isStreamReading"
public static final String	NAMESPACE_GROUP_KEY	"namespace"
public static final String	NUM_SNAPSHOT_SPLITS_FINISHED	"numSnapshotSplitsFinished"
public static final String	NUM_SNAPSHOT_SPLITS_PROCESSED	"numSnapshotSplitsProcessed"
public static final String	NUM_SNAPSHOT_SPLITS_REMAINING	"numSnapshotSplitsRemaining"
public static final String	NUM_TABLES_REMAINING	"numTablesRemaining"
public static final String	NUM_TABLES_SNAPSHOTTED	"numTablesSnapshotted"
public static final String	SCHEMA_GROUP_KEY	"schema"
public static final String	SNAPSHOT_END_TIME	"snapshotEndTime"
public static final String	SNAPSHOT_START_TIME	"snapshotStartTime"
public static final String	TABLE_GROUP_KEY	"table"
public static final int	UNDEFINED	0

org.apache.flink.cdc.connectors.base.source.metrics.SourceReaderMetrics

Modifier and Type	Constant Field	Value
public static final String	CURRENT_EVENT_TIME_LAG	"currentEventTimeLag"
public static final String	NAMESPACE_GROUP_KEY	"namespace"
public static final String	NUM_DDL_RECORDS	"numDDLRecords"
public static final String	NUM_DELETE_DML_RECORDS	"numDeleteDMLRecords"
public static final String	NUM_INSERT_DML_RECORDS	"numInsertDMLRecords"
public static final String	NUM_SNAPSHOT_RECORDS	"numSnapshotRecords"
public static final String	NUM_UPDATE_DML_RECORDS	"numUpdateDMLRecords"
public static final String	SCHEMA_GROUP_KEY	"schema"
public static final String	TABLE_GROUP_KEY	"table"
public static final long	UNDEFINED	-1L

org.apache.flink.cdc.connectors.base.utils.SourceRecordUtils

Modifier and Type	Constant Field	Value
public static final String	SCHEMA_CHANGE_EVENT_KEY_NAME	"io.debezium.connector.*.SchemaChangeKey"
public static final String	SCHEMA_HEARTBEAT_EVENT_KEY_NAME	"io.debezium.connector.common.Heartbeat"

org.apache.flink.cdc.connectors.doris.sink.DorisDataSinkOptions

Modifier and Type	Constant Field	Value
public static final String	STREAM_LOAD_PROP_PREFIX	"sink.properties."
public static final String	TABLE_CREATE_AUTO_PARTITION_PROPERTIES_DEFAULT_PARTITION_KEY	"table.create.auto-partition.properties.default-partition-key"
public static final String	TABLE_CREATE_AUTO_PARTITION_PROPERTIES_DEFAULT_PARTITION_UNIT	"table.create.auto-partition.properties.default-partition-unit"
public static final String	TABLE_CREATE_AUTO_PARTITION_PROPERTIES_EXCLUDE	"table.create.auto-partition.properties.exclude"
public static final String	TABLE_CREATE_AUTO_PARTITION_PROPERTIES_INCLUDE	"table.create.auto-partition.properties.include"
public static final String	TABLE_CREATE_AUTO_PARTITION_PROPERTIES_PREFIX	"table.create.auto-partition.properties."
public static final String	TABLE_CREATE_DEFAULT_PARTITION_KEY	"default-partition-key"
public static final String	TABLE_CREATE_DEFAULT_PARTITION_UNIT	"default-partition-unit"
public static final String	TABLE_CREATE_PARTITION_EXCLUDE	"exclude"
public static final String	TABLE_CREATE_PARTITION_INCLUDE	"include"
public static final String	TABLE_CREATE_PARTITION_KEY	"partition-key"
public static final String	TABLE_CREATE_PARTITION_UNIT	"partition-unit"
public static final String	TABLE_CREATE_PROPERTIES_PREFIX	"table.create.properties."

org.apache.flink.cdc.connectors.doris.utils.DorisSchemaUtils

Modifier and Type	Constant Field	Value
public static final String	DEFAULT_DATE	"1970-01-01"
public static final String	DEFAULT_DATETIME	"1970-01-01 00:00:00"
public static final String	INVALID_OR_MISSING_DATATIME	"0000-00-00 00:00:00"

org.apache.flink.cdc.connectors.elasticsearch.sink.ElasticsearchDataSinkFactory

Modifier and Type	Constant Field	Value
public static final String	IDENTIFIER	"elasticsearch"

org.apache.flink.cdc.connectors.fluss.factory.FlussDataSinkFactory

Modifier and Type	Constant Field	Value
public static final String	IDENTIFIER	"fluss"

org.apache.flink.cdc.connectors.fluss.factory.FlussDataSourceFactory

Modifier and Type	Constant Field	Value
public static final String	IDENTIFIER	"fluss"

org.apache.flink.cdc.connectors.fluss.sink.FlussDataSinkOptions

Modifier and Type	Constant Field	Value
public static final String	CLIENT_PROPERTIES_PREFIX	"properties.client."
public static final String	TABLE_PROPERTIES_PREFIX	"properties.table."

org.apache.flink.cdc.connectors.fluss.sink.v2.metrics.WrapperFlussMetricRegistry

Modifier and Type	Constant Field	Value
public static final String	FLUSS_GROUP_NAME	"fluss"

org.apache.flink.cdc.connectors.fluss.source.FlussDataSourceOptions

Modifier and Type	Constant Field	Value
public static final String	CLIENT_PROPERTIES_PREFIX	"properties.client."
public static final String	TABLE_DISCOVERER_OPTIONS_PREFIX	"table.discoverer."

org.apache.flink.cdc.connectors.fluss.source.discover.FlussDefaultDiscovererFactory

Modifier and Type	Constant Field	Value
public static final String	TYPE	"fluss-default"

org.apache.flink.cdc.connectors.fluss.source.metrics.FlussSourceReaderMetrics

Modifier and Type	Constant Field	Value
public static final long	UNINITIALIZED	-1L

org.apache.flink.cdc.connectors.fluss.source.reader.FlussSourceRecord

Modifier and Type	Constant Field	Value
public static final long	NO_READ_RECORDS_COUNT	-1L

org.apache.flink.cdc.connectors.hudi.sink.HudiDataSinkFactory

Modifier and Type	Constant Field	Value
public static final String	IDENTIFIER	"hudi"

org.apache.flink.cdc.connectors.hudi.sink.HudiDataSinkOptions

Modifier and Type	Constant Field	Value
public static final String	PREFIX_CATALOG_PROPERTIES	"catalog.properties."
public static final String	PREFIX_TABLE_PROPERTIES	"table.properties."

org.apache.flink.cdc.connectors.iceberg.sink.IcebergDataSinkFactory

Modifier and Type	Constant Field	Value
public static final String	IDENTIFIER	"iceberg"

org.apache.flink.cdc.connectors.iceberg.sink.IcebergDataSinkOptions

Modifier and Type	Constant Field	Value
public static final String	PREFIX_CATALOG_PROPERTIES	"catalog.properties."
public static final String	PREFIX_HADOOP_CONF	"hadoop.conf."
public static final String	PREFIX_TABLE_PROPERTIES	"table.properties."

org.apache.flink.cdc.connectors.iceberg.sink.v2.IcebergCommitter

Modifier and Type	Constant Field	Value
public static final String	NAMESPACE_GROUP_KEY	"namespace"
public static final String	SCHEMA_GROUP_KEY	"schema"
public static final String	TABLE_GROUP_KEY	"table"

org.apache.flink.cdc.connectors.iceberg.sink.v2.IcebergWriter

Modifier and Type	Constant Field	Value
public static final String	DEFAULT_FILE_FORMAT	"parquet"
public static final long	DEFAULT_MAX_FILE_SIZE	268435456L

org.apache.flink.cdc.connectors.iceberg.sink.v2.TableMetric

Modifier and Type	Constant Field	Value
public static final String	NUM_COMMIT_TIMES	"numCommitTimes"

org.apache.flink.cdc.connectors.kafka.sink.KafkaDataSinkFactory

Modifier and Type	Constant Field	Value
public static final String	IDENTIFIER	"kafka"

org.apache.flink.cdc.connectors.kafka.sink.KafkaDataSinkOptions

Modifier and Type	Constant Field	Value
public static final String	DELIMITER_SELECTOR_TOPIC	":"
public static final String	DELIMITER_TABLE_MAPPINGS	";"
public static final String	PROPERTIES_PREFIX	"properties."

org.apache.flink.cdc.connectors.kafka.sink.PipelineKafkaRecordSerializationSchema

Modifier and Type	Constant Field	Value
public static final String	NAMESPACE_HEADER_KEY	"namespace"
public static final String	SCHEMA_NAME_HEADER_KEY	"schemaName"
public static final String	TABLE_NAME_HEADER_KEY	"tableName"

org.apache.flink.cdc.connectors.maxcompute.common.Constant

Modifier and Type	Constant Field	Value
public static final String	END_OF_SESSION	"end_of_session"
public static final String	MAXCOMPUTE_PARTITION_NAME	"maxcompute_partition_name"
public static final String	PIPELINE_SESSION_MANAGE_OPERATOR_UID	"$$_session_manage_operator_$$"
public static final String	SCHEMA_ENABLE_FLAG	"odps.schema.model.enabled"
public static final String	TUNNEL_SESSION_ID	"tunnel_session_id"

org.apache.flink.cdc.connectors.mongodb.internal.MongoDBConnectorSourceTask

Modifier and Type	Constant Field	Value
public static final String	COLLECTION_INCLUDE_LIST	"collection.include.list"
public static final String	DATABASE_INCLUDE_LIST	"database.include.list"
public static final String	STARTUP_MODE_INITIAL_SNAPSHOTTING_MAX_THREADS_CONFIG	"startup.mode.copy.existing.max.threads"
public static final String	STARTUP_MODE_INITIAL_SNAPSHOTTING_PIPELINE_CONFIG	"startup.mode.copy.existing.pipeline"
public static final String	STARTUP_MODE_INITIAL_SNAPSHOTTING_QUEUE_SIZE_CONFIG	"startup.mode.copy.existing.queue.size"
public static final String	STARTUP_MODE_TIMESTAMP_START_AT_OPERATION_TIME_CONFIG	"startup.mode.timestamp.start.at.operation.time"

org.apache.flink.cdc.connectors.mongodb.internal.MongoDBEnvelope

Modifier and Type	Constant Field	Value
public static final String	CLUSTER_TIME_FIELD	"clusterTime"
public static final String	COPY_KEY_FIELD	"copy"
public static final String	DATA_FIELD	"_data"
public static final String	DOCUMENT_KEY_FIELD	"documentKey"
public static final String	DROPPED_FIELD	"dropped"
public static final String	FULL_DOCUMENT_BEFORE_CHANGE_FIELD	"fullDocumentBeforeChange"
public static final String	FULL_DOCUMENT_FIELD	"fullDocument"
public static final String	HEARTBEAT_KEY_FIELD	"HEARTBEAT"
public static final String	HEARTBEAT_TOPIC_NAME	"__mongodb_heartbeats"
public static final String	ID_FIELD	"_id"
public static final String	KEY_FIELD	"key"
public static final String	MAX_FIELD	"max"
public static final String	MIN_FIELD	"min"
public static final String	MONGODB_SCHEME	"mongodb"
public static final String	MONGODB_SRV_SCHEME	"mongodb+srv"
public static final String	NAMESPACE_COLLECTION_FIELD	"coll"
public static final String	NAMESPACE_DATABASE_FIELD	"db"
public static final String	NAMESPACE_FIELD	"ns"
public static final String	OPERATION_TYPE_FIELD	"operationType"
public static final String	OUTPUT_SCHEMA	"{ \"name\": \"ChangeStream\", \"type\": \"record\", \"fields\": [ { \"name\": \"_id\", \"type\": \"string\" }, { \"name\": \"operationType\", \"type\": [\"string\", \"null\"] }, { \"name\": \"fullDocument\", \"type\": [\"string\", \"null\"] }, { \"name\": \"fullDocumentBeforeChange\", \"type\": [\"string\", \"null\"] }, { \"name\": \"source\", \"type\": [{\"name\": \"source\", \"type\": \"record\", \"fields\": [ {\"name\": \"ts_ms\", \"type\": \"long\"}, {\"name\": \"snapshot\", \"type\": [\"string\", \"null\"] } ] }, \"null\" ] }, { \"name\": \"ts_ms\", \"type\": [\"long\", \"null\"]}, { \"name\": \"ns\", \"type\": [{\"name\": \"ns\", \"type\": \"record\", \"fields\": [ {\"name\": \"db\", \"type\": \"string\"}, {\"name\": \"coll\", \"type\": [\"string\", \"null\"] } ] }, \"null\" ] }, { \"name\": \"to\", \"type\": [{\"name\": \"to\", \"type\": \"record\", \"fields\": [ {\"name\": \"db\", \"type\": \"string\"}, {\"name\": \"coll\", \"type\": [\"string\", \"null\"] } ] }, \"null\" ] }, { \"name\": \"documentKey\", \"type\": [\"string\", \"null\"] }, { \"name\": \"updateDescription\", \"type\": [{\"name\": \"updateDescription\", \"type\": \"record\", \"fields\": [ {\"name\": \"updatedFields\", \"type\": [\"string\", \"null\"]}, {\"name\": \"removedFields\", \"type\": [{\"type\": \"array\", \"items\": \"string\"}, \"null\"] }] }, \"null\"] }, { \"name\": \"clusterTime\", \"type\": [\"string\", \"null\"] }, { \"name\": \"txnNumber\", \"type\": [\"long\", \"null\"]}, { \"name\": \"lsid\", \"type\": [{\"name\": \"lsid\", \"type\": \"record\", \"fields\": [ {\"name\": \"id\", \"type\": \"string\"}, {\"name\": \"uid\", \"type\": \"string\"}] }, \"null\"] } ]}"
public static final String	SNAPSHOT_KEY_FIELD	"snapshot"
public static final String	SOURCE_FIELD	"source"
public static final String	TIMESTAMP_KEY_FIELD	"ts_ms"
public static final String	UUID_FIELD	"uuid"
public static final String	WATERMARK_TOPIC_NAME	"__mongodb_watermarks"

org.apache.flink.cdc.connectors.mongodb.source.offset.ChangeStreamOffset

Modifier and Type	Constant Field	Value
public static final String	RESUME_TOKEN_FIELD	"resumeToken"
public static final String	TIMESTAMP_FIELD	"timestamp"

org.apache.flink.cdc.connectors.mongodb.source.utils.CollectionDiscoveryUtils

Modifier and Type	Constant Field	Value
public static final String	ADD_NS_FIELD_NAME	"_ns_"
public static final String	REGEX_META_CHARACTERS	".$|()[]{}<>^?*+=!\\"

org.apache.flink.cdc.connectors.mongodb.source.utils.MongoUtils

Modifier and Type	Constant Field	Value
public static final int	BSON_OBJECT_TOO_LARGE	10334
public static final int	CHANGE_STREAM_FATAL_ERROR	280
public static final int	CHANGE_STREAM_HISTORY_LOST	286
public static final int	CLOSE_CHANGE_STREAM	222
public static final int	FAILED_TO_PARSE_ERROR	9
public static final int	ILLEGAL_OPERATION_ERROR	20
public static final int	INVALIDATED_RESUME_TOKEN_ERROR	260
public static final int	RETRY_CHANGE_STREAM	234
public static final int	UNAUTHORIZED_ERROR	13
public static final int	UNKNOWN_FIELD_ERROR	40415

org.apache.flink.cdc.connectors.mysql.debezium.EmbeddedFlinkDatabaseHistory

Modifier and Type	Constant Field	Value
public static final String	DATABASE_HISTORY_INSTANCE_NAME	"database.history.instance.name"

org.apache.flink.cdc.connectors.mysql.debezium.dispatcher.EventDispatcherImpl<T extends io.debezium.schema.DataCollectionId>

Modifier and Type	Constant Field	Value
public static final String	HISTORY_RECORD_FIELD	"historyRecord"

org.apache.flink.cdc.connectors.mysql.debezium.dispatcher.SignalEventDispatcher

Modifier and Type	Constant Field	Value
public static final String	BINLOG_FILENAME_OFFSET_KEY	"file"
public static final String	BINLOG_POSITION_OFFSET_KEY	"pos"
public static final String	DATABASE_NAME	"db"
public static final String	SIGNAL_EVENT_KEY_SCHEMA_NAME	"io.debezium.connector.flink.cdc.embedded.watermark.key"
public static final String	SIGNAL_EVENT_VALUE_SCHEMA_NAME	"io.debezium.connector.flink.cdc.embedded.watermark.value"
public static final String	SPLIT_ID_KEY	"split_id"
public static final String	TABLE_NAME	"table"
public static final String	WATERMARK_KIND	"watermark_kind"
public static final String	WATERMARK_SIGNAL	"_split_watermark_signal_"

org.apache.flink.cdc.connectors.mysql.debezium.task.context.StatefulTaskContext.MySqlEventMetadataProvider

Modifier and Type	Constant Field	Value
public static final String	BINLOG_FILENAME_OFFSET_KEY	"file"
public static final String	BINLOG_POSITION_OFFSET_KEY	"pos"
public static final String	BINLOG_ROW_IN_EVENT_OFFSET_KEY	"row"
public static final String	GTID_KEY	"gtid"
public static final String	QUERY_KEY	"query"
public static final String	SERVER_ID_KEY	"server_id"
public static final String	THREAD_KEY	"thread"

org.apache.flink.cdc.connectors.mysql.factory.MySqlDataSourceFactory

Modifier and Type	Constant Field	Value
public static final String	IDENTIFIER	"mysql"

org.apache.flink.cdc.connectors.mysql.source.MySqlEventDeserializer

Modifier and Type	Constant Field	Value
public static final String	SCHEMA_CHANGE_EVENT_KEY_NAME	"io.debezium.connector.mysql.SchemaChangeKey"

org.apache.flink.cdc.connectors.mysql.source.assigners.MySqlBinlogSplitAssigner

Modifier and Type	Constant Field	Value
public static final String	BINLOG_SPLIT_ID	"binlog-split"

org.apache.flink.cdc.connectors.mysql.source.connection.PooledDataSourceFactory

Modifier and Type	Constant Field	Value
public static final String	CONNECTION_POOL_PREFIX	"connection-pool-"
public static final String	JDBC_URL_PATTERN	"jdbc:mysql://%s:%s/?useInformationSchema=true&nullCatalogMeansCurrent=false&useUnicode=true"
public static final int	MINIMUM_POOL_SIZE	1
public static final String	SERVER_TIMEZONE_KEY	"serverTimezone"

org.apache.flink.cdc.connectors.mysql.source.events.BinlogSplitMetaAssembledEvent

Modifier and Type	Constant Field	Value
public static final long	COMPLETE_WITHOUT_META_GENERATION	-1L

org.apache.flink.cdc.connectors.mysql.source.metrics.MySqlSourceReaderMetrics

Modifier and Type	Constant Field	Value
public static final long	UNDEFINED	-1L

org.apache.flink.cdc.connectors.mysql.source.offset.BinlogOffset

Modifier and Type	Constant Field	Value
public static final String	BINLOG_FILENAME_OFFSET_KEY	"file"
public static final String	BINLOG_POSITION_OFFSET_KEY	"pos"
public static final String	EVENTS_TO_SKIP_OFFSET_KEY	"event"
public static final String	GTID_SET_KEY	"gtids"
public static final String	OFFSET_KIND_KEY	"kind"
public static final String	ROWS_TO_SKIP_OFFSET_KEY	"row"
public static final String	SERVER_ID_KEY	"server_id"
public static final String	TIMESTAMP_KEY	"ts_sec"

org.apache.flink.cdc.connectors.mysql.source.utils.RecordUtils

Modifier and Type	Constant Field	Value
public static final String	SCHEMA_CHANGE_EVENT_KEY_NAME	"io.debezium.connector.mysql.SchemaChangeKey"
public static final String	SCHEMA_HEARTBEAT_EVENT_KEY_NAME	"io.debezium.connector.common.Heartbeat"
public static final String	SCHEMA_TRANSACTION_METADATA_EVENT_KEY_NAME	"io.debezium.connector.common.TransactionMetadataKey"

org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseUtils

Modifier and Type	Constant Field	Value
public static final String	BIGINT	"BIGINT"
public static final String	BINARY	"BINARY"
public static final String	BOOLEAN	"BOOLEAN"
public static final String	CHAR	"CHAR"
public static final String	DATE	"DATE"
public static final String	DATETIME	"DATETIME"
public static final String	DECIMAL	"DECIMAL"
public static final String	DOUBLE	"DOUBLE"
public static final String	FLOAT	"FLOAT"
public static final String	INT	"INT"
public static final String	JSON	"JSON"
public static final String	LONGBLOB	"LONGBLOB"
public static final int	MAX_CHAR_SIZE	256
public static final int	MAX_VARBINARY_SIZE	1048576
public static final int	MAX_VARCHAR_SIZE	262144
public static final String	SMALLINT	"SMALLINT"
public static final String	STRING	"STRING"
public static final String	TEXT	"TEXT"
public static final String	TIME	"TIME"
public static final String	TIMESTAMP	"TIMESTAMP"
public static final String	TINYINT	"TINYINT"
public static final String	VARBINARY	"VARBINARY"
public static final String	VARCHAR	"VARCHAR"

org.apache.flink.cdc.connectors.oracle.factory.OracleDataSourceFactory

Modifier and Type	Constant Field	Value
public static final String	IDENTIFIER	"oracle"

org.apache.flink.cdc.connectors.oracle.source.OracleEventDeserializer

Modifier and Type	Constant Field	Value
public static final String	SCHEMA_CHANGE_EVENT_KEY_NAME	"io.debezium.connector.oracle.SchemaChangeKey"

org.apache.flink.cdc.connectors.oracle.source.OraclePooledDataSourceFactory

Modifier and Type	Constant Field	Value
public static final String	JDBC_URL_PATTERN	"jdbc:oracle:thin:@%s:%s:%s"

org.apache.flink.cdc.connectors.oracle.source.meta.offset.RedoLogOffset

Modifier and Type	Constant Field	Value
public static final String	COMMIT_SCN_KEY	"commit_scn"
public static final String	LCR_POSITION_KEY	"lcr_position"
public static final String	SCN_KEY	"scn"

org.apache.flink.cdc.connectors.paimon.sink.PaimonDataSinkFactory

Modifier and Type	Constant Field	Value
public static final String	IDENTIFIER	"paimon"

org.apache.flink.cdc.connectors.paimon.sink.PaimonDataSinkOptions

Modifier and Type	Constant Field	Value
public static final String	PREFIX_CATALOG_PROPERTIES	"catalog.properties."
public static final String	PREFIX_TABLE_PROPERTIES	"table.properties."

org.apache.flink.cdc.connectors.paimon.sink.SchemaChangeProvider

Modifier and Type	Constant Field	Value
public static final String	DEFAULT_DATETIME	"1970-01-01 00:00:00"
public static final String	INVALID_OR_MISSING_DATATIME	"0000-00-00 00:00:00"

org.apache.flink.cdc.connectors.paimon.sink.v2.PaimonSink<InputT>

Modifier and Type	Constant Field	Value
public static final String	DEFAULT_COMMIT_USER	"admin"

org.apache.flink.cdc.connectors.paimon.sink.v2.PaimonWriterState

Modifier and Type	Constant Field	Value
public static final int	VERSION	0

org.apache.flink.cdc.connectors.postgres.factory.PostgresDataSourceFactory

Modifier and Type	Constant Field	Value
public static final String	IDENTIFIER	"postgres"

org.apache.flink.cdc.connectors.postgres.source.PostgresConnectionPoolFactory

Modifier and Type	Constant Field	Value
public static final String	JDBC_URL_PATTERN	"jdbc:postgresql://%s:%s/%s?ApplicationName=%s"

org.apache.flink.cdc.connectors.postgres.table.PostgreSQLDeserializationConverterFactory

Modifier and Type	Constant Field	Value
public static final String	HEXEWKB	"hexewkb"
public static final String	SRID	"srid"

org.apache.flink.cdc.connectors.sqlserver.factory.SqlServerDataSourceFactory

Modifier and Type	Constant Field	Value
public static final String	IDENTIFIER	"sqlserver"

org.apache.flink.cdc.connectors.starrocks.sink.StarRocksDataSinkFactory

Modifier and Type	Constant Field	Value
public static final String	IDENTIFIER	"starrocks"

org.apache.flink.cdc.connectors.starrocks.sink.StarRocksDataSinkOptions

Modifier and Type	Constant Field	Value
public static final String	SINK_PROPERTIES_PREFIX	"sink.properties."
public static final String	TABLE_CREATE_PROPERTIES_PREFIX	"table.create.properties."

org.apache.flink.cdc.connectors.starrocks.sink.StarRocksUtils

Modifier and Type	Constant Field	Value
public static final String	BIGINT	"BIGINT"
public static final String	BOOLEAN	"BOOLEAN"
public static final String	CHAR	"CHAR"
public static final String	DATE	"DATE"
public static final String	DATETIME	"DATETIME"
public static final String	DECIMAL	"DECIMAL"
public static final String	DEFAULT_DATETIME	"1970-01-01 00:00:00"
public static final String	DOUBLE	"DOUBLE"
public static final String	FLOAT	"FLOAT"
public static final String	INT	"INT"
public static final String	INVALID_OR_MISSING_DATATIME	"0000-00-00 00:00:00"
public static final String	JSON	"JSON"
public static final String	LARGEINT	"BIGINT UNSIGNED"
public static final int	MAX_CHAR_SIZE	255
public static final int	MAX_VARBINARY_SIZE	1048576
public static final int	MAX_VARCHAR_SIZE	1048576
public static final String	SMALLINT	"SMALLINT"
public static final String	STRING	"STRING"
public static final String	TINYINT	"TINYINT"
public static final String	VARBINARY	"VARBINARY"
public static final String	VARCHAR	"VARCHAR"

org.apache.flink.cdc.connectors.starrocks.sink.TableCreateConfig

Modifier and Type	Constant Field	Value
public static final int	MAX_UNICODE_CHAR_BYTES	4

org.apache.flink.cdc.connectors.values.factory.ValuesDataFactory

Modifier and Type	Constant Field	Value
public static final String	IDENTIFIER	"values"

org.apache.flink.cdc.debezium.DebeziumSourceFunction<T>

Modifier and Type	Constant Field	Value
public static final String	HISTORY_RECORDS_STATE_NAME	"history-records-states"
public static final String	LEGACY_IMPLEMENTATION_KEY	"internal.implementation"
public static final String	LEGACY_IMPLEMENTATION_VALUE	"legacy"
public static final int	MAX_NUM_PENDING_CHECKPOINTS	100
public static final String	OFFSETS_STATE_NAME	"offset-states"

org.apache.flink.cdc.debezium.event.DebeziumSchemaDataTypeInference

Modifier and Type	Constant Field	Value
public static final int	DEFAULT_DECIMAL_PRECISION	20
public static final String	PRECISION_PARAMETER_KEY	"connect.decimal.precision"

org.apache.flink.cdc.debezium.internal.DebeziumChangeConsumer

Modifier and Type	Constant Field	Value
public static final String	LAST_COMMIT_LSN_KEY	"lsn_commit"
public static final String	LAST_COMPLETELY_PROCESSED_LSN_KEY	"lsn_proc"

org.apache.flink.cdc.debezium.internal.FlinkDatabaseHistory

Modifier and Type	Constant Field	Value
public static final String	DATABASE_HISTORY_INSTANCE_NAME	"database.history.instance.name"

org.apache.flink.cdc.debezium.internal.FlinkDatabaseSchemaHistory

Modifier and Type	Constant Field	Value
public static final String	DATABASE_HISTORY_INSTANCE_NAME	"database.history.instance.name"

org.apache.flink.cdc.debezium.internal.FlinkOffsetBackingStore

Modifier and Type	Constant Field	Value
public static final int	FLUSH_TIMEOUT_SECONDS	10
public static final String	OFFSET_STATE_VALUE	"offset.storage.flink.state.value"

org.apache.flink.cdc.debezium.table.DebeziumOptions

Modifier and Type	Constant Field	Value
public static final String	DEBEZIUM_OPTIONS_PREFIX	"debezium."

org.apache.flink.cdc.debezium.utils.JdbcUrlUtils

Modifier and Type	Constant Field	Value
public static final String	PROPERTIES_PREFIX	"jdbc.properties."

org.apache.flink.cdc.runtime.operators.schema.common.SchemaManager.Serializer

Modifier and Type	Constant Field	Value
public static final int	CURRENT_VERSION	2

org.apache.flink.cdc.runtime.operators.schema.common.event.GetEvolvedSchemaRequest

Modifier and Type	Constant Field	Value
public static final int	LATEST_SCHEMA_VERSION	-1

org.apache.flink.cdc.runtime.operators.schema.common.event.GetOriginalSchemaRequest

Modifier and Type	Constant Field	Value
public static final int	LATEST_SCHEMA_VERSION	-1

org.apache.flink.cdc.runtime.operators.schema.common.metrics.SchemaOperatorMetrics

Modifier and Type	Constant Field	Value
public static final String	NUM_FAILED_SCHEMA_CHANGE_EVENTS	"numFailedSchemaChangeEvents"
public static final String	NUM_FINISHED_SCHEMA_CHANGE_EVENTS	"numFinishedSchemaChangeEvents"
public static final String	NUM_IGNORED_SCHEMA_CHANGE_EVENTS	"numIgnoredSchemaChangeEvents"
public static final String	NUM_SCHEMA_CHANGE_EVENTS	"numSchemaChangeEvents"
public static final String	SCHEMA_CHANGE_BEHAVIOR	"schemaChangeBehavior"

org.apache.flink.cdc.runtime.operators.transform.PreTransformChangeInfo.Serializer

Modifier and Type	Constant Field	Value
public static final int	CURRENT_VERSION	2
public static final int	VERSION_BEFORE_STATE_COMPATIBILITY	1

org.apache.flink.cdc.runtime.operators.transform.converter.PostTransformConverters

Modifier and Type	Constant Field	Value
public static final String	SOFT_DELETE_CONVERTER	"SOFT_DELETE"

org.apache.flink.cdc.runtime.parser.JaninoCompiler

Modifier and Type	Constant Field	Value
public static final String	DEFAULT_AI_MODEL_CLIENTS	"__ai_model_clients__"
public static final String	DEFAULT_EPOCH_TIME	"__epoch_time__"
public static final String	DEFAULT_TIME_ZONE	"__time_zone__"

org.apache.flink.cdc.runtime.parser.metadata.MetadataColumns

Modifier and Type	Constant Field	Value
public static final String	DEFAULT_DATA_EVENT_TYPE	"__data_event_type__"
public static final String	DEFAULT_NAMESPACE_NAME	"__namespace_name__"
public static final String	DEFAULT_SCHEMA_NAME	"__schema_name__"
public static final String	DEFAULT_TABLE_NAME	"__table_name__"