本文为您介绍Stream Reader支持的数据类型、字段映射和数据源等参数及配置示例。
Stream Reader插件实现了从内存中自动产生数据的功能,主要用于数据同步的性能测试和基本的功能测试。
Stream Reader支持的数据类型,如下所示。
数据类型 | 类型描述 |
---|---|
string | 字符型 |
long | 长整型 |
date | 日期类型 |
bool | 布尔型 |
bytes | 字节型 |
参数说明
参数 | 描述 | 是否必选 | 默认值 |
---|---|---|---|
column | 产生的源数据的列数据和类型,可以配置多列。可以配置产生随机字符串,并制定范围,示例如下。
配置项说明如下:
|
是 | 无 |
sliceRecordCount | 表示循环产生column的份数。 | 是 | 无 |
脚本开发介绍
配置一个从内存中读数据的同步作业。
{
"type":"job",
"version":"2.0",//版本号。
"steps":[
{
"stepType":"stream",//插件名。
"parameter":{
"column":[//字段。
{
"type":"string",//数据类型。
"value":"field"//值。
},
{
"type":"long",
"value":100
},
{
"dateFormat":"yyyy-MM-dd HH:mm:ss",//时间格式。
"type":"date",
"value":"2014-12-12 12:12:12"
},
{
"type":"bool",
"value":true
},
{
"type":"bytes",
"value":"byte string"
}
],
"sliceRecordCount":"100000"//表示循环产生column的份数。
},
"name":"Reader",
"category":"reader"
},
{
"stepType":"stream",
"parameter":{},
"name":"Writer",
"category":"writer"
}
],
"setting":{
"errorLimit":{
"record":"0"//错误记录数。
},
"speed":{
"throttle":true,//false代表不限流,下面的限流的速度不生效;true代表限流。
"concurrent":1,//作业并发数。
"mbps":"12"//限流
}
},
"order":{
"hops":[
{
"from":"Reader",
"to":"Writer"
}
]
}
}