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
↓ 18 callers
Method
add
(Message value, Map<Long, UserConsumerAmountPerMinute> accumulator)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/window/SlidingWindowTest.java:57
↓ 15 callers
Method
getTransCode
()
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/common/Message.java:66
↓ 14 callers
Method
getAmount
()
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/common/Message.java:74
↓ 12 callers
Method
getTime
()
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/domain/MobilePaymentInfo.java:77
↓ 9 callers
Method
setTime
(Date time)
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/domain/MobilePaymentInfo.java:81
↓ 8 callers
Method
getUserId
()
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/common/Message.java:99
↓ 6 callers
Method
convertDateToString
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 callers
Method
fromCollection
(StreamExecutionEnvironment streamExecutionEnvironment)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/source/InnerSource.java:37
↓ 6 callers
Method
getRelativeDate
取得从startDate开始的前(正)/后(负)day天 @param startDate @param day @return date
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/util/DateUtil.java:223
↓ 5 callers
Method
getResponse
()
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/domain/request/BaseRequest.java:22
↓ 5 callers
Method
setAccountNo
(String accountNo)
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/domain/request/MobilePaymentRequest.java:28
↓ 5 callers
Method
setAmount
(Integer amount)
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/domain/request/MobilePaymentRequest.java:52
↓ 5 callers
Method
setBankCardNo
(String bankCardNo)
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/domain/request/MobilePaymentRequest.java:36
↓ 5 callers
Method
setMobile
(String mobile)
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/domain/request/MobilePaymentRequest.java:44
↓ 5 callers
Method
setOutTradeDate
(String outTradeDate)
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/domain/request/MobilePaymentRequest.java:60
↓ 4 callers
Method
getDatePattern
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 callers
Method
getValue
()
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/domain/DefeatMapReduceObject.java:29
↓ 3 callers
Method
generatorUserId
()
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/common/Message.java:94
↓ 3 callers
Method
getDateTime
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 callers
Method
process
(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 callers
Method
setAccountNo
(String accountNo)
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/domain/MobilePaymentInfo.java:49
↓ 3 callers
Method
setAmount
(Long amount)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/common/UserConsumerAmountPerMinute.java:29
↓ 3 callers
Method
setAmount
(Integer amount)
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/domain/MobilePaymentInfo.java:73
↓ 3 callers
Method
setBankCardNo
(String bankCardNo)
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/domain/MobilePaymentInfo.java:57
↓ 3 callers
Method
setMobile
(String mobile)
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/domain/MobilePaymentInfo.java:65
↓ 3 callers
Method
setPayOrderNo
(String payOrderNo)
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/domain/MobilePaymentInfo.java:41
↓ 2 callers
Method
convertStringToDate
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 callers
Method
filter
(String s)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/datastream/FilterApiTest.java:21
↓ 2 callers
Method
getId
()
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/common/Message.java:58
↓ 2 callers
Method
getPhoneNo
()
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/domain/PhoneNoBlackObject.java:21
↓ 2 callers
Method
getSumAmount
()
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/common/TradeCountMinuteResult.java:25
↓ 2 callers
Method
map
(String s)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/others/BroadcastTableTest.java:36
↓ 2 callers
Method
mongoDbFactory
()
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/mongodb/config/SpringMongoConfig.java:26
↓ 2 callers
Method
saveMobilePaymentInfo
(MobilePaymentInfo info)
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/mongodb/service/MobilePaymentInfoService.java:12
↓ 2 callers
Method
setCurrentMinute
(String currentMinute)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/common/UserConsumerAmountPerMinute.java:37
↓ 2 callers
Method
setCurrentMinute
(String currentMinute)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/common/TradeCountMinuteResult.java:37
↓ 2 callers
Method
setSumAmount
(Long sumAmount)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/common/TradeCountMinuteResult.java:29
↓ 2 callers
Method
setUserId
(Long userId)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/common/UserConsumerAmountPerMinute.java:21
↓ 2 callers
Method
toString
()
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/common/Message.java:107
↓ 1 callers
Method
filter
(Message value)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/window/SlidingWindowTest.java:41
↓ 1 callers
Method
flatMap
flatMap相对于Map和filter更灵活,不仅仅一对一,也可以过滤也可以一对多
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/datastream/FlatMapApiTest.java:24
↓ 1 callers
Method
fromFile
(StreamExecutionEnvironment streamExecutionEnvironment)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/source/InnerSource.java:27
↓ 1 callers
Method
generatorId
()
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/common/Message.java:90
↓ 1 callers
Method
getAmount
()
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/common/UserConsumerAmountPerMinute.java:25
↓ 1 callers
Method
getAvgAmountPerMonthByAccountNo
(String accountNo)
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/service/MobilePaymentRuleService.java:38
↓ 1 callers
Method
getCode
()
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/enums/EnumRuleResponseLevel.java:20
↓ 1 callers
Method
getCurrentMinute
()
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/common/TradeCountMinuteResult.java:33
↓ 1 callers
Method
getDesc
()
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/enums/EnumRuleResponseLevel.java:28
↓ 1 callers
Method
getDescByCode
(String code)
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/enums/EnumRuleResponseLevel.java:41
↓ 1 callers
Method
getId
()
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/domain/DefeatMapReduceObject.java:21
↓ 1 callers
Method
getKey
(Message message)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/window/TumblingWindowProcessWindowFunctionTest.java:47
↓ 1 callers
Method
getPhoneNoBlackListFromMongoDb
()
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/service/PhoneNoBlacklistService.java:56
↓ 1 callers
Method
getResult
(Map<Long, UserConsumerAmountPerMinute> accumulator)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/window/SlidingWindowTest.java:73
↓ 1 callers
Method
getTradeTime
()
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/common/Message.java:82
↓ 1 callers
Method
getTransName
()
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/common/TransTypeInfo.java:25
↓ 1 callers
Method
isBlack
(String phoneNo)
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/service/PhoneNoBlacklistService.java:43
↓ 1 callers
Method
isOpen
()
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/common/TransTypeInfo.java:33
↓ 1 callers
Method
map
(ObjectNode jsonNodes)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/GetPayInfoJob.java:61
↓ 1 callers
Method
map
(String s)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/window/TumblingWindowUseEventTimeTest.java:31
↓ 1 callers
Method
map
(String s)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/window/TumblingWindowProcessWindowFunctionTest.java:37
↓ 1 callers
Method
map
(String s)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/window/TumblingWindowAggregateFunctionTest.java:42
↓ 1 callers
Method
map
(String s)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/window/SlidingWindowTest.java:35
↓ 1 callers
Method
map
(String s)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/datastream/MapApiTest.java:24
↓ 1 callers
Method
reduce
(Tuple2<String, Long> v1, Tuple2<String, Long> v2)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/GetPayInfoJob.java:77
↓ 1 callers
Method
reduce
(Message message, Message message2)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/datastream/KeyByApiTest.java:37
↓ 1 callers
Method
sendMessage
(KafkaProducer<String, String> producer)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/test/BroadcastMsgProducerTest.java:43
↓ 1 callers
Method
sendTransTypeInfo
发送维表配置的交易类型信息 isOpen字段标识开关,如果打开可以在接收的消息中根据transCode去TRANS_TYPE_MAP得到transName @param producer
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/test/BroadcastMsgProducerTest.java:35
↓ 1 callers
Method
setAge
(java.lang.Integer age)
drools_kie_demo/src/main/java/com/canthny/drools_kie_demo/domain/UserInfo.java:43
↓ 1 callers
Method
setAssets
(com.canthny.drools_kie_demo.domain.Assets assets)
drools_kie_demo/src/main/java/com/canthny/drools_kie_demo/domain/UserInfo.java:67
↓ 1 callers
Method
setFund
(java.lang.Long fund)
drools_kie_demo/src/main/java/com/canthny/drools_kie_demo/domain/Assets.java:38
↓ 1 callers
Method
setId
(java.lang.Long id)
drools_kie_demo/src/main/java/com/canthny/drools_kie_demo/domain/UserInfo.java:27
↓ 1 callers
Method
setMoney
(java.lang.Long money)
drools_kie_demo/src/main/java/com/canthny/drools_kie_demo/domain/Assets.java:22
↓ 1 callers
Method
setName
(java.lang.String name)
drools_kie_demo/src/main/java/com/canthny/drools_kie_demo/domain/UserInfo.java:35
↓ 1 callers
Method
setOpen
(boolean open)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/common/TransTypeInfo.java:37
↓ 1 callers
Method
setPhoneNo
(String phoneNo)
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/domain/PhoneNoBlackObject.java:25
↓ 1 callers
Method
setStock
(java.lang.Long stock)
drools_kie_demo/src/main/java/com/canthny/drools_kie_demo/domain/Assets.java:30
↓ 1 callers
Method
setTransCode
(String transCode)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/common/TransTypeInfo.java:21
↓ 1 callers
Method
setTransCode
(String transCode)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/common/Message.java:70
↓ 1 callers
Method
setTransCode
(String transCode)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/common/TradeCountMinuteResult.java:21
↓ 1 callers
Method
setTransName
(String transName)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/common/TransTypeInfo.java:29
↓ 1 callers
Method
testTumblingEventTimeWindows
(KeyedStream<Tuple2<String, Long>, Tuple> keyBy)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/GetPayInfoJob.java:74
Method
Assets
()
drools_kie_demo/src/main/java/com/canthny/drools_kie_demo/domain/Assets.java:15
Method
DateUtil
Checkstyle rule: utility classes should not have public constructor
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/util/DateUtil.java:34
Method
EnumRuleResponseLevel
(String code, String desc)
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/enums/EnumRuleResponseLevel.java:36
Method
IntegerRedisSerializer
()
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/redis/RedisConfig.java:45
Method
Message
符合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
Method
RuleResponse
(String code, String level, String msg)
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/domain/response/RuleResponse.java:16
Method
UserInfo
()
drools_kie_demo/src/main/java/com/canthny/drools_kie_demo/domain/UserInfo.java:20
Method
add
(Message value, TradeCountMinuteResult accumulator)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/window/TumblingWindowAggregateFunctionTest.java:107
Method
checkIsNull
(RuleResponse response)
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/domain/response/RuleResponse.java:52
Method
compare
(UserConsumerAmountPerMinute o1, UserConsumerAmountPerMinute o2)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/window/SlidingWindowTest.java:94
Method
compareDate
判断当前时间是否大于传入时间加传入天数 @param date 传入日期 @param day 增加天数 @return true or false
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/util/DateUtil.java:321
Method
containerProperties
()
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/kafka/config/MobilePaymentInfoConfig.java:24
Method
converStringToTimestamp
String转化为Timestamp:
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/util/DateUtil.java:56
Method
converTimestampToString
Timestamp和String之间转换的函数:
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/util/DateUtil.java:40
Method
countDays
统计两个时间差,返回的是天数(即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
Method
createAccumulator
()
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/window/TumblingWindowAggregateFunctionTest.java:103
Method
createAccumulator
()
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/window/SlidingWindowTest.java:53
Method
deserialize
(byte[] bytes)
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/common/MessageDeserializationSchema.java:13
Method
deserialize
(byte[] bytes)
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/redis/RedisConfig.java:54
next →
1–100 of 214, ranked by callers