概述介绍 百捷OA系统是适用于中小型企业的平台型OA管理软件,融合了广州百捷网络长期从事管理软件开发的丰富经验与先进技术, 该系统采用领先的B/S(浏览器/服务器)操作方式,使得网络办公不受地域限制。...百捷OA系统提供常用的功能模块,包括:个人办公、工作流、公文、人力资源、行政办公、档案、项目管理、知识库、在线交流、CRM系统等,并且未来还会持续增加更多功能模块。...随OA系统同时提供的还有百捷WEB开发平台、百捷工作流平台,让使用者无忧使用、任意定制属于自己的OA系统。 个人感觉还是不错的。
最近在网上找到一个“工作流程快速开发框架”,用JAVA编写的,大家可以下载下来学习参考下。主要:基于activiti5.22, 前后端分离,模块化,超低耦合。...流程变量管理:定义管理流程变量 流程分支groovy脚本支持 会签: 多人参与投票,可通过百分比,票数来计算投票结果,并支持会签结果后置动作的配置。...外部子流程: 外部子流程让流程公共逻辑抽出,更有利于业务流的划分和复用,是一枚大杀器。...动态任务:(开发中)可以配置虚拟任务,定义任务产生和回收节点,并配置其办理人等信息。 移动端:支持移动端协同办公,并且移动端依然支持强大的表单生成功能,支持pc端所有表单控件。...与平台没有直接关系。
腾讯选择用 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
腾讯选择用 Flink 作为新一代的实时流计算引擎,并对社区版的 Flink 进行了深度的优化,在此之上构建了一个集开发、测试、部署和运维于一体的一站式可视化实时计算平台—— Oceanus 。...本文整理自腾讯大数据高级工程师杨华在 QCon 全球软件开发大会(北京站)2019 上的演讲,他介绍了腾讯流计算技术的演进过程,产品化及云端对外服务进展。...18 年下半年,我们的 Oceanus 平台已经有足够的能力来构建常见的流计算应用,我们部门内部的一些实时流计算业务也已经在平台上稳定运行,于是我们开始为腾讯云、腾讯其他事业群以及业务线提供流计算服务。...同时,我们也将平台整合进我们的大数据套件,为外部私有云客户提供流计算服务。...以上是对 Oceanus 平台的介绍,如果大家有兴趣可以扫描 PPT 最后的二维码来进一步了解我们的平台以及腾讯云上的流计算服务。
今天我们一起来学习计算和控制流吧。...二、基本计算语句 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流计算开发:七、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函数
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函数
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函数
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-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函数
背景 随着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元无门槛券
手把手带您无忧上云