Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/canthny/big-data
/ functions
Functions
214 in github.com/canthny/big-data
⨍
Functions
214
◇
Types & classes
53
Method
extractAscendingTimestamp
(Message element)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/window/TumblingWindowUseEventTimeTest.java:35
Method
extractTimestamp
(ObjectNode element)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/GetPayInfoJob.java:47
Method
findPhonenNoBlackList
mongodb查询,指定查询条件和查询结果字段
tanghao-bigdata-drools/src/test/java/com/tanghao/bigdata/drools/test/TestMongodb.java:103
Method
getAccountNo
()
drools_kie_demo/src/main/java/com/canthny/drools_kie_demo/domain/UserInfo.java:47
Method
getAccountNo
()
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/domain/MobilePaymentInfo.java:45
Method
getAccountNo
()
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/domain/request/MobilePaymentRequest.java:24
Method
getAge
()
drools_kie_demo/src/main/java/com/canthny/drools_kie_demo/domain/UserInfo.java:39
Method
getAmount
()
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/domain/MobilePaymentInfo.java:69
Method
getAmount
()
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/domain/request/MobilePaymentRequest.java:48
Method
getAssets
()
drools_kie_demo/src/main/java/com/canthny/drools_kie_demo/domain/UserInfo.java:63
Method
getBankCardNo
()
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/domain/MobilePaymentInfo.java:53
Method
getBankCardNo
()
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/domain/request/MobilePaymentRequest.java:32
Method
getCalendarToday
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
Method
getCode
()
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/domain/response/RuleResponse.java:28
Method
getCountDays
计算当前日期到结束日期的天小时分钟 @param endDate @return string
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/util/DateUtil.java:291
Method
getCountPerHourByAccountNo
从缓存中获取流计算结果,该用户一小时内充值次数 @param accountNo @return
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/service/MobilePaymentRuleService.java:61
Method
getCurrentMinute
()
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/common/UserConsumerAmountPerMinute.java:33
Method
getCurrentTimestamp
()
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/util/DateUtil.java:349
Method
getDate
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
Method
getDateTimePattern
()
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/util/DateUtil.java:79
Method
getDay
根据日期获取星期几 @param date java.util.Date对象,不能为null @return int
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/util/DateUtil.java:255
Method
getFund
()
drools_kie_demo/src/main/java/com/canthny/drools_kie_demo/domain/Assets.java:34
Method
getId
()
drools_kie_demo/src/main/java/com/canthny/drools_kie_demo/domain/UserInfo.java:23
Method
getKey
(Message message)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/window/TumblingWindowUseEventTimeTest.java:42
Method
getKey
(Message message)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/window/TumblingWindowAggregateFunctionTest.java:52
Method
getKey
(Message value)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/window/SlidingWindowTest.java:49
Method
getKey
(Message message)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/datastream/KeyByApiTest.java:30
Method
getLevel
()
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/domain/response/RuleResponse.java:36
Method
getMobile
()
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/domain/MobilePaymentInfo.java:61
Method
getMobile
()
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/domain/request/MobilePaymentRequest.java:40
Method
getMoney
()
drools_kie_demo/src/main/java/com/canthny/drools_kie_demo/domain/Assets.java:18
Method
getMsg
()
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/domain/response/RuleResponse.java:44
Method
getName
()
drools_kie_demo/src/main/java/com/canthny/drools_kie_demo/domain/UserInfo.java:31
Method
getNextDay
得到一个时间延后或前移几天的时间,nowdate为时间,delay为前移或后延的天数 @param nowdate yyyyMMdd @param delay @return
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/util/DateUtil.java:360
Method
getOutTradeDate
()
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/domain/request/MobilePaymentRequest.java:56
Method
getPayOrderNo
()
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/domain/MobilePaymentInfo.java:37
Method
getProducedType
()
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/common/MessageDeserializationSchema.java:21
Method
getRelativeMinute
取得从startDate开始的前(正)/后(负)minute分 @param startDate @param minute @return date
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/util/DateUtil.java:236
Method
getResult
(TradeCountMinuteResult accumulator)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/window/TumblingWindowAggregateFunctionTest.java:153
Method
getRisk_type
()
drools_kie_demo/src/main/java/com/canthny/drools_kie_demo/domain/UserInfo.java:55
Method
getStock
()
drools_kie_demo/src/main/java/com/canthny/drools_kie_demo/domain/Assets.java:26
Method
getTimeByHour
当期时间的前后几小时 @param hour @return
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/util/DateUtil.java:383
Method
getTimeNow
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
Method
getTodayYYYYMMDD
获取8位数字的今天日期格式 @return
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/util/DateUtil.java:281
Method
getTransCode
()
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/common/TransTypeInfo.java:17
Method
getTransCode
()
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/common/TradeCountMinuteResult.java:17
Method
getUserId
()
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/common/UserConsumerAmountPerMinute.java:17
Method
getWeek
根据字符串日期获取对应的星期 @param time @return @throws ParseException
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/util/DateUtil.java:397
Method
getWholeDay
功能:天数向上取整,velocity使用<br> @param in @return int
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/util/DateUtil.java:341
Method
init
()
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/service/MobilePaymentRuleService.java:31
Method
init
()
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/service/PhoneNoBlacklistService.java:36
Method
insertPhoneNoBlackList
插入黑名单数据
tanghao-bigdata-drools/src/test/java/com/tanghao/bigdata/drools/test/TestMongodb.java:72
Method
isEndOfStream
(Message message)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/common/MessageDeserializationSchema.java:17
Method
main
(String[] args)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/TestAction.java:15
Method
main
(String[] args)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/GetPayInfoJob.java:35
Method
main
(String[] args)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/source/InnerSource.java:18
Method
main
(String[] args)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/source/KafkaSource.java:22
Method
main
(String[] args)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/test/BroadcastMsgProducerTest.java:18
Method
main
(String[] args)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/test/MsgProducerTest.java:21
Method
main
(String[] args)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/window/TumblingWindowUseEventTimeTest.java:24
Method
main
(String[] args)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/window/TumblingWindowProcessWindowFunctionTest.java:31
Method
main
(String[] args)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/window/TumblingWindowAggregateFunctionTest.java:36
Method
main
(String[] args)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/window/SlidingWindowTest.java:29
Method
main
(String[] args)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/others/BroadcastTableTest.java:29
Method
main
(String[] args)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/datastream/KeyByApiTest.java:20
Method
main
(String[] args)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/datastream/UnionAndSplitStreamTest.java:21
Method
main
(String[] args)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/datastream/MapApiTest.java:19
Method
main
(String[] args)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/datastream/FlatMapApiTest.java:17
Method
main
(String[] args)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/datastream/FilterApiTest.java:16
Method
main
(String[] args)
drools_kie_demo/src/main/java/com/canthny/drools_kie_demo/test/DroolKieTestDemo.java:26
Method
main
(String[] args)
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/DroolsStarter.java:15
Method
main
(String[] args)
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/domain/MobilePaymentInfo.java:97
Method
merge
(TradeCountMinuteResult a, TradeCountMinuteResult b)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/window/TumblingWindowAggregateFunctionTest.java:157
Method
merge
(Map<Long, UserConsumerAmountPerMinute> a, Map<Long, UserConsumerAmountPerMinute> b)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/window/SlidingWindowTest.java:79
Method
messageListenerContainer
(ConsumerFactory<String, String> consumerFactory,
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/kafka/config/MobilePaymentInfoConfig.java:31
Method
mongoTemplate
()
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/mongodb/config/SpringMongoConfig.java:31
Method
onMessage
(ConsumerRecord<String, String> stringStringConsumerRecord)
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/kafka/listener/MobilePaymentInfoListener.java:23
Method
open
(Configuration parameters)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/window/TumblingWindowAggregateFunctionTest.java:82
Method
processBroadcastElement
(TransTypeInfo value, Context ctx, Collector<Tuple2<Message, String>> out)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/others/BroadcastTableTest.java:64
Method
processElement
(Message value, ReadOnlyContext ctx, Collector<Tuple2<Message, String>> out)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/others/BroadcastTableTest.java:56
Method
processElement
(Message value, Context ctx, Collector<Message> out)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/datastream/UnionAndSplitStreamTest.java:44
Method
redisTemplate
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
Method
saveMobilePaymentInfo
(MobilePaymentInfo info)
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/mongodb/service/impl/MobilePaymentInfoServiceImpl.java:20
Method
serialize
(Integer num)
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/redis/RedisConfig.java:58
Method
setAccountNo
(java.lang.String accountNo)
drools_kie_demo/src/main/java/com/canthny/drools_kie_demo/domain/UserInfo.java:51
Method
setAmount
(Long amount)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/common/Message.java:78
Method
setCode
(String code)
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/domain/response/RuleResponse.java:32
Method
setCode
(String code)
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/enums/EnumRuleResponseLevel.java:24
Method
setDesc
(String desc)
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/enums/EnumRuleResponseLevel.java:32
Method
setId
(String id)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/common/Message.java:62
Method
setId
(String id)
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/domain/DefeatMapReduceObject.java:25
Method
setLevel
(String level)
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/domain/response/RuleResponse.java:40
Method
setMsg
(String msg)
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/domain/response/RuleResponse.java:48
Method
setResponse
(String code,String level,String desc)
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/domain/request/BaseRequest.java:18
Method
setRisk_type
(java.lang.String risk_type)
drools_kie_demo/src/main/java/com/canthny/drools_kie_demo/domain/UserInfo.java:59
Method
setTradeTime
(Date tradeTime)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/common/Message.java:86
Method
setUserId
(Long userId)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/common/Message.java:103
Method
setValue
(Integer value)
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/domain/DefeatMapReduceObject.java:33
Method
testCase1
测试case1:金额超限
tanghao-bigdata-drools/src/test/java/com/tanghao/bigdata/drools/test/TestDrools.java:35
Method
testCase2
该银行卡号在黑名单内(银行卡黑名单表) 手机号在黑名单内(手机号黑名单表)
tanghao-bigdata-drools/src/test/java/com/tanghao/bigdata/drools/test/TestDrools.java:73
← previous
next →
101–200 of 214, ranked by callers