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

精选列表

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

Apache DolphinScheduler 工作流卡死，怎么解决？

背景 Apache DolphinScheduler 有时候可能会出现工作流卡死问题：工作流显示运行状态（小齿轮一直转），但进入工作流查看各任务实例却是没有运行的状态。

2025-12-10

Gfast 工作流引擎 2.0 正式发布

Gfast 是基于 GF (GoFrame) 的后台管理系统，此次为丰富Gfast生态而增加工作流，经过长时间的精心研发和严格测试，全新Gfast工作流版本现已正式发布！

2024-10-18

❤️‍🔥FlyFlow工作流:新增办理节点

我们深刻理解传统 BPMN.js 工作流引擎的复杂性，因此，FlyFlow 致力于通过简化操作逻辑，打破技术壁垒，让每一位用户都能轻松上手，快速构建并管理个性化的业务流程。

2024-09-04

Vanus —— 无服务器事件流系统

Vanus 是一个开源的无服务器事件流平台，具有内置的事件处理功能。它连接 SaaS、云服务和数据库，帮助用户构建下一代事件驱动的应用程序。

2023-06-25

实例讲解Flink 流处理程序编程模型

从概念上讲，stream 是数据记录的流（可能永远不会结束），transformation 是一个运算，它接受一个或多个流作为输入，经过处理/计算后生成一个或多个输出流。

2023-06-09

详解ROMA Connect API 流控实现技术

图2 业务挑战而对于流控的具体挑战如下：每天10次与每分钟10万次的流控同时存在流控反馈周期比流控周期还久流控的维度特别多流控同步处理时间影响用户体验流控静态设置，要么过高要么过低流控失效造成业务失效

2022-10-10

极简 Java 工作流概念入门

为什么需要工作流松哥将之前的文章转发到朋友圈后，有小伙伴评论说一直不理解为什么需要工作流，今天我们就先来说说这个话题。

2022-08-26

短视频无尽流前端开发指南

本文基于对家装家居内容短视频无尽流的开发实践，总结出了一套适应于该场景及衍生场景的前端开发指南，通过阅读本文可以快速了解短视频无尽流的前端开发。

2022-08-05

“消息驱动、事件驱动、流 ”基础概念解析

流Streaming 流是一组有序的无界事件或数据，执行操作通常是固定的某个事件段（e.g. 00:00 – 12:00）或一个相对事件（E.g. 过去 12 小时）。

2022-04-26

Garden —— 自动完成工作流的工具

Garden 是一款可自动完成工作流的开发工具，使 Kubernetes 应用的开发和测试变得快捷，无需在笔记本电脑上运行 Docker 或 Kubernetes，快速的集群内构建、对 dev 和 CI

2021-06-04

Java函数式编程-3.流(Stream)

对核心类库的改进主要包括集合类的API和新引入的流(Stream)。流使程序员得以站在更高的抽象层次上对集合进行操作。 1.什么是流(Stream)?

2021-01-17

Gfast 工作流引擎 1.0 正式发布

Gfast管理系统采用go语言开发，基于GF(GoFrame)的后台管理系统，现增加工作流引擎模块开源发布，实现工作流引擎与业务解绑，不同业务数据均可接入，以业务数据驱动的状态机机制，让系统更具可用性，

2020-12-24

拥抱 Java 8 并行流吧，速度飞起！

让我们来看看吧并行流认识和开启并行流什么是并行流：并行流就是将一个流的内容分成多个数据块，并用不同的线程分别处理每个不同数据块的流。

2020-07-28

Apache NiFi之Kafka流数据到HBase

一.说明在大数据平台的业务场景中，处理实时kafka数据流数据，以成为必要的能力；此篇将尝试通过Apache NiFi来接入Kafka数据然后处理后存储之HBase 二.开拔 Ⅰ).配置ConsumeKafka

2019-08-06

Java 学习（23）---（IO流之字节流)

read(): 一次读取一个字节 int read(byte[] bys): 一次读取一个字节数组 |--FileInputStream |--BufferedInputStream |-- 字节输出流

2018-08-02

java学习笔记--io流的异常处理

= null) { fileOutputStream.close(); System.out.println("关闭输出流对象成功..."); } } catch (IOException e) {//

2018-04-23

(创建于2018/1/1) #include <iostream> #include<fstream> using namespace std; //操作文本文件 void writereadtext() { //写入文本到一个文件中并创建这个文件，然后读取写入的内容显示到控制台 char* fname = "D://renzhenming.txt"; //创建输入流 ofstream fout(fname); //创建失败 if (fout.bad()) { return; } //写入 fout << "jack" << endl; fout << "rose" << endl; //关闭 fout.close(); //读取 ifstream fin(fname); if (fin.bad()) { return; } char ch; while (fin.get(ch)) { //输出 cout << ch; } fin.close(); } //复制二进制文件（图片） void copyBinaryFile() { char *src = "D://beauty.jpg"; char *des = "D://beauty_copy.jpg"; //二进制文件使用binary ifstream fin(src,ios::binary); ofstream fout(des, ios::binary); if (fin.bad() || fout.bad()) { return; } while (!fin.eof()) { char buff[1024] = {0}; fin.read(buff, 1024); fout.write(buff, 1024); } fin.close(); fout.close(); } class Person { public: Person() { } Person(char * name, int age) { this->name = name; this->age = age; } void print() { cout << name << "," << age << endl; } private: char * name; int age; }; //对象持久化 void save_object() { Person p1("renzhenming",27); Person p2("wuzizi", 26); //写入 ofstream fout("D://obj.data", ios::binary); fout.write((char *)(&p1), sizeof(Person)); fout.write((char*)(&p2), sizeof(Person)); fout.close(); //读出 ifstream fin("D://obj.data", ios::binary); Person temp; fin.read((char*)(&temp), sizeof(Person)); temp.print(); fin.read((char*)(&temp), sizeof(Person)); temp.print(); } //标准模板库 #include<string> void stl() { string s1 = "haha"; string s2(" sha bi"); string s3 = s1 + s2; cout << s3 << endl; //转c字符串 const char * str = s3.c_str(); cout << str << endl; } //容器 #include<vector> void c_list() { vector<int> v; v.push_back(12); v.push_back(11); v.push_back(10); for (int i = 0; i < v.size(); i++) { cout << v[i] << endl; } } void main() { //writereadtext(); //copyBinaryFile(); //save_object(); //stl(); c_list(); system("pause"); }

2018-03-19

Scrapy 架构及数据流图简介

详细内容查看下面的数据流(Data Flow)部分。调度器(Scheduler) 调度器从引擎接受request并将他们入队，以便之后引擎请求他们时提供给引擎。

2018-03-12

资源下载

更多资源

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部分的功能。