-
Spring Cloud Stream同一通道根据消息内容分发不同的消费逻辑
应用场景 有的时候,我们对于同一通道中的消息处理,会通过判断头信息或者消息内容来做一些差异化处理,比如:可能在消息头信息中带入消息版本号,然后通过if判断来执行不同的处理逻辑,其代码结构可能是这样的: @StreamListener(value = TestTopic.INPUT) public void receiveV1(String payload, ...
时间:2018-12-27点击:269收藏
-
Ignite 与 Spark 都很强,那如果把它们整合起来会怎样?
在前面的文章中,我们分别介绍了 Ignite 和 Spark 这两种技术,从功能上对两者进行了全面深入的对比。经过分析,可以得出这样一个结论:两者都很强大,但是差别很大,定位不同,因此会有不同的适用领域。 但是,这两种技术也是可以互补的,那么它们互补适用于场景是什么呢?主要是这么几个方面:如果觉得 Spark 中的 SQL 等运行速度较慢,那么 Ignite...
时间:2018-12-27点击:285收藏
-
免费带你体验阿里巴巴旗舰大数据计算产品MaxCompute
什么是MaxCompute? 众所周知,MaxCompute是阿里云推出的承载EB级的数据存储能力,百PB级的单日计算能力,公共云覆盖国内外十几个国家和地区,专有云包含城市大脑在内部署超过100+套的阿里巴巴的统一计算平台。官方地址:https://www.aliyun.com/product/odps MaxCompute是真正为大数据而生的企业级云计算产...
时间:2018-12-26点击:225收藏
-
Streaming System 第三章:Watermarks
简介 本章主要介绍鲁棒的处理乱序数据的核心概念,这些概念的运用使流处理系统超越批处理系统的关键所在。本章我们从流计算系统的底层机制深入来探讨一下watermark。学习这些机制有助于我们更好理解和使用watermark。我们将讨论watermark如何生成,传播和影响输出结果的时间戳。我们还将解释,watermark如何保证结果的正确性。 本文由《Strea...
时间:2018-12-26点击:535收藏
-
Flink入坑指南 第一章 - 简介
Flink入坑指南系列文章,从实际例子入手,一步步引导用户零基础入门实时计算/Flink,并成长为使用Flink的高阶用户。本文属个人原创,仅做技术交流之用,笔者才疏学浅,如有错误,欢迎指正。转载请注明出处,侵权必究。 Flink是什么 这是个很玄妙的问题。在以下网站上做了很专业的介绍。 Flink官网:https://flink.apache.org/ F...
时间:2018-12-26点击:255收藏
-
Flink入坑指南 第二章 - 从一个需求开始
Flink入坑指南系列文章,从实际例子入手,一步步引导用户零基础入门实时计算/Flink,并成长为使用Flink的高阶用户。本文属个人原创,仅做技术交流之用,笔者才疏学浅,如有错误,欢迎指正。转载请注明出处,侵权必究。 从一个需求开始 小明是一个电商平台的数据开发工程师,在其公司的电商平台上,分了很多类目,每个类目有很多店铺。整个公司的数据链路如下: 蓝色链...
时间:2018-12-26点击:232收藏
-
Flink入坑指南 第三章:第一个作业
摘要: Flink入坑指南系列文章,从实际例子入手,一步步引导用户零基础入门实时计算/Flink,并成长为使用Flink的高阶用户。本文属个人原创,仅做技术交流之用,笔者才疏学浅,如有错误,欢迎指正。转载请注明出处,侵权必究。 Flink接口 Flink支持三种接口,也就是三种写作业的方式: SQL:实时计算产品与开源Flink相比,提供更全面的语法支持,目...
时间:2018-12-26点击:228收藏
-
云HBase备份恢复,为云HBase数据安全保驾护航
云HBase发布备份恢复功能,为用户数据保驾护航。对大多数公司来说数据的安全性以及可靠性是非常重要的,如何保障数据的安全以及数据的可靠是大多数数据库必须考虑的。2016 IDC的报告表示数据的备份(data-protection)和数据恢复(retention)是Nosql的最基础的需求之一。 为什么需要云HBase备份恢复? 我们希望云HBase支...
时间:2018-12-26点击:244收藏
-
12月27日云栖精选夜读 | Python拼接字符串的七种方式
忘了在哪看到一位编程大牛调侃,他说程序员每天就做两件事,其中之一就是处理字符串。相信不少同学会有同感。 几乎任何一种编程语言,都把字符串列为最基础和不可或缺的数据类型。而拼接字符串是必备的一种技能。今天,我跟大家一起来学习Python拼接字符串的七种方式。 热点热议 Python拼接字符串的七种方式 作者:技术小能手发表在:Python中文社区 解密 | 阿...
时间:2018-12-26点击:228收藏
-
四面快手归来,分享Java真题及面经:策略模式+红黑树+Java锁+Redis+Kafka等分布式
看真题,了解差距,明确学习方向与目标。 看面经,提前准备,事半功倍。 一面(一个小时十分钟) 1.自我介绍 2.说说B+树和B树的区别,优缺点等? 3聊聊Spring,主要IOC等等 4多线程JUC包下的一些常见的类,比如CountDownLatch、Semaphore等 5.锁的概念,锁相关的关键字,volatile,synchronized。还比较了Re...
时间:2018-12-26点击:219收藏
-
阿里云服务:阿里云专家服务介绍
阿里云专家服务,提供从咨询到实施、从迁云到护航的全周期专业服务,满足各场景下的服务需求。第一:上云前提供,咨询与设计服务针对评估、规划、建设、迁移或优化系统的需求,提供基于阿里云产品特性和最佳实践的迁移、建设或优化方案。1.迁云咨询服务提供迁云前的专业设计和咨询。评估业务系统迁移阿里云平台的可行性,设计业务系统的产品选型和应用架构,以及应用系统、存储、数据库...
时间:2018-12-26点击:208收藏
-
【Java开发者专场】阿里特邀专家徐雷:Java为王,互联网高并发架构设计选型之路
本篇文章来自于2018年12月22日举办的《阿里云栖开发者沙龙—Java技术专场》,徐雷专家是该专场第三位演讲的嘉宾,本篇文章是根据徐雷专家在《阿里云栖开发者沙龙—Java技术专场》的演讲视频以及PPT整理而成。 摘要:Java从诞生以来几乎一直是排名第一的语言,长期霸榜。在架构师成长道路中,学习Java是绝对是最正确的选择。本文分别分别介绍了Java平台的...
时间:2018-12-26点击:296收藏
点击排行
-
Docker使用Oracle官方镜像安装(12C,18C,19C)
- Springboot2将连接池hikari替换为druid,体验最强大的数据库连接池
- Docker快速安装Oracle11G,搭建oracle11g学习环境
- CentOS8编译安装MySQL8.0.19
- SpringBoot2配置默认Tomcat设置,开启更多高级功能
- MySQL8.0.19开启GTID主从同步CentOS8
- Jdk安装(Linux,MacOS,Windows),包含三大操作系统的最全安装
- CentOS7,8上快速安装Gitea,搭建Git服务器
- SpringBoot2编写第一个Controller,响应你的http请求并返回结果