Flink实战项目（保险行业真实项目）

[{"title":"（ 73 个子文件 584KB ） Flink实战项目（保险行业真实项目）","children":[{"title":"klrtdw","children":[{"title":"log","children":[{"title":"test.log <span style='color:#111;'> 2.75MB </span>","children":null,"spread":false}],"spread":true},{"title":"pom.xml <span style='color:#111;'> 6.61KB </span>","children":null,"spread":false},{"title":"target","children":null,"spread":false},{"title":"klrtdw.iml <span style='color:#111;'> 81B </span>","children":null,"spread":false},{"title":"resources","children":[{"title":"prod","children":[{"title":"hive_table_ddl.sql <span style='color:#111;'> 5.54KB </span>","children":null,"spread":false},{"title":"ods_extract_tabs.csv <span style='color:#111;'> 11.30KB </span>","children":null,"spread":false},{"title":"hbase-site.xml <span style='color:#111;'> 7.37KB </span>","children":null,"spread":false},{"title":"mot_tables.csv <span style='color:#111;'> 9.67KB </span>","children":null,"spread":false},{"title":"flink-sql-connector-phoenix-1.14-1.0-SNAPSHOT.jar <span style='color:#111;'> 171.76KB </span>","children":null,"spread":false},{"title":"conf.properties <span style='color:#111;'> 103B </span>","children":null,"spread":false}],"spread":true},{"title":"test","children":[{"title":"tmp.json <span style='color:#111;'> 39.12KB </span>","children":null,"spread":false},{"title":"log4j2.xml <span style='color:#111;'> 670B </span>","children":null,"spread":false},{"title":"tmp.csv <span style='color:#111;'> 6.39KB </span>","children":null,"spread":false},{"title":"conf.properties <span style='color:#111;'> 5B </span>","children":null,"spread":false},{"title":"StreamJob测试方法.txt <span style='color:#111;'> 9.22KB </span>","children":null,"spread":false}],"spread":true}],"spread":true},{"title":"src","children":[{"title":"main","children":[{"title":"java","children":[{"title":"kl","children":[{"title":"func","children":[{"title":"KL_BUCKET.java <span style='color:#111;'> 326B </span>","children":null,"spread":false},{"title":"PHOENIX_JOIN.java <span style='color:#111;'> 2.45KB </span>","children":null,"spread":false},{"title":"PAYENDYEARFLAG.java <span style='color:#111;'> 2.27KB </span>","children":null,"spread":false},{"title":"PAYENDYEAR.java <span style='color:#111;'> 2.12KB </span>","children":null,"spread":false}],"spread":true},{"title":"App.java <span style='color:#111;'> 375B </span>","children":null,"spread":false},{"title":"rtjob","children":[{"title":"ContInfo.java <span style='color:#111;'> 3.68KB </span>","children":null,"spread":false},{"title":"CancellCont.java <span style='color:#111;'> 5.73KB </span>","children":null,"spread":false},{"title":"sink","children":[{"title":"KafkaSink.java <span style='color:#111;'> 1.79KB </span>","children":null,"spread":false},{"title":"PhoenixSink.java <span style='color:#111;'> 3.32KB </span>","children":null,"spread":false}],"spread":false},{"title":"XiBao1.java <span style='color:#111;'> 8.16KB </span>","children":null,"spread":false},{"title":"Kafka2Phoenix.java <span style='color:#111;'> 3.86KB </span>","children":null,"spread":false},{"title":"BackCont.java <span style='color:#111;'> 4.96KB </span>","children":null,"spread":false},{"title":"XiBao2.java <span style='color:#111;'> 7.71KB </span>","children":null,"spread":false},{"title":"scripts","children":[{"title":"datax","children":[{"title":"PHOENIX-IMPORT-O_LIS_LDPLAN.py <span style='color:#111;'> 3.48KB </span>","children":null,"spread":false},{"title":"PHOENIX-IMPORT-O_XG_T02SALESINFO_K.py <span style='color:#111;'> 13.00KB </span>","children":null,"spread":false},{"title":"PHOENIX-IMPORT-O_LIS_LMRISKAPP.py <span style='color:#111;'> 8.59KB </span>","children":null,"spread":false},{"title":"PHOENIX-IMPORT-O_LIS_LBCONT.py <span style='color:#111;'> 13.05KB </span>","children":null,"spread":false},{"title":"PHOENIX-IMPORT-O_LIS_LCCONT.py <span style='color:#111;'> 13.08KB </span>","children":null,"spread":false},{"title":"PHOENIX-IMPORT-O_LIS_LPEDORITEM.py <span style='color:#111;'> 5.20KB </span>","children":null,"spread":false},{"title":"PHOENIX-IMPORT-O_LIS_LCPOL.py <span style='color:#111;'> 14.08KB </span>","children":null,"spread":false},{"title":"说明 <span style='color:#111;'> 148B </span>","children":null,"spread":false},{"title":"PHOENIX-IMPORT-O_LIS_LACOM.py <span style='color:#111;'> 7.16KB </span>","children":null,"spread":false},{"title":"PHOENIX-IMPORT-O_LIS_LDCODE.py <span style='color:#111;'> 2.29KB </span>","children":null,"spread":false},{"title":"PHOENIX-IMPORT-O_LIS_LDBANK.py <span style='color:#111;'> 5.89KB </span>","children":null,"spread":false},{"title":"PHOENIX-IMPORT-O_LIS_LAAGENT.py <span style='color:#111;'> 10.93KB </span>","children":null,"spread":false}],"spread":false},{"title":"sql","children":[{"title":"PHOENIX-TABLE-INIT <span style='color:#111;'> 18.21KB </span>","children":null,"spread":false}],"spread":false},{"title":"kafka","children":[{"title":"GROUP_INIT.sh <span style='color:#111;'> 355B </span>","children":null,"spread":false},{"title":"consumer.properties <span style='color:#111;'> 131B </span>","children":null,"spread":false},{"title":"jaas.conf <span style='color:#111;'> 575B </span>","children":null,"spread":false}],"spread":false},{"title":"submit","children":[{"title":"kafka2Phoenix.sh <span style='color:#111;'> 519B </span>","children":null,"spread":false},{"title":"xiBao2.sh <span style='color:#111;'> 535B </span>","children":null,"spread":false},{"title":"cancellCont.sh <span style='color:#111;'> 554B </span>","children":null,"spread":false},{"title":"backCont.sh <span style='color:#111;'> 540B </span>","children":null,"spread":false},{"title":"contInfo.sh <span style='color:#111;'> 543B </span>","children":null,"spread":false},{"title":"xiBao1.sh <span style='color:#111;'> 535B </span>","children":null,"spread":false}],"spread":false}],"spread":false}],"spread":true},{"title":"tmp","children":[{"title":"App2.java <span style='color:#111;'> 6.12KB </span>","children":null,"spread":false},{"title":"Hbase2Hive.java <span style='color:#111;'> 1.97KB </span>","children":null,"spread":false},{"title":"PhoenixTableTest.java <span style='color:#111;'> 2.70KB </span>","children":null,"spread":false},{"title":"App3.java <span style='color:#111;'> 6.25KB </span>","children":null,"spread":false},{"title":"App1.java <span style='color:#111;'> 3.22KB </span>","children":null,"spread":false}],"spread":true},{"title":"common","children":[{"title":"JobException.java <span style='color:#111;'> 356B </span>","children":null,"spread":false},{"title":"TableDesc.java <span style='color:#111;'> 8.68KB </span>","children":null,"spread":false},{"title":"InforData.java <span style='color:#111;'> 8.43KB </span>","children":null,"spread":false},{"title":"InforDeserialize.java <span style='color:#111;'> 2.66KB </span>","children":null,"spread":false},{"title":"TableConf.java <span style='color:#111;'> 7.56KB </span>","children":null,"spread":false}],"spread":false},{"title":"etl","children":[{"title":"dwd","children":null,"spread":false},{"title":"dws","children":[{"title":"StreamReadMOR.java <span style='color:#111;'> 1.97KB </span>","children":null,"spread":false},{"title":"StreamJoinTest.java <span style='color:#111;'> 4.64KB </span>","children":null,"spread":false}],"spread":false},{"title":"ods","children":[{"title":"StreamJob_start.sh <span style='color:#111;'> 624B </span>","children":null,"spread":false},{"title":"StreamJob.java <span style='color:#111;'> 8.62KB </span>","children":null,"spread":false},{"title":"BatchJob_start.sh <span style='color:#111;'> 603B </span>","children":null,"spread":false},{"title":"BatchJob.java <span style='color:#111;'> 6.13KB </span>","children":null,"spread":false}],"spread":false},{"title":"ads","children":[{"title":"ContCancel.java <span style='color:#111;'> 231B </span>","children":null,"spread":false}],"spread":false}],"spread":false},{"title":"utils","children":[{"title":"CDCUtil.java <span style='color:#111;'> 15.14KB </span>","children":null,"spread":false},{"title":"DateUtil.java <span style='color:#111;'> 2.59KB </span>","children":null,"spread":false},{"title":"JobUtil.java <span style='color:#111;'> 9.10KB </span>","children":null,"spread":false},{"title":"ValidUtil.java <span style='color:#111;'> 778B </span>","children":null,"spread":false},{"title":"SQLUtil.java <span style='color:#111;'> 8.38KB </span>","children":null,"spread":false},{"title":"CompareUtil.java <span style='color:#111;'> 511B </span>","children":null,"spread":false}],"spread":false}],"spread":true}],"spread":true}],"spread":true}],"spread":true},{"title":"${project.basedir}","children":[{"title":"src","children":[{"title":"main","children":[{"title":"site","children":[{"title":"resources","children":[{"title":"repo","children":null,"spread":false}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true},{"title":"README.md <span style='color:#111;'> 3.29KB </span>","children":null,"spread":false}],"spread":true}],"spread":true}]