简介: 本文将会讲述共享充电宝开创企业来电科技如何基于 Flink + Hologres 构建统一数据服务加速的实时数仓 作者:陈健新,来电科技数据仓库开发工程师,目前专注于负责来电科技大数据平台离线和实时架构的整合。 深圳来电科技有限公司(以下简称 “来电科技”)是共享充电宝行业开创企业,主要业务 ...
分类:
其他好文 时间:
2021-06-17 17:00:49
阅读次数:
0
Apache Flink Apache Flink is an open source stream processing framework with powerful stream- and batch-processing capabilities. Learn more about Flin ...
分类:
其他好文 时间:
2021-06-15 18:01:00
阅读次数:
0
在消息RabbitMQ时,我们关心的一个问题是手动ack还是自动ack,如果是自动ack就怕出现丢消息的情况 Flink以RabbitMQ作为Source,是怎么保证消息唯一性的呢,是怎么保证ack的. 首先引入依赖包 <dependency> <groupId>org.apache.flink</ ...
分类:
其他好文 时间:
2021-06-11 19:15:45
阅读次数:
0
数栈是云原生—站式数据中台PaaS,我们在github和gitee上有一个有趣的开源项目:FlinkX,FlinkX是一个基于Flink的批流统一的数据同步工具,既可以采集静态的数据,也可以采集实时变化的数据,是全域、异构、批流一体的数据同步引擎。大家喜欢的话请给我们点个star!star!star ...
分类:
其他好文 时间:
2021-06-11 19:07:45
阅读次数:
0
ke01开启: nc -lk 8888 Map package com.text.transformation import org.apache.flink.streaming.api.scala.StreamExecutionEnvironment import org.apache.flink ...
分类:
其他好文 时间:
2021-06-11 18:25:57
阅读次数:
0
1.创业的感受 累,累,累,已经连续创业3天,2晚失眠睡不着,中午午休也睡不着,衣带渐宽终不悔,为伊消得人憔悴,哈哈....。但是觉得自己在成长和进步,连续不断的输出,让我不得已不断的学习,不断的输入。有时候会觉得,特别的孤独,特么的说好大家一起开源,一起创业,但是真正行动的时候,都看不到人,感觉一 ...
分类:
数据库 时间:
2021-06-10 18:02:17
阅读次数:
0
Flink 1.12.1 java.lang.NoClassDefFoundError: org/apache/flink/streaming/api/functions/source/SourceFunction 错误信息描述 使用Idea运行项目,抛出以下异常 java.lang.NoClass ...
分类:
其他好文 时间:
2021-06-06 18:47:58
阅读次数:
0
vip视频教程 IT自学视频教程 编程教程Flink+ClickHouse 玩转企业级实时大数据开发 vip视频教程 IT自学视频教程 编程教程Flink+ClickHouse 玩转企业级实时大数据开发(8章)已经在做大数据,Flink让你轻松提薪;尚未入行大数据,Flink让你弯道超车 Flink ...
分类:
其他好文 时间:
2021-06-03 17:40:23
阅读次数:
0
Flink CEP CEP 复杂事件处理: 根据事件时间的时序关系和聚合关系定制检测规则,持续的从事件流中查询出符合需求的事件序列,分析后得到更复杂的复合事件。 说明: 1.CEP是支持事件乱序的,根据事件时间和WaterMark来判断数据的顺序。 2.Spark内部没有集成CEP,但是有解决方案, ...
分类:
其他好文 时间:
2021-06-02 20:18:35
阅读次数:
0
Flink 状态 Flink状态: 状态可以是历史结果,也可以是存储的数据,归根揭底是保存的内容就是状态。 流式计算分为有状态的和无状态的: 无状态的流处理:观察每个独立的事件,并根据最后一个事件的结果进行输出。 有状态的流处理:基于多个事件输出结果。流与流之间的关联操作、流与静态表或动态表之间的关 ...
分类:
其他好文 时间:
2021-06-02 20:06:01
阅读次数:
0