MCPcopy Create free account

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

Functions214 in github.com/canthny/big-data

MethodextractAscendingTimestamp
(Message element)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/window/TumblingWindowUseEventTimeTest.java:35
MethodextractTimestamp
(ObjectNode element)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/GetPayInfoJob.java:47
MethodfindPhonenNoBlackList
mongodb查询,指定查询条件和查询结果字段
tanghao-bigdata-drools/src/test/java/com/tanghao/bigdata/drools/test/TestMongodb.java:103
MethodgetAccountNo
()
drools_kie_demo/src/main/java/com/canthny/drools_kie_demo/domain/UserInfo.java:47
MethodgetAccountNo
()
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/domain/MobilePaymentInfo.java:45
MethodgetAccountNo
()
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/domain/request/MobilePaymentRequest.java:24
MethodgetAge
()
drools_kie_demo/src/main/java/com/canthny/drools_kie_demo/domain/UserInfo.java:39
MethodgetAmount
()
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/domain/MobilePaymentInfo.java:69
MethodgetAmount
()
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/domain/request/MobilePaymentRequest.java:48
MethodgetAssets
()
drools_kie_demo/src/main/java/com/canthny/drools_kie_demo/domain/UserInfo.java:63
MethodgetBankCardNo
()
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/domain/MobilePaymentInfo.java:53
MethodgetBankCardNo
()
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/domain/request/MobilePaymentRequest.java:32
MethodgetCalendarToday
This method returns the current date in the format: MM/dd/yyyy @return the current date @throws ParseException when String doesn't match
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/util/DateUtil.java:153
MethodgetCode
()
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/domain/response/RuleResponse.java:28
MethodgetCountDays
计算当前日期到结束日期的天小时分钟 @param endDate @return string
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/util/DateUtil.java:291
MethodgetCountPerHourByAccountNo
从缓存中获取流计算结果,该用户一小时内充值次数 @param accountNo @return
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/service/MobilePaymentRuleService.java:61
MethodgetCurrentMinute
()
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/common/UserConsumerAmountPerMinute.java:33
MethodgetCurrentTimestamp
()
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/util/DateUtil.java:349
MethodgetDate
This method attempts to convert an Oracle-formatted date in the form dd-MMM-yyyy to mm/dd/yyyy. @param aDate date from database as a strin
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/util/DateUtil.java:91
MethodgetDateTimePattern
()
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/util/DateUtil.java:79
MethodgetDay
根据日期获取星期几 @param date java.util.Date对象,不能为null @return int
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/util/DateUtil.java:255
MethodgetFund
()
drools_kie_demo/src/main/java/com/canthny/drools_kie_demo/domain/Assets.java:34
MethodgetId
()
drools_kie_demo/src/main/java/com/canthny/drools_kie_demo/domain/UserInfo.java:23
MethodgetKey
(Message message)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/window/TumblingWindowUseEventTimeTest.java:42
MethodgetKey
(Message message)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/window/TumblingWindowAggregateFunctionTest.java:52
MethodgetKey
(Message value)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/window/SlidingWindowTest.java:49
MethodgetKey
(Message message)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/datastream/KeyByApiTest.java:30
MethodgetLevel
()
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/domain/response/RuleResponse.java:36
MethodgetMobile
()
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/domain/MobilePaymentInfo.java:61
MethodgetMobile
()
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/domain/request/MobilePaymentRequest.java:40
MethodgetMoney
()
drools_kie_demo/src/main/java/com/canthny/drools_kie_demo/domain/Assets.java:18
MethodgetMsg
()
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/domain/response/RuleResponse.java:44
MethodgetName
()
drools_kie_demo/src/main/java/com/canthny/drools_kie_demo/domain/UserInfo.java:31
MethodgetNextDay
得到一个时间延后或前移几天的时间,nowdate为时间,delay为前移或后延的天数 @param nowdate yyyyMMdd @param delay @return
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/util/DateUtil.java:360
MethodgetOutTradeDate
()
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/domain/request/MobilePaymentRequest.java:56
MethodgetPayOrderNo
()
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/domain/MobilePaymentInfo.java:37
MethodgetProducedType
()
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/common/MessageDeserializationSchema.java:21
MethodgetRelativeMinute
取得从startDate开始的前(正)/后(负)minute分 @param startDate @param minute @return date
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/util/DateUtil.java:236
MethodgetResult
(TradeCountMinuteResult accumulator)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/window/TumblingWindowAggregateFunctionTest.java:153
MethodgetRisk_type
()
drools_kie_demo/src/main/java/com/canthny/drools_kie_demo/domain/UserInfo.java:55
MethodgetStock
()
drools_kie_demo/src/main/java/com/canthny/drools_kie_demo/domain/Assets.java:26
MethodgetTimeByHour
当期时间的前后几小时 @param hour @return
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/util/DateUtil.java:383
MethodgetTimeNow
This method returns the current date time in the format: MM/dd/yyyy HH:MM a @param theTime the current time @return the current date/time
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/util/DateUtil.java:142
MethodgetTodayYYYYMMDD
获取8位数字的今天日期格式 @return
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/util/DateUtil.java:281
MethodgetTransCode
()
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/common/TransTypeInfo.java:17
MethodgetTransCode
()
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/common/TradeCountMinuteResult.java:17
MethodgetUserId
()
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/common/UserConsumerAmountPerMinute.java:17
MethodgetWeek
根据字符串日期获取对应的星期 @param time @return @throws ParseException
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/util/DateUtil.java:397
MethodgetWholeDay
功能:天数向上取整,velocity使用<br> @param in @return int
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/util/DateUtil.java:341
Methodinit
()
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/service/MobilePaymentRuleService.java:31
Methodinit
()
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/service/PhoneNoBlacklistService.java:36
MethodinsertPhoneNoBlackList
插入黑名单数据
tanghao-bigdata-drools/src/test/java/com/tanghao/bigdata/drools/test/TestMongodb.java:72
MethodisEndOfStream
(Message message)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/common/MessageDeserializationSchema.java:17
Methodmain
(String[] args)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/TestAction.java:15
Methodmain
(String[] args)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/GetPayInfoJob.java:35
Methodmain
(String[] args)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/source/InnerSource.java:18
Methodmain
(String[] args)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/source/KafkaSource.java:22
Methodmain
(String[] args)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/test/BroadcastMsgProducerTest.java:18
Methodmain
(String[] args)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/test/MsgProducerTest.java:21
Methodmain
(String[] args)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/window/TumblingWindowUseEventTimeTest.java:24
Methodmain
(String[] args)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/window/TumblingWindowProcessWindowFunctionTest.java:31
Methodmain
(String[] args)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/window/TumblingWindowAggregateFunctionTest.java:36
Methodmain
(String[] args)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/window/SlidingWindowTest.java:29
Methodmain
(String[] args)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/others/BroadcastTableTest.java:29
Methodmain
(String[] args)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/datastream/KeyByApiTest.java:20
Methodmain
(String[] args)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/datastream/UnionAndSplitStreamTest.java:21
Methodmain
(String[] args)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/datastream/MapApiTest.java:19
Methodmain
(String[] args)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/datastream/FlatMapApiTest.java:17
Methodmain
(String[] args)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/datastream/FilterApiTest.java:16
Methodmain
(String[] args)
drools_kie_demo/src/main/java/com/canthny/drools_kie_demo/test/DroolKieTestDemo.java:26
Methodmain
(String[] args)
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/DroolsStarter.java:15
Methodmain
(String[] args)
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/domain/MobilePaymentInfo.java:97
Methodmerge
(TradeCountMinuteResult a, TradeCountMinuteResult b)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/window/TumblingWindowAggregateFunctionTest.java:157
Methodmerge
(Map<Long, UserConsumerAmountPerMinute> a, Map<Long, UserConsumerAmountPerMinute> b)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/window/SlidingWindowTest.java:79
MethodmessageListenerContainer
(ConsumerFactory<String, String> consumerFactory,
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/kafka/config/MobilePaymentInfoConfig.java:31
MethodmongoTemplate
()
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/mongodb/config/SpringMongoConfig.java:31
MethodonMessage
(ConsumerRecord<String, String> stringStringConsumerRecord)
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/kafka/listener/MobilePaymentInfoListener.java:23
Methodopen
(Configuration parameters)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/window/TumblingWindowAggregateFunctionTest.java:82
MethodprocessBroadcastElement
(TransTypeInfo value, Context ctx, Collector<Tuple2<Message, String>> out)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/others/BroadcastTableTest.java:64
MethodprocessElement
(Message value, ReadOnlyContext ctx, Collector<Tuple2<Message, String>> out)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/others/BroadcastTableTest.java:56
MethodprocessElement
(Message value, Context ctx, Collector<Message> out)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/datastream/UnionAndSplitStreamTest.java:44
MethodredisTemplate
redisTemplate默认jdkSerializeable,key会产生\xac\xed\x00\x05t\x00\x13这样的字符,所以设置成StringRedisSerializer @return
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/redis/RedisConfig.java:29
MethodsaveMobilePaymentInfo
(MobilePaymentInfo info)
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/mongodb/service/impl/MobilePaymentInfoServiceImpl.java:20
Methodserialize
(Integer num)
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/redis/RedisConfig.java:58
MethodsetAccountNo
(java.lang.String accountNo)
drools_kie_demo/src/main/java/com/canthny/drools_kie_demo/domain/UserInfo.java:51
MethodsetAmount
(Long amount)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/common/Message.java:78
MethodsetCode
(String code)
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/domain/response/RuleResponse.java:32
MethodsetCode
(String code)
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/enums/EnumRuleResponseLevel.java:24
MethodsetDesc
(String desc)
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/enums/EnumRuleResponseLevel.java:32
MethodsetId
(String id)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/common/Message.java:62
MethodsetId
(String id)
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/domain/DefeatMapReduceObject.java:25
MethodsetLevel
(String level)
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/domain/response/RuleResponse.java:40
MethodsetMsg
(String msg)
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/domain/response/RuleResponse.java:48
MethodsetResponse
(String code,String level,String desc)
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/domain/request/BaseRequest.java:18
MethodsetRisk_type
(java.lang.String risk_type)
drools_kie_demo/src/main/java/com/canthny/drools_kie_demo/domain/UserInfo.java:59
MethodsetTradeTime
(Date tradeTime)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/common/Message.java:86
MethodsetUserId
(Long userId)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/common/Message.java:103
MethodsetValue
(Integer value)
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/domain/DefeatMapReduceObject.java:33
MethodtestCase1
测试case1:金额超限
tanghao-bigdata-drools/src/test/java/com/tanghao/bigdata/drools/test/TestDrools.java:35
MethodtestCase2
该银行卡号在黑名单内(银行卡黑名单表) 手机号在黑名单内(手机号黑名单表)
tanghao-bigdata-drools/src/test/java/com/tanghao/bigdata/drools/test/TestDrools.java:73
← previousnext →101–200 of 214, ranked by callers