MCPcopy Create free account

hub / github.com/canthny/big-data / functions

Functions214 in github.com/canthny/big-data

MethodtestCase3
当前单笔充值额度大于用户最近一个月充值额度平均值的3倍(定时批处理,月初统计上个月充值平均额度)
tanghao-bigdata-drools/src/test/java/com/tanghao/bigdata/drools/test/TestDrools.java:92
MethodtestCase4
一个小时内充值次数不超过5笔(实时流计算,保留用户一小时充值笔数)
tanghao-bigdata-drools/src/test/java/com/tanghao/bigdata/drools/test/TestDrools.java:111
MethodtestMapReduce
mongodb mapreduce批处理任务,可以通过定时器去执行,也可以通过crontab定时任务方式去执行脚本 计算三天内用户缴费平均值 @throws ParseException
tanghao-bigdata-drools/src/test/java/com/tanghao/bigdata/drools/test/TestMongodb.java:88
MethodtestMobilePaymentRuleService
()
tanghao-bigdata-drools/src/test/java/com/tanghao/bigdata/drools/test/TestRuleService.java:25
MethodtestPayRule
()
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/controller/TestPayRule.java:24
MethodtestPhoneNoBlacklistService
()
tanghao-bigdata-drools/src/test/java/com/tanghao/bigdata/drools/test/TestRuleService.java:20
MethodtestSave
缴费数据插入 @throws ParseException
tanghao-bigdata-drools/src/test/java/com/tanghao/bigdata/drools/test/TestMongodb.java:47
MethodtestSendMobilePaymentInfo
()
tanghao-bigdata-drools/src/test/java/com/tanghao/bigdata/drools/test/TestKafkaProduct.java:27
MethodtoString
()
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/common/TransTypeInfo.java:41
MethodtoString
()
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/common/UserConsumerAmountPerMinute.java:41
MethodtoString
()
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/common/TradeCountMinuteResult.java:41
MethodtoString
()
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/domain/MobilePaymentInfo.java:85
MethodtoString
()
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/domain/DefeatMapReduceObject.java:37
MethodtoString
()
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/domain/response/RuleResponse.java:60
← previous201–214 of 214, ranked by callers