从流获取记录帮助文档

从流获取记录是从上一转换执行后的结果中获取数据并输出。该步骤必须和其他带有“转换”或“将行复制到结果”功能的插件配合使用。步骤配置信息如图1所示。 

 

                           

                                                     图1 “从流获取数据”步骤配置信息

 

下文详细解释各控件的含义：

1、转换步骤名称：步骤的名称，在单一转换中，名称必须唯一。

2、字段：

(1)、字段名称：输入流中的记录字段名称，指定后将从流中获取该字段记录。

(2)、类型：指定字段类型：字符串，日期，数字，布尔值，整数，BigNumber，序列化或二进制

(3)、长度：对于数字：数字的有效长度；对于字符串：字符串的总长度；对于日期：字符串的打印输出长度（例如，输入4只会返回年份）。

(4)、精度：对于数字：小数位数。

 

下面将举例说明“从流获取记录”步骤在“Kafka消费者”步骤中的使用场景：

在“从流获取记录”步骤中设置好Kafka消费者的字段名称，再将其写入日志如图2-4所示

             

 

                                             图2 “从流获取记录”步骤配置信息

               

 

                                             图3 “从流获取记录”步骤配置信息

      

 

                                             图4 “从流获取记录”步骤配置信息

在“Kafka消费者”步骤中的“转换”处，设置好“从流获取记录”转换的路径。如图5所示：

     

 

                                             图5 “Kafka消费者”步骤配置信息

执行后，结果如图6所示：

     

 

                                                             图6 执行结果

 

文章原创首发于：https://ckettle.ccsaii.com.cn/help/StepPluginType/RecordsFromStream?s=****

更多CKettle内容，欢迎点击上述链接学习。