:MySQL Reader

{
    "type":"job",
    "version":"2.0",// The version number. 
    "steps":[
        {
            "stepType":"mysql",// The reader type. 
            "parameter":{
                "column":[// The names of the columns from which you want to read data. 
                    "id"
                ],
                "connection":[
                    {   "querySql":["select a,b from join1 c join join2 d on c.id = d.id;"], // The SQL statement that is used to read data from the source table. 
                        "datasource":"",// The name of the data source. 
                        "table":[// The name of the source table. The table name must be enclosed in brackets []. 
                            "xxx"
                        ]
                    }
                ],
                "where":"",// The WHERE clause. 
                "splitPk":"",// The shard key. 
                "encoding":"UTF-8"// The encoding format. 
            },
            "name":"Reader",
            "category":"reader"
        },
        {
            "stepType":"stream",
            "parameter":{},
            "name":"Writer",
            "category":"writer"
        }
    ],
    "setting":{
        "errorLimit":{
            "record":"0"// The maximum number of dirty data records allowed. 
        },
        "speed":{
            "throttle":true,// Specifies whether to enable throttling. The value false indicates that throttling is disabled, and the value true indicates that throttling is enabled. The mbps parameter takes effect only when the throttle parameter is set to true. 
            "concurrent":1,// The maximum number of parallel threads. 
            "mbps":"12"// The maximum transmission rate.
        }
    },
    "order":{
        "hops":[
            {
                "from":"Reader",
                "to":"Writer"
            }
        ]
    }
}

{
    "type": "job",
    "version": "2.0",
    "steps": [
        {
            "stepType": "mysql",
            "parameter": {
                "indexes": [
                    {
                        "type": "unique",
                        "column": [
                            "id"
                        ]
                    }
                ],
                "envType": 0,
                "useSpecialSecret": false,
                "column": [
                    "id",
                    "buyer_name",
                    "seller_name",
                    "item_id",
                    "city",
                    "zone"
                ],
                "tableComment": "Test order table",
                "connection": [
                    {
                        "datasource": "rds_dataservice",
                        "table": [
                            "rds_table"
                        ]
                    },
                    {
                        "datasource": "rds_workshop_log",
                        "table": [
                            "rds_table"
                        ]
                    }
                ],
                "where": "",
                "splitPk": "id",
                "encoding": "UTF-8"
            },
            "name": "Reader",
            "category": "reader"
        },
        {
            "stepType": "odps",
            "parameter": {
                           },
            "name": "Writer",
            "category": "writer"
        },
        {
            "name": "Processor",
            "stepType": null,
            "category": "processor",
            "copies": 1,
            "parameter": {
                "nodes": [],
                "edges": [],
                "groups": [],
                "version": "2.0"
            }
        }
    ],
    "setting": {
        "executeMode": null,
        "errorLimit": {
            "record": ""
        },
        "speed": {
            "concurrent": 2,
            "throttle": false
        }
    },
    "order": {
        "hops": [
            {
                "from": "Reader",
                "to": "Writer"
            }
        ]
    }
}