概述介绍 百捷OA系统是适用于中小型企业的平台型OA管理软件，融合了广州百捷网络长期从事管理软件开发的丰富经验与先进技术， 该系统采用领先的B/S(浏览器/服务器)操作方式，使得网络办公不受地域限制。...百捷OA系统提供常用的功能模块，包括：个人办公、工作流、公文、人力资源、行政办公、档案、项目管理、知识库、在线交流、CRM系统等，并且未来还会持续增加更多功能模块。...随OA系统同时提供的还有百捷WEB开发平台、百捷工作流平台，让使用者无忧使用、任意定制属于自己的OA系统。 个人感觉还是不错的。
最近在网上找到一个“工作流程快速开发框架”，用JAVA编写的，大家可以下载下来学习参考下。主要：基于activiti5.22， 前后端分离，模块化，超低耦合。...流程变量管理：定义管理流程变量 流程分支groovy脚本支持 会签: 多人参与投票，可通过百分比，票数来计算投票结果，并支持会签结果后置动作的配置。...外部子流程： 外部子流程让流程公共逻辑抽出，更有利于业务流的划分和复用，是一枚大杀器。...动态任务：（开发中）可以配置虚拟任务，定义任务产生和回收节点，并配置其办理人等信息。 移动端：支持移动端协同办公，并且移动端依然支持强大的表单生成功能，支持pc端所有表单控件。...与平台没有直接关系。
腾讯选择用 Flink 作为新一代的实时流计算引擎，并对社区版的 Flink 进行了深度的优化，在此之上构建了一个集开发、测试、部署和运维于一体的一站式可视化实时计算平台——Oceanus。...本文整理自腾讯大数据高级工程师杨华在 QCon 全球软件开发大会（北京站）2019上的演讲，他介绍了腾讯流计算技术的演进过程，产品化及云端对外服务进展。...18 年下半年，我们的 Oceanus 平台已经有足够的能力来构建常见的流计算应用，我们部门内部的一些实时流计算业务也已经在平台上稳定运行，于是我们开始为腾讯云、腾讯其他事业群以及业务线提供流计算服务。...同时，我们也将平台整合进我们的大数据套件，为外部私有云客户提供流计算服务。...以上是对 Oceanus 平台的介绍，如果大家有兴趣可以扫描 PPT 最后的二维码来进一步了解我们的平台以及腾讯云上的流计算服务。
腾讯选择用 Flink 作为新一代的实时流计算引擎，并对社区版的 Flink 进行了深度的优化，在此之上构建了一个集开发、测试、部署和运维于一体的一站式可视化实时计算平台—— Oceanus 。...本文整理自腾讯大数据高级工程师杨华在 QCon 全球软件开发大会（北京站）2019 上的演讲，他介绍了腾讯流计算技术的演进过程，产品化及云端对外服务进展。...18 年下半年，我们的 Oceanus 平台已经有足够的能力来构建常见的流计算应用，我们部门内部的一些实时流计算业务也已经在平台上稳定运行，于是我们开始为腾讯云、腾讯其他事业群以及业务线提供流计算服务。...同时，我们也将平台整合进我们的大数据套件，为外部私有云客户提供流计算服务。...以上是对 Oceanus 平台的介绍，如果大家有兴趣可以扫描 PPT 最后的二维码来进一步了解我们的平台以及腾讯云上的流计算服务。
朋友多年自主研发的flink-sql 流计算可视化 UI 平台，细细品味一番确实很好用，做到真正的MSP（混合云场景）多数据多复用的情况实现，下面是这个产品的使用说明看看大家有没有使用场景。...一、简介 flink-streaming-platform-web系统是基于flink封装的一个可视化的web系统，用户只需在web界面进行sql配置就能完成流计算任务， 主要功能包含任务配置、启/停任务...目的是减少开发，完全实现flink-sql 流计算任务 支持本地模式、yarn-per模式、STANDALONE模式 支持udf、自定义连接器等,完全兼容官方连接器 目前flink版本已经升级到1.12...flink-streaming-udf.jar 地址填写后 可以在sql语句里面直接写 CREATE FUNCTION jsonHasKey as ascom.yt.udf.JsonHasKeyUDF; udf 开发...钉钉报警设置官方文档：https://help.aliyun.com/knowledge_detail/106247.html 安全设置 关键词必须填写： 告警 效果图 三、配置demo demo1 单流kafka
今天我们一起来学习计算和控制流吧。...二、基本计算语句 1.赋值语句 = 2.Python语言的赋值语句很好地结合了“计算”和“存储”。...3.赋值语句的执行语义为： ①计算表达式的值，存储起来 ②贴上变量标签以便将来引用 4.与计算机运行过程中的“计算”和“存储”相对应。 5.“控制器确定下一条程序语句”即对应“控制”。...三、计算和控制流 1.计算与流程 ? 2.控制流语句决定下一条语句 四、计算与流程 数据是对现实世界处理和过程的抽象，各种类型的数据对象可以通过各种运算组织成复杂的表达式。...六、控制流语句 1.控制流语句用来组织语句描述过程 ? 2控制流语句举例 ? ? 七、分析程序流程 1.代码 ? 2.流程图 ?
flink join,Flink是下一代大数据计算平台，可处理流计算和批量计算。《Flink-1.9流计算开发：十五、join函数》cosmozhu写的本系列文章的第十五篇。...需求 当前有一个订单流（每秒1个订单），一个人民币-美元汇率流（每10秒发布一个新汇率）。实时计算一个汇率窗口期（10秒）内，订单的外汇金额。...(); env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime); //CNY -> USD 汇率流...相关文章 Flink-1.9流计算开发：十六、intervalJoin函数 Flink-1.9流计算开发：十四、union函数 Flink-1.9流计算开发：十三、min、minBy、max、maxBy...函数 Flink-1.9流计算开发：十二、apply函数 Flink-1.9流计算开发：十一、count-window-Sliding窗口函数
DataSource用来产生或者获取数据流，Transformations对数据流做转换，Sinks作为数据的出口输出到将数据输出到数据库，文件等系统，不过Transformations、Sinks并不是必须的...在上一篇文章Flink-1.9流处理开发：一、最初的开始HELLO WORLD的hello world例子中的流处理过程就是由DataSource和Sinks组成的。...需求 本篇文章实现一个很简单的逻辑，创建一个数据流{"apple","orange","banana","watermelon"}，将数据流的单词做大写转换，然后将其打印出来。...相关文章 Flink-1.9流计算开发：十六、intervalJoin函数 Flink-1.9流计算开发：十五、join函数 Flink-1.9流计算开发：十四、union函数 Flink-1.9...流计算开发：十三、min、minBy、max、maxBy函数 Flink-1.9流计算开发：十二、apply函数
Flink是下一代大数据计算平台，可处理流计算和批量计算。《Flink-1.9流计算开发：六、reduce函数》是cosmozhu写的本系列文章的第六篇。...这个例子中，reduce函数的功能就是将数据流中的上一个数据和当前数据相加，然后返回传递给下次调用。 ?...相关文章 Flink-1.9流计算开发：十六、intervalJoin函数 Flink-1.9流计算开发：十五、join函数 Flink-1.9流计算开发：十四、union函数 Flink-1.9...流计算开发：十三、min、minBy、max、maxBy函数 Flink-1.9流计算开发：十二、apply函数
Flink是下一代大数据计算平台，可处理流计算和批量计算。《Flink-1.9流计算开发：七、fold函数》是cosmozhu写的本系列文章的第七篇。...fold 函数是 keyedStream 流的方法，为了将DataStream不做其它处理的转为 keyedStream。因此在这里使用了这种写法。...2、new HashMap() 这里是创建一个临时暂存器，用来保存流中产生的状态。 ?...相关文章 Flink-1.9流计算开发：十六、intervalJoin函数 Flink-1.9流计算开发：十五、join函数 Flink-1.9流计算开发：十四、union函数 Flink-1.9...流计算开发：十三、min、minBy、max、maxBy函数 Flink-1.9流计算开发：十二、apply函数
Kafka 作为一个分布式的流平台，正在大数据相关领域得到越来越广泛的应用，本文将会介绍 kafka 的相关内容。...01 — 简介 流平台如 kafka 具备三大关键能力： 发布和订阅消息流，类似于消息队列。 以容错的方式存储消息流。 实时处理消息流。...kafka 的流处理，可以持续获取输入流的数据，然后进行加工处理，最后写入到输出流。...kafka 的流处理强依赖于 kafka 本身，并且只是一个类库，与当前知名的流处理框架如 spark 和 flink 还是有不小的区别和差距。...3、未指定 partition 但是消息中有 key ，那么将会根据 key 值计算然后发送到指定分区，相同的 key 一定是相同的 partition 。
在本篇文章中我们接着来说filter函数,此函数主要作用就是根据用户条件，过滤数据流中数据。 需求 将数据流的单词做大写转换，并保留其小写，然后只打印出字符串长度大于5的元素。...String[] words = {"apple","orange","banana","watermelon"}; //创建DataSource //根据给定的元素创建一个数据流，...out.collect(value.toUpperCase()); } }); //过滤掉单词长度不大于5的单词 //对数据流中的每个元素执行...相关文章 Flink-1.9流计算开发：十六、intervalJoin函数 Flink-1.9流计算开发：十五、join函数 Flink-1.9流计算开发：十四、union函数 Flink-1.9...流计算开发：十三、min、minBy、max、maxBy函数 Flink-1.9流计算开发：十二、apply函数
在上一篇文章Flink-1.9流计算开发：二、Map函数文章中我们使用了map方法。在本篇文章中我们将使用flatMap，来验证一下它与map方法的差异。...需求 本篇文章实现一个很简单的逻辑，创建一个数据流{"apple","orange","banana","watermelon"}，将数据流的单词做大写转换，并保留其小写，然后将其打印出来。...String[] words = {"apple","orange","banana","watermelon"}; //创建DataSource //根据给定的元素创建一个数据流，...相关文章 Flink-1.9流计算开发：十六、intervalJoin函数 Flink-1.9流计算开发：十五、join函数 Flink-1.9流计算开发：十四、union函数 Flink-1.9...流计算开发：十三、min、minBy、max、maxBy函数 Flink-1.9流计算开发：十二、apply函数
1+ flink intervalJoin,Flink是下一代大数据计算平台，可处理流计算和批量计算。...《Flink-1.9流计算开发：十六、intervalJoin函数》cosmozhu写的本系列文章的第十六篇。通过简单的DEMO来演示flink intervalJoin函数执行的效果 。...如果您还不了解join如何使用，请跳到我上一篇文章Flink-1.9流计算开发：十五、join函数。...Flink-1.9流计算开发：十五、join函数 Flink-1.9流计算开发：十四、union函数 Flink-1.9流计算开发：十三、min、minBy、max、maxBy函数 Flink-1.9...流计算开发：十二、apply函数 Flink-1.9流计算开发：十一、count-window-Sliding窗口函数
Flink是下一代大数据计算平台，可处理流计算和批量计算。《Flink-1.9流计算开发：十二、apply函数》cosmozhu写的本系列文章的第十二篇。...} }, "order-info"); orderSource. // 未使用keyby分区流的时间窗口...相关文章 Flink-1.9流计算开发：十六、intervalJoin函数 Flink-1.9流计算开发：十五、join函数 Flink-1.9流计算开发：十四、union函数 Flink-1.9...流计算开发：十三、min、minBy、max、maxBy函数 Flink-1.9流计算开发：十一、count-window-Sliding窗口函数
背景 随着flink在流计算领域越来越火，很多公司基于flink搭建了自己的实时计算平台，用户可以在实时平台通过jar或者sql的方式来开发、上线、下线、运维flink任务，避免了构建flink任务的复杂性...平时我们自己开发一个flink任务之后，都是通过脚本的方式提交到集群的，但是我们搭建了一个实时计算之后，就不能通过命令行来管理任务了，我们今天就主要讲一下如何通过api的方式来和yarn集群交互。...这种模式启动任务时间长，一般适合运行常驻任务，比如flink流任务. 案例详解 今天我们主要讲一下如何通过api的方式来停止一个通过per job模式部署在yarn集群上的任务。
1+ Flink是下一代大数据计算平台，可处理流计算和批量计算。《Flink-1.9流计算开发：十四、union函数》cosmozhu写的本系列文章的第十四篇。...需求 本篇文章我们看一下union的用法，将多个币种的汇率流合并成一个汇率流。...coefficient=6.21] 4> ExchangeRateInfo [from=EUR, to=CNY, coefficient=7.46] 小结 在sql中union是将多个查询结果集合汇总成一个结果集合，而在流计算中类似的将多个流合并成一个流...Flink-1.9流计算开发：十六、intervalJoin函数 Flink-1.9流计算开发：十五、join函数 Flink-1.9流计算开发：十三、min、minBy、max、maxBy函数...Flink-1.9流计算开发：十二、apply函数 Flink-1.9流计算开发：十一、count-window-Sliding窗口函数
我们先来看看什么是工作流？ 所谓工作流引擎是指workflow作为应用系统的一部分，并为之提供对各应用系统有决定作用的根据角色、分工和条件的不同决定信息传递路由、内容等级等核心解决方案。...XJR开发平台的工作流是整合activity工作流引擎的图形化流程设计器，通过可视化配置界面。基于B/S结构，纯浏览器应用，只需要拖拽组件，拼接流程，就能实现各层的审批。...在OA办公系统中，每个人都会用的请假流程，我们拿请假申请流程来举例，看看如何利用XJR快速开发平台进行可视化设计流程？...建立工作流程前我们需要先通过XJR快速开发平台的可视化表单设计先设计设计出请假表单。前面有文章详细介绍过了，在这里不详细讲解了。...一、点击后台工作流程→流程设计 二、用流程设计器画出请假流程图，XJR快速开发平台的流程设计器是整合activtity开发，采用可视化编辑工作流引擎，辅助研发人员设计专业的流程功能，像我这种只会办公软件的人都可轻易上手
设计概要： 把数据流形象话的比作水流 使用redis流和流的存储功能做水库，分别设计进水和出水系统 使用tornado可以同时支持多个进出水水管并行运行，互不干扰 使用streamz库灵活实现加在进出水管上的算法...，可以实现限速rate_limit、过滤filter、批处理map，合并zip，缓冲buffer等特性 使用类库¶ 使用了tornado的异步和streamz的流处理两个库，需要redis 5.0以上版本...self.stopped = True self.finalize(self, self.stop, weakref.ref(self)) 出水口设计¶ 从redis读取流数据生成
其实2014年的时候就无意间看到这款RoadFlow开源的工作流开发平台，相比ccflow，这应该属于轻量级的.Net开源平台。...以下介绍来自官方网站，你可以下载源码和查看详细介绍 先进的.NET MVC开源工作流快速开发平台 – RoadFlow RoadFlow是一款集成工作流引擎的ASP.NET MVC...快速开发平台，由从事多年工作流开发与实施的技术团队开发。...该工作流平台是根据多年对企事业单位工作流应用经验总结而成，是一款符合于国情的工作流平台，特别适合于国内无标准，复杂多变的工作审批流转。...拥有全浏览器兼容的可视化流程设计器、表单设计器、基于角色的权限管理等先进设计理念，是您开发OA、CRM、HR、ERP等大型系统的最佳基础平台。
领取专属 10元无门槛券
手把手带您无忧上云
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储
