Conditions 节点 创建任务 任务参数 相关任务 任务样例 1、创建工作流 2、查看执行结果 注意事项 Conditions 节点 Conditions 是一个条件节点，根据上游任务运行状态，判断应该运行哪个下游任务。截止目前 Conditions 支持多个上游任务，但只支持两个下游任务。当上游任务数超过一个时，可以通过且 以及或...

主机监控 主机监控 选定监控集群后，选定监控类型为"主机"，可以通过"环境"和"主机标签"来进一步筛选需要查看监控信息的主机，其中"主机标签"部分可以多选。筛选完毕，页面中将展示选中主机的相关监控信息： 您可以点击主机名，查看单个主机的监控详情；也可以勾选多台主机，点击“查看详情”查看所选主机的监控。 主机：主机的hostname 状态：主...

标签群组 概述 前提条件 配置流程 标签价值 标签群组 概述 数据平台可以采集业务系统产生的数据，经过一系列标准化处理之后，按照约定输出到存储系统（默认ElasticSearch 或 clickhouse），供业务读取，进行人群圈选，进而营销触达等。 标签群组数据实施的一般流程是： 确定需求，确定输入数据来源，确定数据输出方式及格式...

ShenYu Admin数据结构 插件、选择器和规则 资源权限 数据权限 元数据 字典管理 ShenYu Admin数据结构 Apache ShenYu Admin 是网关的后台管理系统，能够可视化管理所有插件、选择器和规则，设置用户、角色，控制资源。 插件、选择器和规则 插件：Apache ShenYu 使用插件化设计思想，实现插...

静态流主要用于按位读写，可以让你很方便的对各种数据文件格式进解析，并且实现能够在不占用太多内存的情况下，进行边读边解析。 其中，stream和static_stream都提供了按位读写的接口。但是stream比较通用，适合各种数据流，但是比较重量级。 而static_stream仅仅针对固定大小的静态buffer数据进行操作，比较轻量快速，而且对位的操作...

Ingest 节点 创建管道流 测试管道流 处理器 convert grok gsub date 其他处理器插件 Ingest 节点 Ingest 节点是 Elasticsearch 5.0 新增的节点类型和功能。其开启方式为：在 elasticsearch.yml 中定义： node . ingest : true I...

数据集成 组合使用衍生数据的工具 理解数据流 衍生数据与分布式事务 全局有序的限制 排序事件以捕捉因果关系 批处理与流处理 维护衍生状态 应用演化后重新处理数据 铁路上的模式迁移 Lambda架构 统一批处理和流处理 数据集成 ​ 本书中反复出现的主题是，对于任何给定的问题都会有好几种解决方案，所有这些解决方案都有不同的优...

算子 数据流转换 Map DataStream → DataStream FlatMap DataStream → DataStream Filter DataStream → DataStream KeyBy DataStream → KeyedStream Reduce KeyedStream → DataStream Window ...

ChainDataset ChainDataset class paddle.io. ChainDataset [源代码] 将多个流式数据集级联的数据集。 用于级联的数据集须都是 paddle.io.IterableDataset 数据集，将各流式数据集按顺序级联为一个数据集。 参数: datasets (list of Iterab...

流量控制 插件 选择器和规则 流量筛选 流量控制 Apache ShenYu 网关通过插件、选择器和规则完成流量控制。相关数据结构可以参考之前的 ShenYu Admin数据结构 。 插件 在shenyu-admin 后台，每个插件都用handle （json 格式）字段来表示不同的处理，而插件处理就是用来管理编辑json 里面的自定义处...