DescribeStreamingJobResponseBody (gpdb20160503 3.0.0 API)

java.lang.Object
- com.aliyun.tea.TeaModel
- - com.aliyun.gpdb20160503.models.DescribeStreamingJobResponseBody

public class DescribeStreamingJobResponseBody
extends com.aliyun.tea.TeaModel

字段概要

字段
限定符和类型	字段和说明
`String`	`account` The username of the account.
`String`	`consistency` example: ATLEAST / EXACTLY
`String`	`createTime` The time when the job was created.
`String`	`dataSourceId` The name of the data source.
`String`	`dataSourceName` example: test_kafka
`List<String>`	`destColumns` The destination fields.
`String`	`destDatabase` The name of the destination database.
`String`	`destSchema` example: dest-schema
`String`	`destTable` The name of the destination table.
`Integer`	`errorLimitCount` example: 5
`String`	`errorMessage` The information about the job status.
`String`	`fallbackOffset` example: EARLIEST / LATEST
`String`	`groupName` example: test_group
`String`	`jobConfig` example: DATABASE: adbpgss_test USER: adbpgss_test PASSWORD: adbpgssTest HOST: gp-xxx-master.gpdb.rds-aliyun-pre.rds.aliyuncs.com PORT: 5432 KAFKA: INPUT: SOURCE: BROKERS: broker1:9092,broker2:9092,broker3:9092 TOPIC: testtopic FALLBACK_OFFSET: earliest KEY: COLUMNS: - NAME: customer_id TYPE: int FORMAT: delimited DELIMITED_OPTION: DELIMITER: \"\|\" VALUE: COLUMNS: - TYPE: integer NAME: l_orderkey - TYPE: integer NAME: l_partkey - TYPE: integer NAME: l_suppkey - TYPE: integer NAME: l_linenumber - TYPE: decimal NAME: l_quantity - TYPE: decimal NAME: l_extendedprice - TYPE: decimal NAME: l_discount - TYPE: decimal NAME: l_tax - TYPE: char NAME: l_returnflag - TYPE: char NAME: l_linestatus - TYPE: date NAME: l_shipdate - TYPE: date NAME: l_commitdate - TYPE: date NAME: l_receiptdate - TYPE: text NAME: l_shipinstruct - TYPE: text NAME: l_shipmode - TYPE: text NAME: l_comment FORMAT: delimited DELIMITED_OPTION: DELIMITER: \"\|\" ERROR_LIMIT: 10 OUTPUT: SCHEMA: adbpgss_test TABLE: write_with_insert_plaintext MODE: MERGE MATCH_COLUMNS: - l_orderkey - l_partkey - l_suppkey UPDATE_COLUMNS: - l_linenumber - l_quantity - l_extendedprice - l_discount - l_tax - l_returnflag - l_linestatus - l_shipdate - l_commitdate - l_receiptdate - l_shipinstruct - l_shipmode - l_comment MAPPING: - EXPRESSION: l_orderkey NAME: l_orderkey - EXPRESSION: l_partkey NAME: l_partkey - EXPRESSION: l_suppkey NAME: l_suppkey - EXPRESSION: l_linenumber NAME: l_linenumber - EXPRESSION: l_quantity NAME: l_quantity - EXPRESSION: l_extendedprice NAME: l_extendedprice - EXPRESSION: l_discount NAME: l_discount - EXPRESSION: l_tax NAME: l_tax - EXPRESSION: l_returnflag NAME: l_returnflag - EXPRESSION: l_linestatus NAME: l_linestatus - EXPRESSION: l_shipdate NAME: l_shipdate - EXPRESSION: l_commitdate NAME: l_commitdate - EXPRESSION: l_receiptdate NAME: l_receiptdate - EXPRESSION: l_shipinstruct NAME: l_shipinstruct - EXPRESSION: l_shipmode NAME: l_shipmode - EXPRESSION: l_comment NAME: l_comment COMMIT: MAX_ROW: 1000 MINIMAL_INTERVAL: 1000 CONSISTENCY: ATLEAST POLL: BATCHSIZE: 1000 TIMEOUT: 1000 PROPERTIES: group.id: testgroup
`String`	`jobDescription` The description of the job.
`String`	`jobId` The job ID.
`String`	`jobName` The name of the job.
`List<String>`	`matchColumns`
`String`	`mode` example: basic/professional
`String`	`modifyTime` The time when the job was last modified.
`String`	`password` The password of the account.
`String`	`requestId` The request ID.
`List<String>`	`srcColumns` The source fields.
`String`	`status` The status of the job.
`List<String>`	`updateColumns`
`String`	`writeMode` The write mode.

构造器概要

构造器
构造器和说明

DescribeStreamingJobResponseBody()

构造器
构造器和说明
`DescribeStreamingJobResponseBody()`

方法概要

所有方法静态方法实例方法具体方法
限定符和类型	方法和说明
`static DescribeStreamingJobResponseBody`	`build(Map<String,?> map)`
`String`	`getAccount()`
`String`	`getConsistency()`
`String`	`getCreateTime()`
`String`	`getDataSourceId()`
`String`	`getDataSourceName()`
`List<String>`	`getDestColumns()`
`String`	`getDestDatabase()`
`String`	`getDestSchema()`
`String`	`getDestTable()`
`Integer`	`getErrorLimitCount()`
`String`	`getErrorMessage()`
`String`	`getFallbackOffset()`
`String`	`getGroupName()`
`String`	`getJobConfig()`
`String`	`getJobDescription()`
`String`	`getJobId()`
`String`	`getJobName()`
`List<String>`	`getMatchColumns()`
`String`	`getMode()`
`String`	`getModifyTime()`
`String`	`getPassword()`
`String`	`getRequestId()`
`List<String>`	`getSrcColumns()`
`String`	`getStatus()`
`List<String>`	`getUpdateColumns()`
`String`	`getWriteMode()`
`DescribeStreamingJobResponseBody`	`setAccount(String account)`
`DescribeStreamingJobResponseBody`	`setConsistency(String consistency)`
`DescribeStreamingJobResponseBody`	`setCreateTime(String createTime)`
`DescribeStreamingJobResponseBody`	`setDataSourceId(String dataSourceId)`
`DescribeStreamingJobResponseBody`	`setDataSourceName(String dataSourceName)`
`DescribeStreamingJobResponseBody`	`setDestColumns(List<String> destColumns)`
`DescribeStreamingJobResponseBody`	`setDestDatabase(String destDatabase)`
`DescribeStreamingJobResponseBody`	`setDestSchema(String destSchema)`
`DescribeStreamingJobResponseBody`	`setDestTable(String destTable)`
`DescribeStreamingJobResponseBody`	`setErrorLimitCount(Integer errorLimitCount)`
`DescribeStreamingJobResponseBody`	`setErrorMessage(String errorMessage)`
`DescribeStreamingJobResponseBody`	`setFallbackOffset(String fallbackOffset)`
`DescribeStreamingJobResponseBody`	`setGroupName(String groupName)`
`DescribeStreamingJobResponseBody`	`setJobConfig(String jobConfig)`
`DescribeStreamingJobResponseBody`	`setJobDescription(String jobDescription)`
`DescribeStreamingJobResponseBody`	`setJobId(String jobId)`
`DescribeStreamingJobResponseBody`	`setJobName(String jobName)`
`DescribeStreamingJobResponseBody`	`setMatchColumns(List<String> matchColumns)`
`DescribeStreamingJobResponseBody`	`setMode(String mode)`
`DescribeStreamingJobResponseBody`	`setModifyTime(String modifyTime)`
`DescribeStreamingJobResponseBody`	`setPassword(String password)`
`DescribeStreamingJobResponseBody`	`setRequestId(String requestId)`
`DescribeStreamingJobResponseBody`	`setSrcColumns(List<String> srcColumns)`
`DescribeStreamingJobResponseBody`	`setStatus(String status)`
`DescribeStreamingJobResponseBody`	`setUpdateColumns(List<String> updateColumns)`
`DescribeStreamingJobResponseBody`	`setWriteMode(String writeMode)`

从类继承的方法 com.aliyun.tea.TeaModel
build, buildMap, confirmType, confirmType, parseObject, toMap, toMap, toModel, validate, validateParams

从类继承的方法 java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- 字段详细资料
  - account
```
@NameInMap(value="Account")
public String account
```
    The username of the account.
    example:
    test-account
  - consistency
```
@NameInMap(value="Consistency")
public String consistency
```
    example:
    ATLEAST / EXACTLY
  - createTime
```
@NameInMap(value="CreateTime")
public String createTime
```
    The time when the job was created.
    
    Use the UTC time format: yyyy-MM-ddTHH:mm:ssZ
    example:
    2019-09-08T16:00:00Z
  - dataSourceId
```
@NameInMap(value="DataSourceId")
public String dataSourceId
```
    The name of the data source.
    example:
    test-kafka
  - dataSourceName
```
@NameInMap(value="DataSourceName")
public String dataSourceName
```
    example:
    test_kafka
  - destColumns
```
@NameInMap(value="DestColumns")
public List<String> destColumns
```
    The destination fields.
  - destDatabase
```
@NameInMap(value="DestDatabase")
public String destDatabase
```
    The name of the destination database.
    example:
    dest-db
  - destSchema
```
@NameInMap(value="DestSchema")
public String destSchema
```
    example:
    dest-schema
  - destTable
```
@NameInMap(value="DestTable")
public String destTable
```
    The name of the destination table.
    example:
    dest-table
  - errorLimitCount
```
@NameInMap(value="ErrorLimitCount")
public Integer errorLimitCount
```
    example:
    5
  - errorMessage
```
@NameInMap(value="ErrorMessage")
public String errorMessage
```
    The information about the job status. For example, if the job is in the Exception state, the cause of the exception is displayed. If the job is in the Running state, this parameter is left empty.
    example:
    ""
  - fallbackOffset
```
@NameInMap(value="FallbackOffset")
public String fallbackOffset
```
    example:
    EARLIEST / LATEST
  - groupName
```
@NameInMap(value="GroupName")
public String groupName
```
    example:
    test_group
  - jobConfig
```
@NameInMap(value="JobConfig")
public String jobConfig
```
    example:
    DATABASE: adbpgss_test USER: adbpgss_test PASSWORD: adbpgssTest HOST: gp-xxx-master.gpdb.rds-aliyun-pre.rds.aliyuncs.com PORT: 5432 KAFKA: INPUT: SOURCE: BROKERS: broker1:9092,broker2:9092,broker3:9092 TOPIC: testtopic FALLBACK_OFFSET: earliest KEY: COLUMNS: - NAME: customer_id TYPE: int FORMAT: delimited DELIMITED_OPTION: DELIMITER: \"|\" VALUE: COLUMNS: - TYPE: integer NAME: l_orderkey - TYPE: integer NAME: l_partkey - TYPE: integer NAME: l_suppkey - TYPE: integer NAME: l_linenumber - TYPE: decimal NAME: l_quantity - TYPE: decimal NAME: l_extendedprice - TYPE: decimal NAME: l_discount - TYPE: decimal NAME: l_tax - TYPE: char NAME: l_returnflag - TYPE: char NAME: l_linestatus - TYPE: date NAME: l_shipdate - TYPE: date NAME: l_commitdate - TYPE: date NAME: l_receiptdate - TYPE: text NAME: l_shipinstruct - TYPE: text NAME: l_shipmode - TYPE: text NAME: l_comment FORMAT: delimited DELIMITED_OPTION: DELIMITER: \"|\" ERROR_LIMIT: 10 OUTPUT: SCHEMA: adbpgss_test TABLE: write_with_insert_plaintext MODE: MERGE MATCH_COLUMNS: - l_orderkey - l_partkey - l_suppkey UPDATE_COLUMNS: - l_linenumber - l_quantity - l_extendedprice - l_discount - l_tax - l_returnflag - l_linestatus - l_shipdate - l_commitdate - l_receiptdate - l_shipinstruct - l_shipmode - l_comment MAPPING: - EXPRESSION: l_orderkey NAME: l_orderkey - EXPRESSION: l_partkey NAME: l_partkey - EXPRESSION: l_suppkey NAME: l_suppkey - EXPRESSION: l_linenumber NAME: l_linenumber - EXPRESSION: l_quantity NAME: l_quantity - EXPRESSION: l_extendedprice NAME: l_extendedprice - EXPRESSION: l_discount NAME: l_discount - EXPRESSION: l_tax NAME: l_tax - EXPRESSION: l_returnflag NAME: l_returnflag - EXPRESSION: l_linestatus NAME: l_linestatus - EXPRESSION: l_shipdate NAME: l_shipdate - EXPRESSION: l_commitdate NAME: l_commitdate - EXPRESSION: l_receiptdate NAME: l_receiptdate - EXPRESSION: l_shipinstruct NAME: l_shipinstruct - EXPRESSION: l_shipmode NAME: l_shipmode - EXPRESSION: l_comment NAME: l_comment COMMIT: MAX_ROW: 1000 MINIMAL_INTERVAL: 1000 CONSISTENCY: ATLEAST POLL: BATCHSIZE: 1000 TIMEOUT: 1000 PROPERTIES: group.id: testgroup
  - jobDescription
```
@NameInMap(value="JobDescription")
public String jobDescription
```
    The description of the job.
    example:
    test_job
  - jobId
```
@NameInMap(value="JobId")
public String jobId
```
    The job ID.
    example:
    1
  - jobName
```
@NameInMap(value="JobName")
public String jobName
```
    The name of the job.
    example:
    test-job
  - matchColumns
```
@NameInMap(value="MatchColumns")
public List<String> matchColumns
```
  - mode
```
@NameInMap(value="Mode")
public String mode
```
    example:
    basic/professional
  - modifyTime
```
@NameInMap(value="ModifyTime")
public String modifyTime
```
    The time when the job was last modified.
    
    Use the UTC time format: yyyy-MM-ddTHH:mm:ssZ
    example:
    2019-09-08T17:00:00Z
  - password
```
@NameInMap(value="Password")
public String password
```
    The password of the account.
    example:
    pwd123
  - requestId
```
@NameInMap(value="RequestId")
public String requestId
```
    The request ID.
    example:
    B4CAF581-2AC7-41AD-8940-D56DF7AADF5B
  - srcColumns
```
@NameInMap(value="SrcColumns")
public List<String> srcColumns
```
    The source fields.
  - status
```
@NameInMap(value="Status")
public String status
```
    The status of the job. Valid values:
    - Init: The job is being initialized.
    - Running: The job is running.
    - Exception: The job encounters an exception.
    - Paused: The job is paused.
    example:
    Running
  - updateColumns
```
@NameInMap(value="UpdateColumns")
public List<String> updateColumns
```
  - writeMode
```
@NameInMap(value="WriteMode")
public String writeMode
```
    The write mode.
    example:
    INSERT/UPDATE/MERGE
- 构造器详细资料
  - DescribeStreamingJobResponseBody
```
public DescribeStreamingJobResponseBody()
```
- 方法详细资料
  - build
```
public static DescribeStreamingJobResponseBody build(Map<String,?> map)
                                              throws Exception
```
    抛出:
    
    Exception
  - setAccount
```
public DescribeStreamingJobResponseBody setAccount(String account)
```
  - getAccount
```
public String getAccount()
```
  - setConsistency
```
public DescribeStreamingJobResponseBody setConsistency(String consistency)
```
  - getConsistency
```
public String getConsistency()
```
  - setCreateTime
```
public DescribeStreamingJobResponseBody setCreateTime(String createTime)
```
  - getCreateTime
```
public String getCreateTime()
```
  - setDataSourceId
```
public DescribeStreamingJobResponseBody setDataSourceId(String dataSourceId)
```
  - getDataSourceId
```
public String getDataSourceId()
```
  - setDataSourceName
```
public DescribeStreamingJobResponseBody setDataSourceName(String dataSourceName)
```
  - getDataSourceName
```
public String getDataSourceName()
```
  - setDestColumns
```
public DescribeStreamingJobResponseBody setDestColumns(List<String> destColumns)
```
  - getDestColumns
```
public List<String> getDestColumns()
```
  - setDestDatabase
```
public DescribeStreamingJobResponseBody setDestDatabase(String destDatabase)
```
  - getDestDatabase
```
public String getDestDatabase()
```
  - setDestSchema
```
public DescribeStreamingJobResponseBody setDestSchema(String destSchema)
```
  - getDestSchema
```
public String getDestSchema()
```
  - setDestTable
```
public DescribeStreamingJobResponseBody setDestTable(String destTable)
```
  - getDestTable
```
public String getDestTable()
```
  - setErrorLimitCount
```
public DescribeStreamingJobResponseBody setErrorLimitCount(Integer errorLimitCount)
```
  - getErrorLimitCount
```
public Integer getErrorLimitCount()
```
  - setErrorMessage
```
public DescribeStreamingJobResponseBody setErrorMessage(String errorMessage)
```
  - getErrorMessage
```
public String getErrorMessage()
```
  - setFallbackOffset
```
public DescribeStreamingJobResponseBody setFallbackOffset(String fallbackOffset)
```
  - getFallbackOffset
```
public String getFallbackOffset()
```
  - setGroupName
```
public DescribeStreamingJobResponseBody setGroupName(String groupName)
```
  - getGroupName
```
public String getGroupName()
```
  - setJobConfig
```
public DescribeStreamingJobResponseBody setJobConfig(String jobConfig)
```
  - getJobConfig
```
public String getJobConfig()
```
  - setJobDescription
```
public DescribeStreamingJobResponseBody setJobDescription(String jobDescription)
```
  - getJobDescription
```
public String getJobDescription()
```
  - setJobId
```
public DescribeStreamingJobResponseBody setJobId(String jobId)
```
  - getJobId
```
public String getJobId()
```
  - setJobName
```
public DescribeStreamingJobResponseBody setJobName(String jobName)
```
  - getJobName
```
public String getJobName()
```
  - setMatchColumns
```
public DescribeStreamingJobResponseBody setMatchColumns(List<String> matchColumns)
```
  - getMatchColumns
```
public List<String> getMatchColumns()
```
  - setMode
```
public DescribeStreamingJobResponseBody setMode(String mode)
```
  - getMode
```
public String getMode()
```
  - setModifyTime
```
public DescribeStreamingJobResponseBody setModifyTime(String modifyTime)
```
  - getModifyTime
```
public String getModifyTime()
```
  - setPassword
```
public DescribeStreamingJobResponseBody setPassword(String password)
```
  - getPassword
```
public String getPassword()
```
  - setRequestId
```
public DescribeStreamingJobResponseBody setRequestId(String requestId)
```
  - getRequestId
```
public String getRequestId()
```
  - setSrcColumns
```
public DescribeStreamingJobResponseBody setSrcColumns(List<String> srcColumns)
```
  - getSrcColumns
```
public List<String> getSrcColumns()
```
  - setStatus
```
public DescribeStreamingJobResponseBody setStatus(String status)
```
  - getStatus
```
public String getStatus()
```
  - setUpdateColumns
```
public DescribeStreamingJobResponseBody setUpdateColumns(List<String> updateColumns)
```
  - getUpdateColumns
```
public List<String> getUpdateColumns()
```
  - setWriteMode
```
public DescribeStreamingJobResponseBody setWriteMode(String writeMode)
```
  - getWriteMode
```
public String getWriteMode()
```

类 DescribeStreamingJobResponseBody

字段概要

构造器概要

方法概要

从类继承的方法 com.aliyun.tea.TeaModel

从类继承的方法 java.lang.Object

字段详细资料

account

consistency

createTime

dataSourceId

dataSourceName

destColumns

destDatabase

destSchema

destTable

errorLimitCount

errorMessage

fallbackOffset

groupName

jobConfig

jobDescription

jobId

jobName

matchColumns

mode

modifyTime

password

requestId

srcColumns

status

updateColumns

writeMode

构造器详细资料

DescribeStreamingJobResponseBody

方法详细资料

build

setAccount

getAccount

setConsistency

getConsistency

setCreateTime

getCreateTime

setDataSourceId

getDataSourceId

setDataSourceName

getDataSourceName

setDestColumns

getDestColumns

setDestDatabase

getDestDatabase

setDestSchema

getDestSchema

setDestTable

getDestTable

setErrorLimitCount

getErrorLimitCount

setErrorMessage

getErrorMessage

setFallbackOffset

getFallbackOffset

setGroupName

getGroupName

setJobConfig

getJobConfig

setJobDescription

getJobDescription

setJobId

getJobId

setJobName

getJobName

setMatchColumns

getMatchColumns

setMode

getMode

setModifyTime

getModifyTime

setPassword

getPassword

setRequestId