一 问题 hivesql可以正常运行，spark3.0运行报错如图 spark3.0配置 查看源码新增一个 val STORE_ASSIGNMENT_POLICY = buildConf("spark.sql.storeAssignmentPolicy") .doc("When inserting ...
分类：
数据库 时间：
2019-12-25 20:34:49
阅读次数：
162
这里将介绍Flink对有状态计算的支持，其中包括状态计算和无状态计算的区别，以及在Flink中支持的不同状态类型，分别有 Keyed State 和 Operator State 。另外针对状态数据的持久化，以及整个 Flink 任务的数据一致性保证，Flink 提供了 Checkpoint 机制处 ...
分类：
其他好文 时间：
2019-12-24 18:32:48
阅读次数：
94
这里将介绍Flink对有状态计算的支持，其中包括状态计算和无状态计算的区别，以及在Flink中支持的不同状态类型，分别有 Keyed State 和 Operator State 。另外针对状态数据的持久化，以及整个 Flink 任务的数据一致性保证，Flink 提供了 Checkpoint 机制处... ...
分类：
其他好文 时间：
2019-12-24 09:20:00
阅读次数：
88
MaxCompute（原ODPS）是阿里云自主研发的具有业界领先水平的分布式大数据处理平台, 尤其在集团内部得到广泛应用，支撑了多个BU的核心业务。 MaxCompute除了持续优化性能外，也致力于提升SQL语言的用户体验和表达能力，提高广大ODPS开发者的生产力。 MaxCompute基于ODPS ...
分类：
其他好文 时间：
2019-12-23 17:00:34
阅读次数：
92
AST11103 Problem Solving with Programming SkillsAdditional Individual Assignment: Min-Game Programming (40%)Learning Outcomes1. Use common application ...
分类：
其他好文 时间：
2019-12-22 19:59:28
阅读次数：
74
Description Description Divide two integers without using multiplication, division and mod operator. If it will overflow(exceeding 32-bit signed integ ...
分类：
其他好文 时间：
2019-12-21 20:28:53
阅读次数：
82
SELECT FROM_UNIXTIME(ipt_date/1000) FROM ipt_data SELECTFROM_UNIXTIME(ipt_date/1000),ipt_data.ipt_date,ipt_data.ipt_num,ipt_data.ipt_operator,ipt_data ...
分类：
数据库 时间：
2019-12-21 18:39:01
阅读次数：
277
官方文档 （由于本人公众号权限的原因，这一节的大部分例子都没有测试） 注意： 2.上传图文消息素材，需要用到图片时，请使用上一步获取的图片 URL； 如果需要在群发图文中插入小程序，则在调用上传图文消息素材接口时，需在content字段中添加小程序跳转链接，有以下三种样式的可供选择。 小程序卡片跳转 ...
分类：
其他好文 时间：
2019-12-21 18:33:06
阅读次数：
191
目录 1.使用时间格式化方法 2.进行时间补偿（默认当前时区是东八区，即8x3600x1000=28800000） mongodb的默认时间是格林尼治时间，如果是要按照日期进行分组需要注意！！！。 解决方案： 1.使用时间格式化方法 Aggregation.project().and("create ...
分类：
数据库 时间：
2019-12-21 15:53:31
阅读次数：
88
原来series_id是numeric型，现在转换为varchar(64)； ...
分类：
数据库 时间：
2019-12-20 20:53:13
阅读次数：
135
