Path	Lines of Code
kafka-connect/kafka-connect-events/src/main/java/org/apache/iceberg/connect/events/AvroUtil.java	67
kafka-connect/kafka-connect-events/src/main/java/org/apache/iceberg/connect/events/CommitComplete.java	72
kafka-connect/kafka-connect-events/src/main/java/org/apache/iceberg/connect/events/CommitToTable.java	102
kafka-connect/kafka-connect-events/src/main/java/org/apache/iceberg/connect/events/DataComplete.java	76
kafka-connect/kafka-connect-events/src/main/java/org/apache/iceberg/connect/events/DataWritten.java	118
kafka-connect/kafka-connect-events/src/main/java/org/apache/iceberg/connect/events/Event.java	110
kafka-connect/kafka-connect-events/src/main/java/org/apache/iceberg/connect/events/Payload.java	7
kafka-connect/kafka-connect-events/src/main/java/org/apache/iceberg/connect/events/PayloadType.java	15
kafka-connect/kafka-connect-events/src/main/java/org/apache/iceberg/connect/events/StartCommit.java	56
kafka-connect/kafka-connect-events/src/main/java/org/apache/iceberg/connect/events/TableReference.java	107
kafka-connect/kafka-connect-events/src/main/java/org/apache/iceberg/connect/events/TopicPartitionOffset.java	91
kafka-connect/kafka-connect-runtime/src/integration/java/org/apache/iceberg/connect/IntegrationDynamicTableTest.java	53
kafka-connect/kafka-connect-runtime/src/integration/java/org/apache/iceberg/connect/IntegrationMultiTableTest.java	57
kafka-connect/kafka-connect-runtime/src/integration/java/org/apache/iceberg/connect/IntegrationTest.java	123
kafka-connect/kafka-connect-runtime/src/integration/java/org/apache/iceberg/connect/IntegrationTestBase.java	180
kafka-connect/kafka-connect-runtime/src/integration/java/org/apache/iceberg/connect/KafkaConnectUtils.java	95
kafka-connect/kafka-connect-runtime/src/integration/java/org/apache/iceberg/connect/TestContext.java	95
kafka-connect/kafka-connect-runtime/src/integration/java/org/apache/iceberg/connect/TestEvent.java	82
kafka-connect/kafka-connect-transforms/src/main/java/org/apache/iceberg/connect/transforms/CdcConstants.java	13
kafka-connect/kafka-connect-transforms/src/main/java/org/apache/iceberg/connect/transforms/CopyValue.java	92
kafka-connect/kafka-connect-transforms/src/main/java/org/apache/iceberg/connect/transforms/DebeziumTransform.java	187
kafka-connect/kafka-connect-transforms/src/main/java/org/apache/iceberg/connect/transforms/DmsTransform.java	70
kafka-connect/kafka-connect-transforms/src/main/java/org/apache/iceberg/connect/transforms/JsonToMapException.java	9
kafka-connect/kafka-connect-transforms/src/main/java/org/apache/iceberg/connect/transforms/JsonToMapTransform.java	120
kafka-connect/kafka-connect-transforms/src/main/java/org/apache/iceberg/connect/transforms/JsonToMapUtils.java	256
kafka-connect/kafka-connect-transforms/src/main/java/org/apache/iceberg/connect/transforms/KafkaMetadataTransform.java	242
kafka-connect/kafka-connect-transforms/src/main/java/org/apache/iceberg/connect/transforms/MongoDebeziumTransform.java	234
kafka-connect/kafka-connect-transforms/src/main/java/org/debezium/connector/mongodb/transforms/ArrayEncoding.java	30
kafka-connect/kafka-connect-transforms/src/main/java/org/debezium/connector/mongodb/transforms/MongoDataConverter.java	438
kafka-connect/kafka-connect/src/main/java/org/apache/iceberg/connect/CatalogUtils.java	66
kafka-connect/kafka-connect/src/main/java/org/apache/iceberg/connect/Committer.java	23
kafka-connect/kafka-connect/src/main/java/org/apache/iceberg/connect/CommitterFactory.java	8
kafka-connect/kafka-connect/src/main/java/org/apache/iceberg/connect/IcebergSinkConfig.java	383
kafka-connect/kafka-connect/src/main/java/org/apache/iceberg/connect/IcebergSinkConnector.java	43
kafka-connect/kafka-connect/src/main/java/org/apache/iceberg/connect/IcebergSinkTask.java	72
kafka-connect/kafka-connect/src/main/java/org/apache/iceberg/connect/TableSinkConfig.java	28
kafka-connect/kafka-connect/src/main/java/org/apache/iceberg/connect/channel/Channel.java	123
kafka-connect/kafka-connect/src/main/java/org/apache/iceberg/connect/channel/CommitState.java	126
kafka-connect/kafka-connect/src/main/java/org/apache/iceberg/connect/channel/CommitterImpl.java	157
kafka-connect/kafka-connect/src/main/java/org/apache/iceberg/connect/channel/Coordinator.java	264
kafka-connect/kafka-connect/src/main/java/org/apache/iceberg/connect/channel/CoordinatorThread.java	42
kafka-connect/kafka-connect/src/main/java/org/apache/iceberg/connect/channel/Envelope.java	21
kafka-connect/kafka-connect/src/main/java/org/apache/iceberg/connect/channel/KafkaClientFactory.java	44
kafka-connect/kafka-connect/src/main/java/org/apache/iceberg/connect/channel/KafkaUtils.java	70
kafka-connect/kafka-connect/src/main/java/org/apache/iceberg/connect/channel/NotRunningException.java	6
kafka-connect/kafka-connect/src/main/java/org/apache/iceberg/connect/channel/Worker.java	88
kafka-connect/kafka-connect/src/main/java/org/apache/iceberg/connect/data/IcebergWriter.java	95
kafka-connect/kafka-connect/src/main/java/org/apache/iceberg/connect/data/IcebergWriterFactory.java	104
kafka-connect/kafka-connect/src/main/java/org/apache/iceberg/connect/data/IcebergWriterResult.java	34
kafka-connect/kafka-connect/src/main/java/org/apache/iceberg/connect/data/NoOpWriter.java	16
kafka-connect/kafka-connect/src/main/java/org/apache/iceberg/connect/data/Offset.java	28
kafka-connect/kafka-connect/src/main/java/org/apache/iceberg/connect/data/PartitionedAppendWriter.java	32
kafka-connect/kafka-connect/src/main/java/org/apache/iceberg/connect/data/RecordConverter.java	468
kafka-connect/kafka-connect/src/main/java/org/apache/iceberg/connect/data/RecordUtils.java	140
kafka-connect/kafka-connect/src/main/java/org/apache/iceberg/connect/data/RecordWriter.java	8
kafka-connect/kafka-connect/src/main/java/org/apache/iceberg/connect/data/SchemaUpdate.java	80
kafka-connect/kafka-connect/src/main/java/org/apache/iceberg/connect/data/SchemaUtils.java	300
kafka-connect/kafka-connect/src/main/java/org/apache/iceberg/connect/data/SinkWriter.java	103
kafka-connect/kafka-connect/src/main/java/org/apache/iceberg/connect/data/SinkWriterResult.java	19