MCPcopy Create free account

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

Functions214 in github.com/canthny/big-data

↓ 18 callersMethodadd
(Message value, Map<Long, UserConsumerAmountPerMinute> accumulator)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/window/SlidingWindowTest.java:57
↓ 15 callersMethodgetTransCode
()
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/common/Message.java:66
↓ 14 callersMethodgetAmount
()
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/common/Message.java:74
↓ 12 callersMethodgetTime
()
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/domain/MobilePaymentInfo.java:77
↓ 9 callersMethodsetTime
(Date time)
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/domain/MobilePaymentInfo.java:81
↓ 8 callersMethodgetUserId
()
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/common/Message.java:99
↓ 6 callersMethodconvertDateToString
This method generates a string representation of a date based on the System Property 'dateFormat' in the format you specify on input @param aDate
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/util/DateUtil.java:192
↓ 6 callersMethodfromCollection
(StreamExecutionEnvironment streamExecutionEnvironment)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/source/InnerSource.java:37
↓ 6 callersMethodgetRelativeDate
取得从startDate开始的前(正)/后(负)day天 @param startDate @param day @return date
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/util/DateUtil.java:223
↓ 5 callersMethodgetResponse
()
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/domain/request/BaseRequest.java:22
↓ 5 callersMethodsetAccountNo
(String accountNo)
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/domain/request/MobilePaymentRequest.java:28
↓ 5 callersMethodsetAmount
(Integer amount)
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/domain/request/MobilePaymentRequest.java:52
↓ 5 callersMethodsetBankCardNo
(String bankCardNo)
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/domain/request/MobilePaymentRequest.java:36
↓ 5 callersMethodsetMobile
(String mobile)
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/domain/request/MobilePaymentRequest.java:44
↓ 5 callersMethodsetOutTradeDate
(String outTradeDate)
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/domain/request/MobilePaymentRequest.java:60
↓ 4 callersMethodgetDatePattern
Return default datePattern (MM/dd/yyyy) @return a string representing the date pattern on the UI
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/util/DateUtil.java:66
↓ 4 callersMethodgetValue
()
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/domain/DefeatMapReduceObject.java:29
↓ 3 callersMethodgeneratorUserId
()
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/common/Message.java:94
↓ 3 callersMethodgetDateTime
This method generates a string representation of a date's date/time in the format you specify on input @param aMask the date pattern the s
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/util/DateUtil.java:170
↓ 3 callersMethodprocess
(String s, Context context, Iterable<Message> elements, Collector<TradeCountMinuteResult> out)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/window/TumblingWindowProcessWindowFunctionTest.java:51
↓ 3 callersMethodsetAccountNo
(String accountNo)
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/domain/MobilePaymentInfo.java:49
↓ 3 callersMethodsetAmount
(Long amount)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/common/UserConsumerAmountPerMinute.java:29
↓ 3 callersMethodsetAmount
(Integer amount)
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/domain/MobilePaymentInfo.java:73
↓ 3 callersMethodsetBankCardNo
(String bankCardNo)
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/domain/MobilePaymentInfo.java:57
↓ 3 callersMethodsetMobile
(String mobile)
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/domain/MobilePaymentInfo.java:65
↓ 3 callersMethodsetPayOrderNo
(String payOrderNo)
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/domain/MobilePaymentInfo.java:41
↓ 2 callersMethodconvertStringToDate
This method generates a string representation of a date/time in the format you specify on input @param aMask the date pattern the string i
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/util/DateUtil.java:116
↓ 2 callersMethodfilter
(String s)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/datastream/FilterApiTest.java:21
↓ 2 callersMethodgetId
()
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/common/Message.java:58
↓ 2 callersMethodgetPhoneNo
()
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/domain/PhoneNoBlackObject.java:21
↓ 2 callersMethodgetSumAmount
()
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/common/TradeCountMinuteResult.java:25
↓ 2 callersMethodmap
(String s)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/others/BroadcastTableTest.java:36
↓ 2 callersMethodmongoDbFactory
()
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/mongodb/config/SpringMongoConfig.java:26
↓ 2 callersMethodsaveMobilePaymentInfo
(MobilePaymentInfo info)
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/mongodb/service/MobilePaymentInfoService.java:12
↓ 2 callersMethodsetCurrentMinute
(String currentMinute)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/common/UserConsumerAmountPerMinute.java:37
↓ 2 callersMethodsetCurrentMinute
(String currentMinute)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/common/TradeCountMinuteResult.java:37
↓ 2 callersMethodsetSumAmount
(Long sumAmount)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/common/TradeCountMinuteResult.java:29
↓ 2 callersMethodsetUserId
(Long userId)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/common/UserConsumerAmountPerMinute.java:21
↓ 2 callersMethodtoString
()
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/common/Message.java:107
↓ 1 callersMethodfilter
(Message value)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/window/SlidingWindowTest.java:41
↓ 1 callersMethodflatMap
flatMap相对于Map和filter更灵活,不仅仅一对一,也可以过滤也可以一对多
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/datastream/FlatMapApiTest.java:24
↓ 1 callersMethodfromFile
(StreamExecutionEnvironment streamExecutionEnvironment)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/source/InnerSource.java:27
↓ 1 callersMethodgeneratorId
()
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/common/Message.java:90
↓ 1 callersMethodgetAmount
()
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/common/UserConsumerAmountPerMinute.java:25
↓ 1 callersMethodgetAvgAmountPerMonthByAccountNo
(String accountNo)
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/service/MobilePaymentRuleService.java:38
↓ 1 callersMethodgetCode
()
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/enums/EnumRuleResponseLevel.java:20
↓ 1 callersMethodgetCurrentMinute
()
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/common/TradeCountMinuteResult.java:33
↓ 1 callersMethodgetDesc
()
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/enums/EnumRuleResponseLevel.java:28
↓ 1 callersMethodgetDescByCode
(String code)
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/enums/EnumRuleResponseLevel.java:41
↓ 1 callersMethodgetId
()
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/domain/DefeatMapReduceObject.java:21
↓ 1 callersMethodgetKey
(Message message)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/window/TumblingWindowProcessWindowFunctionTest.java:47
↓ 1 callersMethodgetPhoneNoBlackListFromMongoDb
()
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/service/PhoneNoBlacklistService.java:56
↓ 1 callersMethodgetResult
(Map<Long, UserConsumerAmountPerMinute> accumulator)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/window/SlidingWindowTest.java:73
↓ 1 callersMethodgetTradeTime
()
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/common/Message.java:82
↓ 1 callersMethodgetTransName
()
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/common/TransTypeInfo.java:25
↓ 1 callersMethodisBlack
(String phoneNo)
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/service/PhoneNoBlacklistService.java:43
↓ 1 callersMethodisOpen
()
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/common/TransTypeInfo.java:33
↓ 1 callersMethodmap
(ObjectNode jsonNodes)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/GetPayInfoJob.java:61
↓ 1 callersMethodmap
(String s)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/window/TumblingWindowUseEventTimeTest.java:31
↓ 1 callersMethodmap
(String s)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/window/TumblingWindowProcessWindowFunctionTest.java:37
↓ 1 callersMethodmap
(String s)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/window/TumblingWindowAggregateFunctionTest.java:42
↓ 1 callersMethodmap
(String s)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/window/SlidingWindowTest.java:35
↓ 1 callersMethodmap
(String s)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/datastream/MapApiTest.java:24
↓ 1 callersMethodreduce
(Tuple2<String, Long> v1, Tuple2<String, Long> v2)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/GetPayInfoJob.java:77
↓ 1 callersMethodreduce
(Message message, Message message2)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/datastream/KeyByApiTest.java:37
↓ 1 callersMethodsendMessage
(KafkaProducer<String, String> producer)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/test/BroadcastMsgProducerTest.java:43
↓ 1 callersMethodsendTransTypeInfo
发送维表配置的交易类型信息 isOpen字段标识开关,如果打开可以在接收的消息中根据transCode去TRANS_TYPE_MAP得到transName @param producer
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/test/BroadcastMsgProducerTest.java:35
↓ 1 callersMethodsetAge
(java.lang.Integer age)
drools_kie_demo/src/main/java/com/canthny/drools_kie_demo/domain/UserInfo.java:43
↓ 1 callersMethodsetAssets
(com.canthny.drools_kie_demo.domain.Assets assets)
drools_kie_demo/src/main/java/com/canthny/drools_kie_demo/domain/UserInfo.java:67
↓ 1 callersMethodsetFund
(java.lang.Long fund)
drools_kie_demo/src/main/java/com/canthny/drools_kie_demo/domain/Assets.java:38
↓ 1 callersMethodsetId
(java.lang.Long id)
drools_kie_demo/src/main/java/com/canthny/drools_kie_demo/domain/UserInfo.java:27
↓ 1 callersMethodsetMoney
(java.lang.Long money)
drools_kie_demo/src/main/java/com/canthny/drools_kie_demo/domain/Assets.java:22
↓ 1 callersMethodsetName
(java.lang.String name)
drools_kie_demo/src/main/java/com/canthny/drools_kie_demo/domain/UserInfo.java:35
↓ 1 callersMethodsetOpen
(boolean open)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/common/TransTypeInfo.java:37
↓ 1 callersMethodsetPhoneNo
(String phoneNo)
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/domain/PhoneNoBlackObject.java:25
↓ 1 callersMethodsetStock
(java.lang.Long stock)
drools_kie_demo/src/main/java/com/canthny/drools_kie_demo/domain/Assets.java:30
↓ 1 callersMethodsetTransCode
(String transCode)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/common/TransTypeInfo.java:21
↓ 1 callersMethodsetTransCode
(String transCode)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/common/Message.java:70
↓ 1 callersMethodsetTransCode
(String transCode)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/common/TradeCountMinuteResult.java:21
↓ 1 callersMethodsetTransName
(String transName)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/common/TransTypeInfo.java:29
↓ 1 callersMethodtestTumblingEventTimeWindows
(KeyedStream<Tuple2<String, Long>, Tuple> keyBy)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/GetPayInfoJob.java:74
MethodAssets
()
drools_kie_demo/src/main/java/com/canthny/drools_kie_demo/domain/Assets.java:15
MethodDateUtil
Checkstyle rule: utility classes should not have public constructor
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/util/DateUtil.java:34
MethodEnumRuleResponseLevel
(String code, String desc)
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/enums/EnumRuleResponseLevel.java:36
MethodIntegerRedisSerializer
()
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/redis/RedisConfig.java:45
MethodMessage
符合POJO类的规则: The class is public and standalone (no non-static inner class) The class has a public no-argument constructor All non-static, non-transien
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/common/Message.java:29
MethodRuleResponse
(String code, String level, String msg)
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/domain/response/RuleResponse.java:16
MethodUserInfo
()
drools_kie_demo/src/main/java/com/canthny/drools_kie_demo/domain/UserInfo.java:20
Methodadd
(Message value, TradeCountMinuteResult accumulator)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/window/TumblingWindowAggregateFunctionTest.java:107
MethodcheckIsNull
(RuleResponse response)
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/domain/response/RuleResponse.java:52
Methodcompare
(UserConsumerAmountPerMinute o1, UserConsumerAmountPerMinute o2)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/window/SlidingWindowTest.java:94
MethodcompareDate
判断当前时间是否大于传入时间加传入天数 @param date 传入日期 @param day 增加天数 @return true or false
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/util/DateUtil.java:321
MethodcontainerProperties
()
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/kafka/config/MobilePaymentInfoConfig.java:24
MethodconverStringToTimestamp
String转化为Timestamp:
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/util/DateUtil.java:56
MethodconverTimestampToString
Timestamp和String之间转换的函数:
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/util/DateUtil.java:40
MethodcountDays
统计两个时间差,返回的是天数(即24小时算一天,少于24小时就为0,用这个的时候最好把小时、分钟等去掉) @param beginStr 开始时间 @param endStr @param format @return day
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/util/DateUtil.java:270
MethodcreateAccumulator
()
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/window/TumblingWindowAggregateFunctionTest.java:103
MethodcreateAccumulator
()
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/window/SlidingWindowTest.java:53
Methoddeserialize
(byte[] bytes)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/common/MessageDeserializationSchema.java:13
Methoddeserialize
(byte[] bytes)
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/redis/RedisConfig.java:54
next →1–100 of 214, ranked by callers