leonardBang / flink-sql-etl

Code / Commits / eb554a6
add
Leonard Xu Leonard Xu committed on Apr 24, 2020, 05:26 AM
Showing 9 changed files +381 additions -21 deletions
A data-generator/src/main/resources/test_nonexistedTable.csv +3
A etl-job/src/main/java/TestGen.java +68
M etl-job/src/main/java/kafka2es/Kafka2dynamicEsSQL.java +24 -4
M etl-job/src/main/java/kafka2file/StreamETLKafka2Hdfs.java +2
M etl-job/src/main/java/kafka2file/TestCsv2Csv.java +9 -8
A etl-job/src/main/java/kafka2file/TestFileSink.scala +57
A etl-job/src/main/java/kafka2jdbc/retract2Mysql.java +130
A etl-job/src/main/java/kafka2jdbc/testNonExistedTable.java +79
M pom.xml +9 -9
Browse files at this commit →