Kafka开源增强特性 Kafka开源增强特性 支持监控如下Topic级别的指标： Topic输入的字节流量 Topic输出的字节流量 Topic拒绝的字节流量 Topic每秒失败的fetch请求数 Topic每秒失败的Produce请求数 Topic每秒输入的消息条数 Topic每秒的fetch请求数

查看更多 →

Flink开源增强特性 Flink滑动窗口增强 Flink Job Pipeline增强 Flink Stream SQL Join Flink CEP in SQL 父主题： Flink

查看更多 →

YARN分布式资源管理系统设计的调度引擎，是针对企业客户融合资源池，多租户的业务诉求而设计的高性能企业级调度器。 Superior Scheduler可实现开源调度器、Fair Scheduler以及Capacity Scheduler的所有功能。另外，相较于开源调度器，Superior

查看更多 →

Oozie开源增强特性 Oozie开源增强特性：安全增强 支持Oozie权限管理，提供管理员与普通用户两种角色。 支持单点登录登出，HTTPS访问以及审计日志。 父主题： Oozie

查看更多 →

开源Kafka输入流 功能描述 创建source流从Kafka获取数据，作为作业的输入数据。 Apache Kafka是一个快速、可扩展的、高吞吐、可容错的分布式发布订阅消息系统，具有高吞吐量、内置分区、支持数据副本和容错的特性，适合在大规模消息处理场景中使用。 前提条件 Kaf

查看更多 →

开源Kafka输出流 功能描述 DLI 将Flink作业的输出数据输出到Kafka中。 Apache Kafka是一个快速、可扩展的、高吞吐、可容错的分布式发布订阅消息系统，具有高吞吐量、内置分区、支持数据副本和容错的特性，适合在大规模消息处理场景中使用。 前提条件 Kafka服务

查看更多 →

数据从OA同步到ERP 整体设计流程： 详细设计图： 图1 如上图，数据从OA同步到ERP具体方案如下： 使用之前已经建好的B1(servicelayer)连接器，在连接器中创建一个执行动作，封装创建单据的统一接口； 创建一条api流，用于接受OA审批完成后外发的数据； 将OA外发

查看更多 →

数据； 遍历查询出的所有未同步数据，对每条数据单独处理； 按照OA创建数据接口要求，将B1查询出的数据构造成OA接口的请求格式； 使用OA连接器中创建数据的执行动作，调用OA创建数据接口，在OA中创建数据； 如果在OA中创建数据成功，使用servicelayer连接器中更新数据的

查看更多 →

创建OA审批结果外发流 在OA系统提交审批时，OA系统将审批结果以接口形式发送到 集成工作台 ，因此第一个节点选择"当收到HTTP请求"时 根据OA外发的接口格式，定义请求体参数，在后续节点可以直接引用 根据发送的requestid查询对应的草稿单，用自定义B1连接器中的查询草稿单列

查看更多 →

跨层迁移数据的行为操作。 SET_REPL：为文件设置新的副本数的行为操作。 MOVE_TO_FOLDER：将文件移动到目标文件夹的行为操作。 DELETE：删除文件/目录的行为操作。 SET_NODE_LABEL：设置文件节点标签（NodeLabel）的操作。 使用HDFS冷热

查看更多 →

Spark开源增强特性 跨源复杂数据的SQL查询优化 出于管理和信息收集的需要，企业内部会存储海量数据，包括数目众多的各种数据库、 数据仓库 等，此时会面临以下困境：数据源种类繁多，数据集结构化混合，相关数据存放分散等，这就导致了跨源复杂查询因传输效率低，耗时长。 当前开源Spark

查看更多 →

接收、处理及结果输出；并可以在合适的时候中止业务。 高可用性 Nimbus HA机制，避免了开源Storm集群中Nimbus出现单点故障而导致集群无法提供Topology的新增及管理操作的问题，增强了集群可用性。 父主题： Storm

查看更多 →

开源Kafka输出流 功能描述 DLI将Flink作业的输出数据输出到Kafka中。 Apache Kafka是一个快速、可扩展的、高吞吐、可容错的分布式发布订阅消息系统，具有高吞吐量、内置分区、支持数据副本和容错的特性，适合在大规模消息处理场景中使用。 前提条件 Kafka服务

查看更多 →

开源许可证 操作场景 用户可以查看开源许可证的信息和自定义开源许可证的风险等级。 前提条件 已获取管理控制台的登录账号与密码。 操作步骤 登录开源治理服务控制台。 在左侧导航栏，单击“开源许可证”。 在“开源许可证”页面，可看到许可证列表，内容包含许可证名称、集成风险、许可证描述和风险分析以及重置操作。

查看更多 →

解除云办公服务锁定状态 功能介绍 该接口目前支持解除云办公服务锁定状态。 调试 您可以在 API Explorer 中调试该接口，支持自动认证鉴权。API Explorer可以自动生成SDK代码示例，并提供SDK代码示例调试功能。 URI PUT /v2/{project_id}/w

查看更多 →

存储产品 存储类别 典型应用场景 使用流程 块存储 共享存储池资源 企业日常办公 开发测试 企业应用，例如SAP、Microsoft Exchange和Microsoft SharePoint等 分布式文件系统 各类数据库，例如：MongoDB、Oracle、SQL Server、MySQL和PostgreSQL等

查看更多 →

描述 is_lock Integer 云办公服务是否被锁定，0代表未锁定，1代表锁定。 lock_time String 云办公服务锁定时间，格式：yyyy-MM-dd HH:mm:ss，时区：UTC。 lock_reason String 云办公服务锁定原因。 状态码： 400 表4

查看更多 →

安全办公园区解决方案 方案概述 部署指南

查看更多 →

v/auth/applytoken systemid: OA系统标识 password: OA系统密码 operator：OA操作人 建立连接器连接、认证鉴权 项目Service Layer云服务地址 客户 https://api-service.sperp.myhuaweicloud

查看更多 →

SparkPackERP->OA->SparkPackERP 库存发货单类型为‘报废’ 用户在SparkPackERP系统创建类型为‘报废’的库存发货单，进入等待审批，在前面两个审批阶段完成后进入第三审批阶段 批准者在OA系统对库存发货草稿单审核后进行批准或拒绝操作。 用户登录Spark

查看更多 →

备注 VN/VN QoS组 OA 办公业务 策略名称 test_spr_pf test_spr_lb test_spr_pf：为实时视频会议业务使用的智能选路策略，优先调度到MPLS链路，采用优先占用方式的选路。 test_spr_lb：为大流量办公业务（如文件传输业务）使用的智

查看更多 →