Path	Lines of Code
hudi-kafka-connect/src/main/java/org/apache/hudi/connect/HoodieSinkConnector.java	46
hudi-kafka-connect/src/main/java/org/apache/hudi/connect/HoodieSinkTask.java	165
hudi-kafka-connect/src/main/java/org/apache/hudi/connect/KafkaConnectFileIdPrefixProvider.java	28
hudi-kafka-connect/src/main/java/org/apache/hudi/connect/kafka/KafkaConnectControlAgent.java	149
hudi-kafka-connect/src/main/java/org/apache/hudi/connect/kafka/KafkaControlAgent.java	11
hudi-kafka-connect/src/main/java/org/apache/hudi/connect/kafka/KafkaControlProducer.java	41
hudi-kafka-connect/src/main/java/org/apache/hudi/connect/transaction/ConnectTransactionCoordinator.java	347
hudi-kafka-connect/src/main/java/org/apache/hudi/connect/transaction/ConnectTransactionParticipant.java	221
hudi-kafka-connect/src/main/java/org/apache/hudi/connect/transaction/CoordinatorEvent.java	37
hudi-kafka-connect/src/main/java/org/apache/hudi/connect/transaction/TransactionCoordinator.java	9
hudi-kafka-connect/src/main/java/org/apache/hudi/connect/transaction/TransactionInfo.java	32
hudi-kafka-connect/src/main/java/org/apache/hudi/connect/transaction/TransactionParticipant.java	13
hudi-kafka-connect/src/main/java/org/apache/hudi/connect/utils/KafkaConnectUtils.java	170
hudi-kafka-connect/src/main/java/org/apache/hudi/connect/writers/AbstractConnectWriter.java	66
hudi-kafka-connect/src/main/java/org/apache/hudi/connect/writers/BufferedConnectWriter.java	95
hudi-kafka-connect/src/main/java/org/apache/hudi/connect/writers/ConnectTransactionServices.java	10
hudi-kafka-connect/src/main/java/org/apache/hudi/connect/writers/ConnectWriter.java	8
hudi-kafka-connect/src/main/java/org/apache/hudi/connect/writers/ConnectWriterProvider.java	4
hudi-kafka-connect/src/main/java/org/apache/hudi/connect/writers/KafkaConnectConfigs.java	184
hudi-kafka-connect/src/main/java/org/apache/hudi/connect/writers/KafkaConnectTransactionServices.java	128
hudi-kafka-connect/src/main/java/org/apache/hudi/connect/writers/KafkaConnectWriterProvider.java	81
hudi-kafka-connect/src/main/resources/ControlMessage.proto	56