From DIS

Sample JSON File

"from-config-values": {
          "configs": [
              {
                  "inputs": [
                      {
                         "name": "fromJobConfig.streamName",
                         "value": "cdm"
                      },
                      {
                         "name": "fromJobConfig.disConsumerStrategy",
                         "value": "FROM_LAST_STOP"
                      },
                      {
                         "name": "fromJobConfig.isPermanency",
                         "value": "true"
                      },
                      {
                         "name": "fromJobConfig.maxPollRecords",
                         "value": "100"
                      },
                      {
                         "name": "fromJobConfig.shardId",
                         "value": "0"
                      },
                      {
                         "name": "fromJobConfig.dataFormat",
                         "value": "BINARY"
                      },
                      {
                         "name": "fromJobConfig.separator",
                         "value": ","
                      }
                  ],
                  "name": "fromJobConfig"
              }
          ]
      }

Parameter Description

Parameter	Mandatory	Type	Description
fromJobConfig.streamName	Yes	String	DIS stream name
fromJobConfig.disConsumerStrategy	Yes	Enumeration	Used to set the initial offset when data is pulled from DIS. The options are as follows: LATEST: maximum offset, that is, the latest data FROM_LAST_STOP: data after the last stop EARLIEST: minimum offset, that is, the earliest data
fromJobConfig.isPermanency	Yes	Boolean	Whether to run permanently
fromJobConfig.maxPollRecords	No	String	Maximum number of requests that can be sent to DIS each time
fromJobConfig.shardId	Yes	String	ID of the DIS partition. You can enter multiple partition IDs, which are separated by commas (,).
fromJobConfig.dataFormat	Yes	Enumeration	Format used for parsing data. The options are as follows: BINARY: Data is transferred without being parsed, which is applicable to file migration. CSV: Source data will be migrated after being parsed in CSV format.
fromJobConfig.separator	No	String	Field delimiter
fromJobConfig.appName	No	String	Unique identifier of the consumer application