Path	Lines of Code
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/annotation/Experimental.java	19
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/annotation/Internal.java	8
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/annotation/Public.java	8
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/annotation/PublicEvolving.java	8
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/annotation/VisibleForTesting.java	8
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/ConfigOption.java	109
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/ConfigOptions.java	86
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/Configuration.java	214
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/ConfigurationUtils.java	240
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/FallbackKey.java	40
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/StructuredOptionsSplitter.java	131
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/description/BlockElement.java	4
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/description/Description.java	45
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/description/DescriptionElement.java	6
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/description/Formatter.java	67
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/description/HtmlFormatter.java	44
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/description/InlineElement.java	4
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/description/LineBreakElement.java	13
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/description/LinkElement.java	27
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/description/ListElement.java	21
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/description/TextElement.java	48
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/ArrayData.java	118
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/DecimalData.java	113
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericArrayData.java	230
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericMapData.java	74
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/LocalZonedTimestampData.java	94
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/MapData.java	9
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/RecordData.java	108
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/StringData.java	9
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/TimestampData.java	85
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/ZonedTimestampData.java	110
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinaryArrayData.java	433
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinaryFormat.java	12
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinaryMapData.java	73
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinaryRecordData.java	205
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySection.java	52
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySegmentUtils.java	779
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinaryStringData.java	615
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/LazyBinaryFormat.java	66
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/MurmurHashUtils.java	107
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/NullAwareGetters.java	7
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/AddColumnEvent.java	126
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/AlterColumnTypeEvent.java	109
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/ChangeEvent.java	6
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/CreateTableEvent.java	49
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/DataChangeEvent.java	183
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/DropColumnEvent.java	54
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/DropTableEvent.java	43
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/Event.java	4
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/EventDeserializer.java	8
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/FlushEvent.java	53
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/OperationType.java	9
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/RenameColumnEvent.java	49
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/SchemaChangeEvent.java	8
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/SchemaChangeEventType.java	58
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/SchemaChangeEventTypeFamily.java	53
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/SchemaChangeEventWithPreSchema.java	11
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java	82
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TruncateTableEvent.java	43
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/visitor/AddColumnEventVisitor.java	8
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/visitor/AlterColumnTypeEventVisitor.java	8
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/visitor/CreateTableEventVisitor.java	8
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/visitor/DropColumnEventVisitor.java	8
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/visitor/DropTableEventVisitor.java	8
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/visitor/RenameColumnEventVisitor.java	8
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/visitor/SchemaChangeEventVisitor.java	63
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/visitor/TruncateTableEventVisitor.java	8
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/exceptions/SchemaEvolveException.java	42
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/exceptions/UnsupportedSchemaChangeEventException.java	29
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/factories/DataSinkFactory.java	7
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/factories/DataSourceFactory.java	7
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/factories/Factory.java	17
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/factories/FactoryHelper.java	131
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/function/HashFunction.java	6
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/function/HashFunctionProvider.java	12
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/pipeline/PipelineOptions.java	76
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/pipeline/RuntimeExecutionMode.java	7
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/pipeline/SchemaChangeBehavior.java	10
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/route/RouteRule.java	16
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/schema/Column.java	134
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/schema/MetadataColumn.java	49
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/schema/PhysicalColumn.java	27
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/schema/Schema.java	291
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/schema/Selectors.java	85
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/schema/TableFilter.java	13
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/sink/DataSink.java	16
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/sink/DefaultDataChangeEventHashFunctionProvider.java	66
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/sink/EventSinkProvider.java	6
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/sink/FlinkSinkFunctionProvider.java	11
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/sink/FlinkSinkProvider.java	11
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/sink/MetadataApplier.java	26
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/source/DataSource.java	15
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/source/EventSourceProvider.java	6
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/source/FlinkSourceFunctionProvider.java	11
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/source/FlinkSourceProvider.java	11
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/source/MetadataAccessor.java	13
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/source/SupportedMetadataColumn.java	13
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/text/ParsingException.java	20
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/text/Position.java	48
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/text/TokenStream.java	357
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ArrayType.java	61
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BigIntType.java	31
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BinaryType.java	83
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/BooleanType.java	31
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/CharType.java	83
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataField.java	83
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataType.java	74
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataTypeChecks.java	158
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataTypeDefaultVisitor.java	86
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataTypeFamily.java	20
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataTypeRoot.java	57
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataTypeVisitor.java	25
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataTypes.java	164
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DateType.java	31
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DecimalType.java	83
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DoubleType.java	31
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/FloatType.java	31
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/IntType.java	31
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/LocalZonedTimestampType.java	72
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/MapType.java	67
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/RowType.java	174
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/SmallIntType.java	31
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimeType.java	67
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TimestampType.java	71
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/TinyIntType.java	31
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarBinaryType.java	74
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/VarCharType.java	74
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/ZonedTimestampType.java	71
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/utils/DataTypeUtils.java	168
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/utils/runtime/DataInputViewStream.java	38
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/utils/runtime/DataOutputViewStream.java	18
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/udf/UserDefinedFunction.java	15
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/udf/UserDefinedFunctionContext.java	5
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/utils/ChangeEventUtils.java	88
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/utils/DateTimeUtils.java	181
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/utils/EncodingUtils.java	14
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/utils/InstantiationUtil.java	185
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/utils/Preconditions.java	75
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/utils/Predicates.java	143
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/utils/SchemaMergingUtils.java	818
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/utils/SchemaUtils.java	488
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/utils/StringUtf8Utils.java	195
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/utils/StringUtils.java	34
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/utils/TestCaseUtils.java	58
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/utils/ThreadLocalCache.java	50
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/utils/TimeUtils.java	139
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/utils/TypeCheckUtils.java	94