MCPcopy Create free account

hub / github.com/canthny/big-data / types & classes

Types & classes53 in github.com/canthny/big-data

⨍ Functions 214◇ Types & classes 53
ClassAssets
This class was automatically generated by the data modeler tool.
drools_kie_demo/src/main/java/com/canthny/drools_kie_demo/domain/Assets.java:7
ClassBaseRequest
@Author： Canthny @Description： 一次支付请求参数 @Date： Created in 2018/9/11 15:17
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/domain/request/BaseRequest.java:12
ClassBroadcastMsgProducerTest
Description： kafka生成交易消息 Created By tanghao on 2020/4/7
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/test/BroadcastMsgProducerTest.java:16
ClassBroadcastTableTest
Description： 广播维表动态更新测试，对应的数据源为BroadcastMsgProducerTest产生的数据 场景：上游的消息中仅包含id和code之类的数据要转化成对应的类目名称，从字典表或者动态广播流中获取映射关系，并且支持类目名称可更新或者开关控制 Created By tangh
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/others/BroadcastTableTest.java:27
ClassConstantKafka
Description： kafka常量 Created By tanghao on 2020/4/7
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/common/ConstantKafka.java:7
ClassDateUtil
Date Utility Class used to convert Strings to Dates and Timestamps @author <a href="mailto:matt@raibledesigns.com">Matt Raible</a> Modified by
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/util/DateUtil.java:19
ClassDefeatMapReduceObject
@Author： Canthny @Description： mapreduce后默认输出对象 @Date： Created in 2018/9/30 0:35
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/domain/DefeatMapReduceObject.java:13
ClassDroolKieTestDemo
Description： kie-server动态部署demo测试 Created By tanghao on 2019/7/22
drools_kie_demo/src/main/java/com/canthny/drools_kie_demo/test/DroolKieTestDemo.java:24
ClassDroolsStarter
@Author： Canthny @Description： 启动类 @Date： Created in 2018/9/11 16:43
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/DroolsStarter.java:12
EnumEnumRuleResponseLevel
@Author： Canthny @Description： 风控响应级别 @Date： Created in 2018/9/11 15:23
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/enums/EnumRuleResponseLevel.java:8
ClassFilterApiTest
Description： FilterApi测试类 Created By tanghao on 2020/4/1
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/datastream/FilterApiTest.java:14
ClassFlatMapApiTest
Description： FlatMapApi测试类 Created By tanghao on 2020/4/1
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/datastream/FlatMapApiTest.java:15
ClassGetPayInfoJob
@Author： Canthny @Description： 获取支付信息日志流计算job @Date： Created in 2018/9/13 2:06
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/GetPayInfoJob.java:33
ClassGlobalWindowTest
Description： TODO Created By tanghao on 2020/4/7
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/window/GlobalWindowTest.java:7
ClassInnerSource
Description： 内置数据源 Created By tanghao on 2020/3/31
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/source/InnerSource.java:16
ClassIntegerRedisSerializer
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/redis/RedisConfig.java:41
ClassKafkaSource
Description： TODO Created By tanghao on 2020/4/8
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/source/KafkaSource.java:20
ClassKeyByApiTest
Description： KeyByApi测试类 Created By tanghao on 2020/4/1
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/datastream/KeyByApiTest.java:18
ClassMapApiTest
Description： MapApi测试 Created By tanghao on 2020/3/31
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/datastream/MapApiTest.java:17
ClassMessage
Description： 消息POJO类 Created By tanghao on 2020/4/1
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/common/Message.java:12
ClassMessageDeserializationSchema
Description： TODO Created By tanghao on 2020/4/8
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/common/MessageDeserializationSchema.java:12
ClassMobilePaymentInfo
@Author： Canthny @Description： 手机缴费信息对象 @Date： Created in 2018/9/27 14:35
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/domain/MobilePaymentInfo.java:15
ClassMobilePaymentInfoConfig
@Author： Canthny @Description： 手机充值消息配置 @Date： Created in 2018/9/29 10:24
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/kafka/config/MobilePaymentInfoConfig.java:17
ClassMobilePaymentInfoListener
@Author： Canthny @Description： 手机充值消息监听者 @Date： Created in 2018/9/29 10:27
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/kafka/listener/MobilePaymentInfoListener.java:16
InterfaceMobilePaymentInfoService
@Author： Canthny @Description： 手机缴费信息接口 @Date： Created in 2018/9/27 14:46
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/mongodb/service/MobilePaymentInfoService.java:10
ClassMobilePaymentInfoServiceImpl
@Author： Canthny @Description： 手机缴费信息接口实现类 @Date： Created in 2018/9/27 14:47
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/mongodb/service/impl/MobilePaymentInfoServiceImpl.java:14
ClassMobilePaymentRequest
@Author： Canthny @Description： 手机充值请求对象 @Date： Created in 2018/9/29 19:44
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/domain/request/MobilePaymentRequest.java:10
ClassMobilePaymentRuleService
@Author： Canthny @Description： 缴费规则服务 @Date： Created in 2018/9/30 0:12
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/service/MobilePaymentRuleService.java:20
ClassMsgProducerTest
Description： 消息生成器 Created By tanghao on 2020/4/8
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/test/MsgProducerTest.java:18
ClassMySumAggregate
这里禁止使用RichFunction,暂时不清楚为何这样设计，说是这样使用状态不正确
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/window/TumblingWindowAggregateFunctionTest.java:77
ClassPhoneNoBlackObject
@Author： Canthny @Description： 手机号黑名单 @Date： Created in 2018/9/29 16:06
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/domain/PhoneNoBlackObject.java:13
ClassPhoneNoBlacklistService
@Author： Canthny @Description： 手机号黑名单 @Date： Created in 2018/9/29 15:54
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/service/PhoneNoBlacklistService.java:25
ClassRedisConfig
@Author： Canthny @Description： redis模板类序列化问题配置 @Date： Created in 2018/9/29 21:40
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/redis/RedisConfig.java:18
ClassRuleResponse
@Author： Canthny @Description： 风控响应对象 @Date： Created in 2018/9/11 15:22
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/domain/response/RuleResponse.java:12
ClassSessionWindowTest
Description： TODO Created By tanghao on 2020/4/7
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/window/SessionWindowTest.java:7
ClassSlidingWindowTest
Description： 滑动窗口场景——每5s刷新一次最近1分钟消费总金额用户排名top3 Created By tanghao on 2020/4/7
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/window/SlidingWindowTest.java:27
ClassSpringMongoConfig
@Author： Canthny @Description： mongodb配置 @Date： Created in 2018/9/29 11:21
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/mongodb/config/SpringMongoConfig.java:21
ClassTestAction
@Author： Canthny @Description： 测试一些api @Date： Created in 2018/9/13 15:15
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/TestAction.java:13
ClassTestDrools
@Author： Canthny @Description： drools单元测试类 @Date： Created in 2018/9/29 19:51
tanghao-bigdata-drools/src/test/java/com/tanghao/bigdata/drools/test/TestDrools.java:28
ClassTestKafkaProduct
@Author： Canthny @Description： kafka生产者测试 @Date： Created in 2018/9/29 15:02
tanghao-bigdata-drools/src/test/java/com/tanghao/bigdata/drools/test/TestKafkaProduct.java:20
ClassTestMongodb
@Author： Canthny @Description： mongodb测试类 @Date： Created in 2018/9/27 14:54
tanghao-bigdata-drools/src/test/java/com/tanghao/bigdata/drools/test/TestMongodb.java:33
ClassTestMongodbJob
@Author： Canthny @Description： @Date： Created in 2018/9/29 15:29
tanghao-bigdata-drools/src/test/java/com/tanghao/bigdata/drools/test/TestMongodbJob.java:8
ClassTestPayRule
@Author： Canthny @Description： 测试支付风控拦截 @Date： Created in 2018/9/11 15:18
tanghao-bigdata-drools/src/main/java/com/tanghao/bigdata/drools/controller/TestPayRule.java:20
ClassTestRuleService
@Author： Canthny @Description： 规则服务类测试 @Date： Created in 2018/9/30 0:49
tanghao-bigdata-drools/src/test/java/com/tanghao/bigdata/drools/test/TestRuleService.java:16
ClassTradeCountMinuteResult
Description： 交易统计小时结果 Created By tanghao on 2020/4/9
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/common/TradeCountMinuteResult.java:9
ClassTransTypeInfo
Description： 交易类型信息 Created By tanghao on 2020/4/8
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/common/TransTypeInfo.java:9
ClassTumblingWindowAggregateFunctionTest
Description： 滚动窗口测试 场景：根据transCode统计每分钟充值、提现、消费等各类型交易总金额；并且根据userId统计用户分钟消费金额。 Created By tanghao on 2020/4/7
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/window/TumblingWindowAggregateFunctionTest.java:34
ClassTumblingWindowProcessWindowFunctionTest
Description： 滚动窗口测试 场景：根据transCode统计每分钟充值、提现、消费等各类型交易总金额；并且根据userId统计用户分钟消费金额。 Created By tanghao on 2020/4/7
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/window/TumblingWindowProcessWindowFunctionTest.java:29
ClassTumblingWindowUseEventTimeTest
Description： 使用事件时间 Created By tanghao on 2020/4/9
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/window/TumblingWindowUseEventTimeTest.java:23
ClassUnionAndSplitStreamTest
Description： 合并数据源 Created By tanghao on 2020/4/2
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/datastream/UnionAndSplitStreamTest.java:19
ClassUserConsumerAmountPerMinute
Description： 用户每分钟消费金额统计对象 Created By tanghao on 2020/4/9
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/common/UserConsumerAmountPerMinute.java:9
ClassUserConsumerAmountPerMinuteComparator
tanghao-flink-demo/src/main/java/com/tanghao/flink/demo/api/window/SlidingWindowTest.java:93
ClassUserInfo
This class was automatically generated by the data modeler tool.
drools_kie_demo/src/main/java/com/canthny/drools_kie_demo/domain/UserInfo.java:7