ModifyStreamingJobRequest (gpdb20160503 3.0.0 API)

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

public class ModifyStreamingJobRequest
extends com.aliyun.tea.TeaModel

字段概要

字段
限定符和类型	字段和说明
`String`	`account` The name of the database account.
`String`	`consistency` The delivery guarantee setting.
`String`	`DBInstanceId` The instance ID.
`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.
`Long`	`errorLimitCount` example: 5
`String`	`fallbackOffset` example: earliest / latest
`String`	`groupName` example: group_name
`String`	`jobConfig` The YAML configuration file of the job.
`String`	`jobDescription` The description of the job.
`Long`	`jobId` The job ID.
`List<String>`	`matchColumns`
`String`	`password` The password of the database account.
`String`	`regionId` example: cn-beijing
`List<String>`	`srcColumns` The source fields.
`Boolean`	`tryRun` Specifies whether to test the real-time job.
`List<String>`	`updateColumns`
`String`	`writeMode` The write mode.

构造器概要

构造器
构造器和说明

ModifyStreamingJobRequest()

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

方法概要

所有方法静态方法实例方法具体方法
限定符和类型	方法和说明
`static ModifyStreamingJobRequest`	`build(Map<String,?> map)`
`String`	`getAccount()`
`String`	`getConsistency()`
`String`	`getDBInstanceId()`
`List<String>`	`getDestColumns()`
`String`	`getDestDatabase()`
`String`	`getDestSchema()`
`String`	`getDestTable()`
`Long`	`getErrorLimitCount()`
`String`	`getFallbackOffset()`
`String`	`getGroupName()`
`String`	`getJobConfig()`
`String`	`getJobDescription()`
`Long`	`getJobId()`
`List<String>`	`getMatchColumns()`
`String`	`getPassword()`
`String`	`getRegionId()`
`List<String>`	`getSrcColumns()`
`Boolean`	`getTryRun()`
`List<String>`	`getUpdateColumns()`
`String`	`getWriteMode()`
`ModifyStreamingJobRequest`	`setAccount(String account)`
`ModifyStreamingJobRequest`	`setConsistency(String consistency)`
`ModifyStreamingJobRequest`	`setDBInstanceId(String DBInstanceId)`
`ModifyStreamingJobRequest`	`setDestColumns(List<String> destColumns)`
`ModifyStreamingJobRequest`	`setDestDatabase(String destDatabase)`
`ModifyStreamingJobRequest`	`setDestSchema(String destSchema)`
`ModifyStreamingJobRequest`	`setDestTable(String destTable)`
`ModifyStreamingJobRequest`	`setErrorLimitCount(Long errorLimitCount)`
`ModifyStreamingJobRequest`	`setFallbackOffset(String fallbackOffset)`
`ModifyStreamingJobRequest`	`setGroupName(String groupName)`
`ModifyStreamingJobRequest`	`setJobConfig(String jobConfig)`
`ModifyStreamingJobRequest`	`setJobDescription(String jobDescription)`
`ModifyStreamingJobRequest`	`setJobId(Long jobId)`
`ModifyStreamingJobRequest`	`setMatchColumns(List<String> matchColumns)`
`ModifyStreamingJobRequest`	`setPassword(String password)`
`ModifyStreamingJobRequest`	`setRegionId(String regionId)`
`ModifyStreamingJobRequest`	`setSrcColumns(List<String> srcColumns)`
`ModifyStreamingJobRequest`	`setTryRun(Boolean tryRun)`
`ModifyStreamingJobRequest`	`setUpdateColumns(List<String> updateColumns)`
`ModifyStreamingJobRequest`	`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 name of the database account.
    example:
    test-account
  - consistency
```
@NameInMap(value="Consistency")
public String consistency
```
    The delivery guarantee setting.
    
    Valid values:
    - ATLEAST
    - EXACTLY
    example:
    ATLEAST / EXACTLY
  - DBInstanceId
```
@NameInMap(value="DBInstanceId")
public String DBInstanceId
```
    The instance ID.
    
    This parameter is required.
    example:
    ModifyStreamingJob
  - 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 Long errorLimitCount
```
    example:
    5
  - fallbackOffset
```
@NameInMap(value="FallbackOffset")
public String fallbackOffset
```
    example:
    earliest / latest
  - groupName
```
@NameInMap(value="GroupName")
public String groupName
```
    example:
    group_name
  - jobConfig
```
@NameInMap(value="JobConfig")
public String jobConfig
```
    The YAML configuration file of the job. This parameter must be specified when Mode is set to professional.
    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 Long jobId
```
    The job ID.
    
    This parameter is required.
    example:
    1
  - matchColumns
```
@NameInMap(value="MatchColumns")
public List<String> matchColumns
```
  - password
```
@NameInMap(value="Password")
public String password
```
    The password of the database account.
    example:
    pwd123
  - regionId
```
@NameInMap(value="RegionId")
public String regionId
```
    example:
    cn-beijing
  - srcColumns
```
@NameInMap(value="SrcColumns")
public List<String> srcColumns
```
    The source fields.
  - tryRun
```
@NameInMap(value="TryRun")
public Boolean tryRun
```
    Specifies whether to test the real-time job. Valid values:
    - true
    - false
    Default value: false.
    example:
    true
  - updateColumns
```
@NameInMap(value="UpdateColumns")
public List<String> updateColumns
```
  - writeMode
```
@NameInMap(value="WriteMode")
public String writeMode
```
    The write mode.
    
    Valid values:
    - insert
    - update
    - merge
    example:
    INSERT/UPDATE/MERGE
- 构造器详细资料
  - ModifyStreamingJobRequest
```
public ModifyStreamingJobRequest()
```
- 方法详细资料
  - build
```
public static ModifyStreamingJobRequest build(Map<String,?> map)
                                       throws Exception
```
    抛出:
    
    Exception
  - setAccount
```
public ModifyStreamingJobRequest setAccount(String account)
```
  - getAccount
```
public String getAccount()
```
  - setConsistency
```
public ModifyStreamingJobRequest setConsistency(String consistency)
```
  - getConsistency
```
public String getConsistency()
```
  - setDBInstanceId
```
public ModifyStreamingJobRequest setDBInstanceId(String DBInstanceId)
```
  - getDBInstanceId
```
public String getDBInstanceId()
```
  - setDestColumns
```
public ModifyStreamingJobRequest setDestColumns(List<String> destColumns)
```
  - getDestColumns
```
public List<String> getDestColumns()
```
  - setDestDatabase
```
public ModifyStreamingJobRequest setDestDatabase(String destDatabase)
```
  - getDestDatabase
```
public String getDestDatabase()
```
  - setDestSchema
```
public ModifyStreamingJobRequest setDestSchema(String destSchema)
```
  - getDestSchema
```
public String getDestSchema()
```
  - setDestTable
```
public ModifyStreamingJobRequest setDestTable(String destTable)
```
  - getDestTable
```
public String getDestTable()
```
  - setErrorLimitCount
```
public ModifyStreamingJobRequest setErrorLimitCount(Long errorLimitCount)
```
  - getErrorLimitCount
```
public Long getErrorLimitCount()
```
  - setFallbackOffset
```
public ModifyStreamingJobRequest setFallbackOffset(String fallbackOffset)
```
  - getFallbackOffset
```
public String getFallbackOffset()
```
  - setGroupName
```
public ModifyStreamingJobRequest setGroupName(String groupName)
```
  - getGroupName
```
public String getGroupName()
```
  - setJobConfig
```
public ModifyStreamingJobRequest setJobConfig(String jobConfig)
```
  - getJobConfig
```
public String getJobConfig()
```
  - setJobDescription
```
public ModifyStreamingJobRequest setJobDescription(String jobDescription)
```
  - getJobDescription
```
public String getJobDescription()
```
  - setJobId
```
public ModifyStreamingJobRequest setJobId(Long jobId)
```
  - getJobId
```
public Long getJobId()
```
  - setMatchColumns
```
public ModifyStreamingJobRequest setMatchColumns(List<String> matchColumns)
```
  - getMatchColumns
```
public List<String> getMatchColumns()
```
  - setPassword
```
public ModifyStreamingJobRequest setPassword(String password)
```
  - getPassword
```
public String getPassword()
```
  - setRegionId
```
public ModifyStreamingJobRequest setRegionId(String regionId)
```
  - getRegionId
```
public String getRegionId()
```
  - setSrcColumns
```
public ModifyStreamingJobRequest setSrcColumns(List<String> srcColumns)
```
  - getSrcColumns
```
public List<String> getSrcColumns()
```
  - setTryRun
```
public ModifyStreamingJobRequest setTryRun(Boolean tryRun)
```
  - getTryRun
```
public Boolean getTryRun()
```
  - setUpdateColumns
```
public ModifyStreamingJobRequest setUpdateColumns(List<String> updateColumns)
```
  - getUpdateColumns
```
public List<String> getUpdateColumns()
```
  - setWriteMode
```
public ModifyStreamingJobRequest setWriteMode(String writeMode)
```
  - getWriteMode
```
public String getWriteMode()
```

类 ModifyStreamingJobRequest

字段概要

构造器概要

方法概要

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

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

字段详细资料

account

consistency

DBInstanceId

destColumns

destDatabase

destSchema

destTable

errorLimitCount

fallbackOffset

groupName

jobConfig

jobDescription

jobId

matchColumns

password

regionId

srcColumns

tryRun

updateColumns

writeMode

构造器详细资料

ModifyStreamingJobRequest

方法详细资料

build

setAccount

getAccount

setConsistency

getConsistency

setDBInstanceId

getDBInstanceId

setDestColumns

getDestColumns

setDestDatabase

getDestDatabase

setDestSchema

getDestSchema

setDestTable

getDestTable

setErrorLimitCount

getErrorLimitCount

setFallbackOffset

getFallbackOffset

setGroupName

getGroupName

setJobConfig

getJobConfig

setJobDescription

getJobDescription

setJobId

getJobId

setMatchColumns

getMatchColumns

setPassword

getPassword

setRegionId

getRegionId

setSrcColumns

getSrcColumns

setTryRun

getTryRun

setUpdateColumns

getUpdateColumns

setWriteMode

getWriteMode