文章 2022-11-23 来自:开发者社区

技术干货|云原生数仓AnalyticDB MySQL实时存储引擎演进之路

背景AnalyticDB MySQL作为一款实时数仓产品,在传统数仓的能力基础上为了支持低延迟的写入、更新场景,架构上设计了实时存储引擎;用户的写入、更新会以append_only的方式写入实时存储引擎,经过compact之后构建索引以支持复杂的计算场景。从架构上看,很庆幸SAP HANA、SingleStore有着类似的设计。在线上服务大客户的同时,实时存储引擎也遇到了一些设计、性能上的瓶颈。....

技术干货|云原生数仓AnalyticDB MySQL实时存储引擎演进之路
问答 2022-11-03 来自:开发者社区

AnalyticDB for MySQL 从业务系统实时导入数据用什么语法?

AnalyticDB for MySQL 从业务系统实时导入数据用什么语法?

问答 2022-11-03 来自:开发者社区

AnalyticDB for MySQL 实时导入数据适用于什么场景?

AnalyticDB for MySQL 实时导入数据适用于什么场景?

文章 2022-10-19 来自:开发者社区

Flume+Kafka+Spark Streaming+MySQL实时日志分析

项目背景网络发展迅速的时代,越来越多人通过网络获取跟多的信息或通过网络作一番自己的事业,当投身于搭建属于自己的网站、APP或小程序时会发现,经过一段时间经营和维护发现浏览量和用户数量的增长速度始终没有提升。在对其进行设计改造时无从下手,当在不了解用户的浏览喜欢和个用户群体的喜好。虽然服务器日志中明确的记载了用户访浏览的喜好但是通过普通方式很难从大量的日志中及时有效的筛选出优质信息。Spark S....

Flume+Kafka+Spark Streaming+MySQL实时日志分析
文章 2022-10-11 来自:开发者社区

FlinkSQL 实时采集Kafka内容到MySQL(实战记录)

01 引言最近在做实时采集Kafka发布的内容到MySQL,本文记录一下关键的点,细节不再描述,希望能帮助到大家。02 实现2.1 添加依赖在工程,除了添加基础的Flink环境依赖,还需要添加flink-connector-kafka的依赖:<dependency> <groupId>org.apache.flink</groupId> <...

FlinkSQL 实时采集Kafka内容到MySQL(实战记录)
问答 2022-09-29 来自:开发者社区

离线改实时数据从hive 迁移到 hbase 还是 mysql 还是 doris , 还是 不迁移?

离线改实时,那数据从hive 迁移到 hbase 还是 mysql 还是 doris , 还是 不迁移?

文章 2022-08-30 来自:开发者社区

实验报告: PolarDB MySQL HTAP:实时数据分析加速

1 设置PolarDB MySQL集群白名单,创建数据库及账号打开PolarDB MySQL控制台,找到创建的集群设置白名单,白名单内加入实验创建的ECS资源的公网ip创建普通账号创建数据库,绑定到刚才创建的账号2申请集群公网地址,开启行存/列存自动引流功能这个设置是RDS没有的,需要点击左侧的基本信息找到数据库代理企业通讯版,点击公网右侧的申请,申请一个公网地址。公网地址申请完后,点击编辑配置....

实验报告: PolarDB MySQL HTAP:实时数据分析加速
问答 2022-08-23 来自:开发者社区

请问一下各位大佬,FlinkCDC在flink sql的mysql实时物化视图是怎么实现的,如果使用

请问一下各位大佬,FlinkCDC在flink sql的mysql实时物化视图是怎么实现的,如果使用的是stream模式,数据发送到kafka, flink sql怎么处理kafka的数据才能实现得到实时物化视图呢。

问答 2022-08-09 来自:开发者社区

各位我想请问个问题,我开窗结果想写入mysql中要保证实时数据更新,mysql中是不是要设置联合主键

各位我想请问个问题,我开窗结果想写入mysql中要保证实时数据更新,mysql中是不是要设置联合主键才行,包括id,windos-start,windos-end一起作为联合主键才能写入

文章 2022-05-14 来自:开发者社区

使用 Flink CDC 实现 MySQL 数据实时入 Apache Doris

本文通过实例来演示怎么通过Flink CDC 结合Doris的Flink Connector实现从Mysql数据库中监听数据并实时入库到Doris数仓对应的表中。1.什么是CDCCDC 是变更数据捕获(Change Data Capture)技术的缩写,它可以将源数据库(Source)的增量变动记录,同步到一个或多个数据目的(Sink)。在同步过程中,还可以对数据进行一定的处理,例如分组(GRO....

使用 Flink CDC 实现 MySQL 数据实时入 Apache Doris

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐

数据库

数据库领域前沿技术分享与交流

+关注
相关镜像