Skip to content

Changes

Summary

  1. 企业所属的监管区域 (details)
Commit 15a7c77553e6c22cc29cd25004a7ba9c8144967c by linhancheng
企业所属的监管区域
The file was addedsrc/streaming-event-platform/flink-event-udf/pom.xml
The file was addedsrc/streaming-event-platform/log.file.1
The file was modified src/streaming-event-platform/pom.xml
The file was modified src/streaming-event-platform/event-tasks/flink-cdc-kafka-source-task/src/main/java/com/bcxin/flink/cdc/kafka/source/task/JdbcBinLogCaptureApp.java
The file was addedsrc/streaming-event-platform/event-tasks/flink-cdc-kafka-source-task/src/main/java/com/bcxin/flink/cdc/kafka/source/task/utils/RecordHeadUtil.java
The file was modified src/streaming-event-platform/event-tasks/flink-cdc-kafka-source-task/src/main/java/com/bcxin/flink/cdc/kafka/source/task/jobs/DbStreamCdcKafkaJob.java
The file was addedsrc/streaming-event-platform/flink-event-udf/src/main/java/com/bcxin/flink/event/udfs/RegionDispatchFunction.java
The file was addedsrc/streaming-event-platform/log.file
The file was addedsrc/streaming-event-platform/event-tasks/flink-cdc-kafka-source-task/src/main/java/com/bcxin/flink/cdc/kafka/source/task/compnents/JdbcDbReaderComponent.java