大数据：金融风控系统（springboot + drools），flink流计算，mongodb-源码

[{"title":"（ 64 个子文件 77KB ） 大数据：金融风控系统（springboot + drools），flink流计算，mongodb-源码","children":[{"title":"big-data-master","children":[{"title":"tanghao-flink-demo","children":[{"title":"src","children":[{"title":"README.md <span style='color:#111;'> 51B </span>","children":null,"spread":false},{"title":"main","children":[{"title":"resources","children":[{"title":"log4j.properties <span style='color:#111;'> 235B </span>","children":null,"spread":false}],"spread":true},{"title":"java","children":[{"title":"com","children":[{"title":"tanghao","children":[{"title":"flink","children":[{"title":"demo","children":[{"title":"TestAction.java <span style='color:#111;'> 1.65KB </span>","children":null,"spread":false},{"title":"api","children":[{"title":"others","children":[{"title":"BroadcastTableTest.java <span style='color:#111;'> 5.06KB </span>","children":null,"spread":false}],"spread":true},{"title":"datastream","children":[{"title":"FilterApiTest.java <span style='color:#111;'> 1.73KB </span>","children":null,"spread":false},{"title":"MapApiTest.java <span style='color:#111;'> 1.57KB </span>","children":null,"spread":false},{"title":"FlatMapApiTest.java <span style='color:#111;'> 1.80KB </span>","children":null,"spread":false},{"title":"KeyByApiTest.java <span style='color:#111;'> 2.40KB </span>","children":null,"spread":false},{"title":"UnionAndSplitStreamTest.java <span style='color:#111;'> 2.76KB </span>","children":null,"spread":false}],"spread":false},{"title":"window","children":[{"title":"TumblingWindowProcessWindowFunctionTest.java <span style='color:#111;'> 6.04KB </span>","children":null,"spread":false},{"title":"SlidingWindowTest.java <span style='color:#111;'> 4.73KB </span>","children":null,"spread":false},{"title":"GlobalWindowTest.java <span style='color:#111;'> 143B </span>","children":null,"spread":false},{"title":"SessionWindowTest.java <span style='color:#111;'> 144B </span>","children":null,"spread":false},{"title":"TumblingWindowAggregateFunctionTest.java <span style='color:#111;'> 7.62KB </span>","children":null,"spread":false},{"title":"TumblingWindowUseEventTimeTest.java <span style='color:#111;'> 2.38KB </span>","children":null,"spread":false}],"spread":false}],"spread":true},{"title":"GetPayInfoJob.java <span style='color:#111;'> 4.17KB </span>","children":null,"spread":false},{"title":"common","children":[{"title":"MessageDeserializationSchema.java <span style='color:#111;'> 614B </span>","children":null,"spread":false},{"title":"Message.java <span style='color:#111;'> 2.81KB </span>","children":null,"spread":false},{"title":"TradeCountMinuteResult.java <span style='color:#111;'> 1.06KB </span>","children":null,"spread":false},{"title":"TransTypeInfo.java <span style='color:#111;'> 995B </span>","children":null,"spread":false},{"title":"UserConsumerAmountPerMinute.java <span style='color:#111;'> 1.02KB </span>","children":null,"spread":false},{"title":"ConstantKafka.java <span style='color:#111;'> 330B </span>","children":null,"spread":false}],"spread":false},{"title":"source","children":[{"title":"InnerSource.java <span style='color:#111;'> 1.64KB </span>","children":null,"spread":false},{"title":"KafkaSource.java <span style='color:#111;'> 1.44KB </span>","children":null,"spread":false}],"spread":false},{"title":"test","children":[{"title":"BroadcastMsgProducerTest.java <span style='color:#111;'> 1.96KB </span>","children":null,"spread":false},{"title":"MsgProducerTest.java <span style='color:#111;'> 1.38KB </span>","children":null,"spread":false}],"spread":false}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true},{"title":"pom.xml <span style='color:#111;'> 4.59KB </span>","children":null,"spread":false}],"spread":true},{"title":".idea","children":[{"title":"uiDesigner.xml <span style='color:#111;'> 8.59KB </span>","children":null,"spread":false}],"spread":true},{"title":"tanghao-bigdata-drools","children":[{"title":"src","children":[{"title":"main","children":[{"title":"resources","children":[{"title":"META-INF","children":[{"title":"kmodule.xml <span style='color:#111;'> 240B </span>","children":null,"spread":false}],"spread":true},{"title":"drools","children":[{"title":"pay_rule2.drl <span style='color:#111;'> 1.13KB </span>","children":null,"spread":false},{"title":"pay_rule.drl <span style='color:#111;'> 1.13KB </span>","children":null,"spread":false}],"spread":true},{"title":"application.properties <span style='color:#111;'> 360B </span>","children":null,"spread":false},{"title":"com.tanghao.bigdata.drools.rules","children":[{"title":"pay_rule.drl <span style='color:#111;'> 2.19KB </span>","children":null,"spread":false}],"spread":true},{"title":"mapreduce","children":[{"title":"mobile_payment_info_reduce.js <span style='color:#111;'> 47B </span>","children":null,"spread":false},{"title":"mobile_payment_info_map.js <span style='color:#111;'> 48B </span>","children":null,"spread":false}],"spread":true}],"spread":true},{"title":"java","children":[{"title":"com","children":[{"title":"tanghao","children":[{"title":"bigdata","children":[{"title":"drools","children":[{"title":"DroolsStarter.java <span style='color:#111;'> 480B </span>","children":null,"spread":false},{"title":"domain","children":[{"title":"PhoneNoBlackObject.java <span style='color:#111;'> 681B </span>","children":null,"spread":false},{"title":"response","children":[{"title":"RuleResponse.java <span style='color:#111;'> 1.41KB </span>","children":null,"spread":false}],"spread":false},{"title":"DefeatMapReduceObject.java <span style='color:#111;'> 949B </span>","children":null,"spread":false},{"title":"MobilePaymentInfo.java <span style='color:#111;'> 2.55KB </span>","children":null,"spread":false},{"title":"request","children":[{"title":"MobilePaymentRequest.java <span style='color:#111;'> 1.27KB </span>","children":null,"spread":false},{"title":"BaseRequest.java <span style='color:#111;'> 625B </span>","children":null,"spread":false}],"spread":false}],"spread":true},{"title":"controller","children":[{"title":"TestPayRule.java <span style='color:#111;'> 1.44KB </span>","children":null,"spread":false}],"spread":false},{"title":"redis","children":[{"title":"RedisConfig.java <span style='color:#111;'> 2.17KB </span>","children":null,"spread":false}],"spread":false},{"title":"util","children":[{"title":"DateUtil.java <span style='color:#111;'> 12.14KB </span>","children":null,"spread":false}],"spread":false},{"title":"enums","children":[{"title":"EnumRuleResponseLevel.java <span style='color:#111;'> 1.04KB </span>","children":null,"spread":false}],"spread":false},{"title":"mongodb","children":[{"title":"service","children":[{"title":"impl","children":[{"title":"MobilePaymentInfoServiceImpl.java <span style='color:#111;'> 767B </span>","children":null,"spread":false}],"spread":false},{"title":"MobilePaymentInfoService.java <span style='color:#111;'> 338B </span>","children":null,"spread":false}],"spread":false},{"title":"config","children":[{"title":"SpringMongoConfig.java <span style='color:#111;'> 1.79KB </span>","children":null,"spread":false}],"spread":false}],"spread":false},{"title":"service","children":[{"title":"MobilePaymentRuleService.java <span style='color:#111;'> 2.61KB </span>","children":null,"spread":false},{"title":"PhoneNoBlacklistService.java <span style='color:#111;'> 2.47KB </span>","children":null,"spread":false}],"spread":false},{"title":"kafka","children":[{"title":"listener","children":[{"title":"MobilePaymentInfoListener.java <span style='color:#111;'> 1.08KB </span>","children":null,"spread":false}],"spread":false},{"title":"config","children":[{"title":"MobilePaymentInfoConfig.java <span style='color:#111;'> 1.43KB </span>","children":null,"spread":false}],"spread":false}],"spread":false}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true},{"title":"test","children":[{"title":"java","children":[{"title":"com","children":[{"title":"tanghao","children":[{"title":"bigdata","children":[{"title":"drools","children":[{"title":"test","children":[{"title":"TestMongodbJob.java <span style='color:#111;'> 164B </span>","children":null,"spread":false},{"title":"TestDrools.java <span style='color:#111;'> 5.74KB </span>","children":null,"spread":false},{"title":"TestRuleService.java <span style='color:#111;'> 956B </span>","children":null,"spread":false},{"title":"TestMongodb.java <span style='color:#111;'> 4.36KB </span>","children":null,"spread":false},{"title":"TestKafkaProduct.java <span style='color:#111;'> 1.26KB </span>","children":null,"spread":false}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true},{"title":"pom.xml <span style='color:#111;'> 3.54KB </span>","children":null,"spread":false},{"title":"README.md <span style='color:#111;'> 3.99KB </span>","children":null,"spread":false}],"spread":true},{"title":"drools_kie_demo","children":[{"title":"src","children":[{"title":"main","children":[{"title":"java","children":[{"title":"com","children":[{"title":"canthny","children":[{"title":"drools_kie_demo","children":[{"title":"domain","children":[{"title":"UserInfo.java <span style='color:#111;'> 1.92KB </span>","children":null,"spread":false},{"title":"Assets.java <span style='color:#111;'> 1012B </span>","children":null,"spread":false}],"spread":true},{"title":"test","children":[{"title":"DroolKieTestDemo.java <span style='color:#111;'> 2.35KB </span>","children":null,"spread":false}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true},{"title":"pom.xml <span style='color:#111;'> 2.00KB </span>","children":null,"spread":false}],"spread":true}],"spread":true}],"spread":true}]