ModifyStreamingJobShrinkRequest (gpdb20160503 3.0.0 API)

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

public class ModifyStreamingJobShrinkRequest
extends com.aliyun.tea.TeaModel

字段概要

字段
限定符和类型	字段和说明
`String`	`account` The name of the database account.
`String`	`consistency` The delivery guarantee setting.
`String`	`DBInstanceId` The instance ID.
`String`	`destColumnsShrink` 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.
`String`	`matchColumnsShrink`
`String`	`password` The password of the database account.
`String`	`regionId` example: cn-beijing
`String`	`srcColumnsShrink` The source fields.
`Boolean`	`tryRun` Specifies whether to test the real-time job.
`String`	`updateColumnsShrink`
`String`	`writeMode` The write mode.

构造器概要

构造器
构造器和说明

ModifyStreamingJobShrinkRequest()

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

方法概要

所有方法静态方法实例方法具体方法
限定符和类型	方法和说明
`static ModifyStreamingJobShrinkRequest`	`build(Map<String,?> map)`
`String`	`getAccount()`
`String`	`getConsistency()`
`String`	`getDBInstanceId()`
`String`	`getDestColumnsShrink()`
`String`	`getDestDatabase()`
`String`	`getDestSchema()`
`String`	`getDestTable()`
`Long`	`getErrorLimitCount()`
`String`	`getFallbackOffset()`
`String`	`getGroupName()`
`String`	`getJobConfig()`
`String`	`getJobDescription()`
`Long`	`getJobId()`
`String`	`getMatchColumnsShrink()`
`String`	`getPassword()`
`String`	`getRegionId()`
`String`	`getSrcColumnsShrink()`
`Boolean`	`getTryRun()`
`String`	`getUpdateColumnsShrink()`
`String`	`getWriteMode()`
`ModifyStreamingJobShrinkRequest`	`setAccount(String account)`
`ModifyStreamingJobShrinkRequest`	`setConsistency(String consistency)`
`ModifyStreamingJobShrinkRequest`	`setDBInstanceId(String DBInstanceId)`
`ModifyStreamingJobShrinkRequest`	`setDestColumnsShrink(String destColumnsShrink)`
`ModifyStreamingJobShrinkRequest`	`setDestDatabase(String destDatabase)`
`ModifyStreamingJobShrinkRequest`	`setDestSchema(String destSchema)`
`ModifyStreamingJobShrinkRequest`	`setDestTable(String destTable)`
`ModifyStreamingJobShrinkRequest`	`setErrorLimitCount(Long errorLimitCount)`
`ModifyStreamingJobShrinkRequest`	`setFallbackOffset(String fallbackOffset)`
`ModifyStreamingJobShrinkRequest`	`setGroupName(String groupName)`
`ModifyStreamingJobShrinkRequest`	`setJobConfig(String jobConfig)`
`ModifyStreamingJobShrinkRequest`	`setJobDescription(String jobDescription)`
`ModifyStreamingJobShrinkRequest`	`setJobId(Long jobId)`
`ModifyStreamingJobShrinkRequest`	`setMatchColumnsShrink(String matchColumnsShrink)`
`ModifyStreamingJobShrinkRequest`	`setPassword(String password)`
`ModifyStreamingJobShrinkRequest`	`setRegionId(String regionId)`
`ModifyStreamingJobShrinkRequest`	`setSrcColumnsShrink(String srcColumnsShrink)`
`ModifyStreamingJobShrinkRequest`	`setTryRun(Boolean tryRun)`
`ModifyStreamingJobShrinkRequest`	`setUpdateColumnsShrink(String updateColumnsShrink)`
`ModifyStreamingJobShrinkRequest`	`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
  - destColumnsShrink
```
@NameInMap(value="DestColumns")
public String destColumnsShrink
```
    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
  - matchColumnsShrink
```
@NameInMap(value="MatchColumns")
public String matchColumnsShrink
```
  - 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
  - srcColumnsShrink
```
@NameInMap(value="SrcColumns")
public String srcColumnsShrink
```
    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
  - updateColumnsShrink
```
@NameInMap(value="UpdateColumns")
public String updateColumnsShrink
```
  - writeMode
```
@NameInMap(value="WriteMode")
public String writeMode
```
    The write mode.
    
    Valid values:
    - insert
    - update
    - merge
    example:
    INSERT/UPDATE/MERGE
- 构造器详细资料
  - ModifyStreamingJobShrinkRequest
```
public ModifyStreamingJobShrinkRequest()
```
- 方法详细资料
  - build
```
public static ModifyStreamingJobShrinkRequest build(Map<String,?> map)
                                             throws Exception
```
    抛出:
    
    Exception
  - setAccount
```
public ModifyStreamingJobShrinkRequest setAccount(String account)
```
  - getAccount
```
public String getAccount()
```
  - setConsistency
```
public ModifyStreamingJobShrinkRequest setConsistency(String consistency)
```
  - getConsistency
```
public String getConsistency()
```
  - setDBInstanceId
```
public ModifyStreamingJobShrinkRequest setDBInstanceId(String DBInstanceId)
```
  - getDBInstanceId
```
public String getDBInstanceId()
```
  - setDestColumnsShrink
```
public ModifyStreamingJobShrinkRequest setDestColumnsShrink(String destColumnsShrink)
```
  - getDestColumnsShrink
```
public String getDestColumnsShrink()
```
  - setDestDatabase
```
public ModifyStreamingJobShrinkRequest setDestDatabase(String destDatabase)
```
  - getDestDatabase
```
public String getDestDatabase()
```
  - setDestSchema
```
public ModifyStreamingJobShrinkRequest setDestSchema(String destSchema)
```
  - getDestSchema
```
public String getDestSchema()
```
  - setDestTable
```
public ModifyStreamingJobShrinkRequest setDestTable(String destTable)
```
  - getDestTable
```
public String getDestTable()
```
  - setErrorLimitCount
```
public ModifyStreamingJobShrinkRequest setErrorLimitCount(Long errorLimitCount)
```
  - getErrorLimitCount
```
public Long getErrorLimitCount()
```
  - setFallbackOffset
```
public ModifyStreamingJobShrinkRequest setFallbackOffset(String fallbackOffset)
```
  - getFallbackOffset
```
public String getFallbackOffset()
```
  - setGroupName
```
public ModifyStreamingJobShrinkRequest setGroupName(String groupName)
```
  - getGroupName
```
public String getGroupName()
```
  - setJobConfig
```
public ModifyStreamingJobShrinkRequest setJobConfig(String jobConfig)
```
  - getJobConfig
```
public String getJobConfig()
```
  - setJobDescription
```
public ModifyStreamingJobShrinkRequest setJobDescription(String jobDescription)
```
  - getJobDescription
```
public String getJobDescription()
```
  - setJobId
```
public ModifyStreamingJobShrinkRequest setJobId(Long jobId)
```
  - getJobId
```
public Long getJobId()
```
  - setMatchColumnsShrink
```
public ModifyStreamingJobShrinkRequest setMatchColumnsShrink(String matchColumnsShrink)
```
  - getMatchColumnsShrink
```
public String getMatchColumnsShrink()
```
  - setPassword
```
public ModifyStreamingJobShrinkRequest setPassword(String password)
```
  - getPassword
```
public String getPassword()
```
  - setRegionId
```
public ModifyStreamingJobShrinkRequest setRegionId(String regionId)
```
  - getRegionId
```
public String getRegionId()
```
  - setSrcColumnsShrink
```
public ModifyStreamingJobShrinkRequest setSrcColumnsShrink(String srcColumnsShrink)
```
  - getSrcColumnsShrink
```
public String getSrcColumnsShrink()
```
  - setTryRun
```
public ModifyStreamingJobShrinkRequest setTryRun(Boolean tryRun)
```
  - getTryRun
```
public Boolean getTryRun()
```
  - setUpdateColumnsShrink
```
public ModifyStreamingJobShrinkRequest setUpdateColumnsShrink(String updateColumnsShrink)
```
  - getUpdateColumnsShrink
```
public String getUpdateColumnsShrink()
```
  - setWriteMode
```
public ModifyStreamingJobShrinkRequest setWriteMode(String writeMode)
```
  - getWriteMode
```
public String getWriteMode()
```

类 ModifyStreamingJobShrinkRequest

字段概要

构造器概要

方法概要

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

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

字段详细资料

account

consistency

DBInstanceId

destColumnsShrink

destDatabase

destSchema

destTable

errorLimitCount

fallbackOffset

groupName

jobConfig

jobDescription

jobId

matchColumnsShrink

password

regionId

srcColumnsShrink

tryRun

updateColumnsShrink

writeMode

构造器详细资料

ModifyStreamingJobShrinkRequest

方法详细资料

build

setAccount

getAccount

setConsistency

getConsistency

setDBInstanceId

getDBInstanceId

setDestColumnsShrink

getDestColumnsShrink

setDestDatabase

getDestDatabase

setDestSchema

getDestSchema

setDestTable

getDestTable

setErrorLimitCount

getErrorLimitCount

setFallbackOffset

getFallbackOffset

setGroupName

getGroupName

setJobConfig

getJobConfig

setJobDescription

getJobDescription

setJobId

getJobId

setMatchColumnsShrink

getMatchColumnsShrink

setPassword

getPassword

setRegionId

getRegionId

setSrcColumnsShrink

getSrcColumnsShrink

setTryRun

getTryRun

setUpdateColumnsShrink

getUpdateColumnsShrink

setWriteMode

getWriteMode