数据库 MySQL Redis DB2 Gauss 200 Gauss 100 Oracle PostgreSQL Sql Server 父主题： 连接器

查看更多 →

数据库 数据库监控项可以对数据库的访问进行监控，可以监控的数据库包含C3P0连接池、Cassandra、ClickHouse、DBCP、Druid、EsRestClient、GaussDb、Hikari连接池、Jetcd、ObsClient、MySQL、Postgresql、Or

查看更多 →

(obj) => { let arr = Object.keys(obj) let res = [] arr.forEach(item => { if (!item.includes('Table')) { res.push({

查看更多 →

collection.mutable.ResizableArray$class.foreach(ResizableArray.scala:59) at scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:47) at kafka

查看更多 →

regclass, older_than interval) 描述：用于给开启自动删除分区功能的表删除分区。 返回值类型：void 备注：该函数运行时，遍历表所有分区，并删除其中boundary小于(now_time - older_than)的分区；如果所有分区都满足删除条件，则保留一个分区，并truncate该表。

查看更多 →

员只需做适量修订，机器自主探索遍历ODG图执行，同步并行完成结果的判定和报告的生成，机器对成功和失败的结果分层聚类，测试人员只需按类批量确认结果。 关键特性 ATGen基于正向API接口定义文档，自动挖掘API测试上下文操作依赖图（ODG），探索遍历ODG自主生成API测试序列，

查看更多 →

，将RDD中所有数据写 MySQL，那么如果是普通的foreach算子，就会一条数据一条数据地写，每次函数调用可能就会创建一个数据库连接，此时就势必会频繁地创建和销毁数据库连接，性能是非常低下；但是如果用foreachPartitions算子一次性处理一个partition的数据，那么对于每个

查看更多 →

集成工作台 -我的流-创建流 步骤2 添加重复执行计划： 步骤2 添加执行动作查询物料列表 查询时间为前两分钟到前一分钟报工的记录： 步骤3 新增遍历循环，遍历从SparkPack 企业ERP查询的物料记录 步骤4 新增变量记录 步骤5 调用mes物料导入 步骤6 给导入接口对应的字段填值 步骤7

查看更多 →

，并输出 val result = femaleData.filter(line => line._2 > 120) result.foreach(println) 父主题： Spark Core程序

查看更多 →

添加重复执行计划： 步骤2 添加执行动作查询MES报工记录列表 查询时间为前两分钟到前一分钟报工的记录： 步骤3 新建变量记录各个查询值 步骤4 新增遍历循环，遍历从MES查询的报工记录 步骤5 根据查询结果为上一步创建的变量赋值 步骤6 根据工单ID查询工序计划详情 步骤7 根据工序计划判断是否

查看更多 →

作 执行动作中的参数用全局配置来管理 定义一个数组变量来接受处理的数据 前面查询单据列表会一次查询出多条数据，因此需要遍历来处理，新增一个遍历集合元素节点，遍历内容引用查询单据列表响应体的value 添加一个数据转换执行动作，这个执行动作是在连接器里自定义的一个函数执行动作，函数

查看更多 →

"RequestId:%s\n", $resp ['RequestId'] ); // 获取删除成功的对象 printf ( "Deleteds:\n" ); foreach ( $resp ['Deleteds'] as $index => $deleted ) { printf ( "Deleteds[%d]"

查看更多 →

该执行动作无输出参数。 遍历集合元素 添加执行动作时，如果选择了“计划”执行动作，则流编排能映射上遍历集合元素里面需要选到遍历项的子节点。 用户选择该执行动作后，侧边栏弹出输入框： 用户需在输入框内填入数组参数，如[1,2,3]或引用数组参数。 如果想对遍历的当前项进行数据处理，可在上下文引用中获取到当前项。

查看更多 →

该执行动作无输出参数。 遍历集合元素 添加执行动作时，如果选择了“计划”执行动作，则流编排能映射上遍历集合元素里面需要选到遍历项的子节点。 用户选择该执行动作后，侧边栏弹出输入框： 用户需在输入框内填入数组参数，如[1,2,3]或引用数组参数。 如果想对遍历的当前项进行数据处理，可在上下文引用中获取到当前项。

查看更多 →

<property name="url" value="jdbc:opengauss://***.***.***.***（需要替换为数据库ip）:20000（需要替换为数据库端口）/test?（test需要替换为对应的database）connectionTimeout=10"/>

查看更多 →

<property name="url" value="jdbc:opengauss://***.***.***.***（需要替换为数据库ip）:20000（需要替换为数据库端口）/test?（test需要替换为对应的database）connectionTimeout=10"/>

查看更多 →

ListObjectsResponse response = client.ListObjects(request); foreach (ObsObject entry in response.ObsObjects) { Console.WriteLine("key

查看更多 →

filter(line => line._2 > 120) result.collect().map(x => x._1 + ',' + x._2).foreach(println) spark.stop() 父主题： Spark Core样例程序

查看更多 →

filter(line => line._2 > 120) result.collect().map(x => x._1 + ',' + x._2).foreach(println) spark.stop() 父主题： Spark Core样例程序

查看更多 →

filter(line => line._2 > 120) result.collect().map(x => x._1 + ',' + x._2).foreach(println) spark.stop() 父主题： Spark Core样例程序

查看更多 →

"SparkOnMultiHbase" val clusterFlagList=List("B", "A") clusterFlagList.foreach{ item => val hbaseConf = getConf( item ) println(hbaseConf

查看更多 →