搜索[流计算 Oceanus]结果-低调大师优秀个人博客

精选列表

搜索[流计算 Oceanus]，共10006篇文章

CentOS8安装MyCat，轻松搞定数据库的读写分离、垂直分库、水平分库

支持密码加密支持服务降级支持IP白名单支持SQL黑名单、sql注入攻击拦截支持prepare预编译指令（1.6）支持非堆内存(Direct Memory)聚合计算（1.6）支持PostgreSQL

2025-09-05

KubeKey_v3.x安装K8s

/kk version --show-supported-k8s # Kubernetes版本说明 # kubernetes_v1.21.14支持边缘计算 # docker容器最高支持到kubernetes_v1.24

2025-12-13

S4分布式流计算引擎

背景最近花了点时间研究了下分布式计算这一块的内容。领导给的第一个任务，就是学习下S4和GridGain。花了几天的时间把s4的源码看了下，把自己的理解和学习的内容做一个记录。

2016-03-29

重新定义流计算：第三代流处理系统 RisingWave 的 2024 年展望

1强化易用性与性价比两大特性 RisingWave 诞生之初，便将"使流计算平民化"作为长期发展目标，致力于强化流处理系统的易用性与高性价比，不断降低流计算学习、使用与维护的门槛。

2024-01-05

每日一博 | 时序数据库的流计算支持

：历史数据的不变性数据的有效性数据的时效性结构化的数据数据的大量性二、时序数据库基本架构针对时序数据的特点，时序数据库一般具有以下特性：高速的数据入库数据的生命周期管理数据的流处理

2023-03-19

基于 Flink 流计算实现的股票交易实时资产应用

开销很大二、技术方案 2.1 ETL 的架构&流计算这里一个更合理的架构方案是使用 ETL 的架构对此做优化。

2023-03-10

eKuiper v1.7.0 将提供流批结合计算能力

流批结合计算并非所有的数据都会经常变化，即使在实时计算中也是如此。在某些情况下，你可能需要用外部存储的静态数据来补全流数据。

2022-10-10

DolphinDB丨金融高频因子流批一体计算神器

今天的推文为大家介绍如何使用DolphinDB发布的响应式状态引擎（Reactive State Engine）高效开发与计算带有状态的高频因子，实现流批统一计算。

2021-03-23

未来大数据处理架构的主流模式：实时流计算

实时流计算技术是当前最前沿的大数据处理方式，并且代表了未来大数据处理架构的主流模式。其对系统的低延时、高并发、高吞吐、高可用、高可靠都带来极大的挑战。

2020-07-22

Flink SQL 功能解密系列 —— 流计算“撤回(Retraction)”案例分析

什么是retraction（撤回）通俗讲retract就是传统数据里面的更新操作，也就是说retract是流式计算场景下对数据更新的处理方式。首先来看下流场景下的一个词频统计列子。

2018-02-07

下图中描述了 Spark 的输入、运行转换、输出。在运行转换中通过算子对 RDD进行转换。算子是 RDD 中定义的函数，可以对 RDD 中的数据进行转换和操作。输入：在 Spark 程序运行中，数据从外部数据空间（例如， HDFS、 Scala 集合或数据）输入到 Spark，数据就进入了 Spark 运行时数据空间，会转化为 Spark 中的数据块，通过 BlockManager 进行管理。运行：在 Spark 数据输入形成 RDD 后，便可以通过变换算子 f liter 等，对数据操作并将 RDD 转化为新的 RDD，通过行动（Action）算子，触发 Spark 提交作业。如果数据需要复用，可以通过 Cache 算子，将数据缓存到内存。输出：程序运行结束数据会输出 Spark 运行时空间，存储到分布式存储中（如saveAsTextFile 输出到 HDFS）或 Scala 数据或集合中（ collect 输出到 Scala 集合，count 返回 Scala Int 型数据）。图 1 Spark 算子和数据空间 Spark的核心数据模型是RDD，但RDD是个抽象类，具体由各子类实现，如MappedRDD、Shuff ledRDD等子类。Spark将常用的大数据操作都转化成为RDD 的子类。本文转自大数据躺过的坑博客园博客，原文链接：http://www.cnblogs.com/zlslch/p/5724027.html，如需转载请自行联系原作者

2017-11-12

实时计算流数据处理系统简单分析

一．实时计算的概念实时计算一般都是针对海量数据进行的，一般要求为秒级。实时计算主要分为两块:数据的实时入库、数据的实时计算。

2017-09-04

流计算风云再起 - PostgreSQL携PipelineDB力挺IoT(物联网)

标签 PostgreSQL , pipelinedb , 流计算 , patch , bug , libcheck , zeromq , kafka , kinesis , IoT , 物联网背景 pipelinedb

2016-12-20

基于Spark机器学习和实时流计算的智能推荐系统

表示评分数据集中用户i对产品j的真实评分，另外一部分表示用户i的特征向量（转置）*产品j的特征向量（这里可以得到预测的i对j的评分）用真实评分减去预测评分然后求平方，对下一个用户，下一个产品进行相同的计算

2015-06-27

Java 学习（25）---（IO流之数据流 / 内存操作流 / 打印流 / 标准输入输出流)

数据流可以读写基本数据类型的数据数据输入流： DataInputStream DataInputStream(InputStream in) 数据输出流： DataOutputStream DataOutputStream

2018-08-02

【架构实战】实时计算架构：Flink处理亿级数据流

我们的数据报表是T+1： - 每天凌晨跑批 - 早上8点出报表 - 运营看昨天的数据 **问题：** - 618大促时，销量激增 - 运营想看实时数据调整策略 - 但只能看昨天的数据 - 错过最佳调整时机引入实时计算后

2026-07-30

数据采集 & 流批一体计算工具 bboss v6.8.2 发布

数据采集ETL&流批一体化计算工具 bboss v6.8.2 发布。

2023-02-23

流批一体生产应用！Bigo 实时计算平台建设实践

本文由 Bigo 计算平台负责人徐帅分享，主要介绍 Bigo 实时计算平台建设实践的介绍。

2021-03-01

Flink SQL 功能解密系列 —— 阿里云流计算/Blink支持的connectors

Blink Connectors 总览 Connector 是连接外部数据和blink计算框架的桥梁，也是流计算的入口和出口。

2018-02-07

基于分布式流计算平台(storm)的CGI采集与清理系统

本文简单介绍了基于分布式流计算平台Storm的海量CGI采集去重系统——Storm-Cgi。

2014-01-08

Java 学习（26）---（IO流之Properties 类 / 合并流 / 序列化流 / 随机访问流)

; } } // 把集合中的数据重新存储到文件中 Writer w = new FileWriter( "user.txt"); prop.store(w,null); w.close(); 合并流

2018-08-02

从批到流，实时监控预警——DolphinDB 工业物联网实时计算指南

本章要讨论的，正是这个问题——实时计算。和批计算不同，实时计算面对的是持续不断的流式数据。在对实时性要求极高的业务场景中，需要以低延时完成数据清洗、聚合计算、异常判断和告警触发。

2026-08-18

资源下载

更多资源

Mario

马里奥是站在游戏界顶峰的超人气多面角色。马里奥靠吃蘑菇成长，特征是大鼻子、头戴帽子、身穿背带裤，还留着胡子。与他的双胞胎兄弟路易基一起，长年担任任天堂的招牌角色。

Spring

Spring框架（Spring Framework）是由Rod Johnson于2002年提出的开源Java企业级应用框架，旨在通过使用JavaBean替代传统EJB实现方式降低企业级编程开发的复杂性。该框架基于简单性、可测试性和松耦合性设计理念，提供核心容器、应用上下文、数据访问集成等模块，支持整合Hibernate、Struts等第三方框架，其适用范围不仅限于服务器端开发，绝大多数Java应用均可从中受益。

Rocky Linux

Rocky Linux（中文名：洛基）是由Gregory Kurtzer于2020年12月发起的企业级Linux发行版，作为CentOS稳定版停止维护后与RHEL（Red Hat Enterprise Linux）完全兼容的开源替代方案，由社区拥有并管理，支持x86_64、aarch64等架构。其通过重新编译RHEL源代码提供长期稳定性，采用模块化包装和SELinux安全架构，默认包含GNOME桌面环境及XFS文件系统，支持十年生命周期更新。

WebStorm

WebStorm 是jetbrains公司旗下一款JavaScript 开发工具。目前已经被广大中国JS开发者誉为“Web前端开发神器”、“最强大的HTML5编辑器”、“最智能的JavaScript IDE”等。与IntelliJ IDEA同源，继承了IntelliJ IDEA强大的JS部分的功能。

精选列表

CentOS8安装MyCat，轻松搞定数据库的读写分离、垂直分库、水平分库

KubeKey_v3.x安装K8s

S4分布式流计算引擎

重新定义流计算：第三代流处理系统 RisingWave 的 2024 年展望

每日一博 | 时序数据库的流计算支持

基于 Flink 流计算实现的股票交易实时资产应用

eKuiper v1.7.0 将提供流批结合计算能力

DolphinDB丨金融高频因子流批一体计算神器

未来大数据处理架构的主流模式：实时流计算

Flink SQL 功能解密系列 —— 流计算“撤回(Retraction)”案例分析

Spark 概念学习系列之Spark计算工作流（十二）

实时计算流数据处理系统简单分析

流计算风云再起 - PostgreSQL携PipelineDB力挺IoT(物联网)

基于Spark机器学习和实时流计算的智能推荐系统

Java 学习（25）---（IO流之数据流 / 内存操作流 / 打印流 / 标准输入输出流)

【架构实战】实时计算架构：Flink处理亿级数据流

数据采集 & 流批一体计算工具 bboss v6.8.2 发布

流批一体生产应用！Bigo 实时计算平台建设实践

Flink SQL 功能解密系列 —— 阿里云流计算/Blink支持的connectors

基于分布式流计算平台(storm)的CGI采集与清理系统

Java 学习（26）---（IO流之Properties 类 / 合并流 / 序列化流 / 随机访问流)

从批到流，实时监控预警——DolphinDB 工业物联网实时计算指南

资源下载

Mario

Spring

Rocky Linux

WebStorm

欢迎您来访！

精选列表

CentOS8安装MyCat，轻松搞定数据库的读写分离、垂直分库、水平分库

KubeKey_v3.x安装K8s

S4分布式流计算引擎

重新定义流计算：第三代流处理系统 RisingWave 的 2024 年展望

每日一博 | 时序数据库的流计算支持

基于 Flink 流计算实现的股票交易实时资产应用

eKuiper v1.7.0 将提供流批结合计算能力

DolphinDB丨金融高频因子流批一体计算神器

未来大数据处理架构的主流模式：实时流计算

Flink SQL 功能解密系列 —— 流计算“撤回(Retraction)”案例分析

Spark 概念学习系列之Spark计算工作流（十二）

实时计算 流数据处理系统简单分析

流计算风云再起 - PostgreSQL携PipelineDB力挺IoT(物联网)

基于Spark机器学习和实时流计算的智能推荐系统

Java 学习（25）---（IO流之数据流 / 内存操作流 / 打印流 / 标准输入输出流)

【架构实战】实时计算架构：Flink处理亿级数据流

数据采集 & 流批一体计算工具 bboss v6.8.2 发布

流批一体生产应用！Bigo 实时计算平台建设实践

Flink SQL 功能解密系列 —— 阿里云流计算/Blink支持的connectors

基于分布式流计算平台(storm)的CGI采集与清理系统

Java 学习（26）---（IO流之Properties 类 / 合并流 / 序列化流 / 随机访问流)

从批到流，实时监控预警——DolphinDB 工业物联网实时计算指南

资源下载

Mario

Spring

Rocky Linux

WebStorm

欢迎您来访！

实时计算流数据处理系统简单分析