CreateStreamingJobShrinkRequest (gpdb20160503 3.0.0 API)

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

public class CreateStreamingJobShrinkRequest
extends com.aliyun.tea.TeaModel

字段概要

字段
限定符和类型	字段和说明
`String`	`account` The name of the database account.
`String`	`consistency` The delivery guarantee setting.
`String`	`dataSourceId` The data source ID.
`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` The number of allowed error rows.
`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.
`String`	`jobName` The name of the job.
`String`	`matchColumnsShrink` The update condition columns that are used to join the source data and the destination table.
`String`	`mode` The configuration mode.
`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` The columns to be updated if a row of data meets the update condition.
`String`	`writeMode` The write mode.

构造器概要

构造器
构造器和说明

CreateStreamingJobShrinkRequest()

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

方法概要

所有方法静态方法实例方法具体方法
限定符和类型	方法和说明
`static CreateStreamingJobShrinkRequest`	`build(Map<String,?> map)`
`String`	`getAccount()`
`String`	`getConsistency()`
`String`	`getDataSourceId()`
`String`	`getDBInstanceId()`
`String`	`getDestColumnsShrink()`
`String`	`getDestDatabase()`
`String`	`getDestSchema()`
`String`	`getDestTable()`
`Long`	`getErrorLimitCount()`
`String`	`getFallbackOffset()`
`String`	`getGroupName()`
`String`	`getJobConfig()`
`String`	`getJobDescription()`
`String`	`getJobName()`
`String`	`getMatchColumnsShrink()`
`String`	`getMode()`
`String`	`getPassword()`
`String`	`getRegionId()`
`String`	`getSrcColumnsShrink()`
`Boolean`	`getTryRun()`
`String`	`getUpdateColumnsShrink()`
`String`	`getWriteMode()`
`CreateStreamingJobShrinkRequest`	`setAccount(String account)`
`CreateStreamingJobShrinkRequest`	`setConsistency(String consistency)`
`CreateStreamingJobShrinkRequest`	`setDataSourceId(String dataSourceId)`
`CreateStreamingJobShrinkRequest`	`setDBInstanceId(String DBInstanceId)`
`CreateStreamingJobShrinkRequest`	`setDestColumnsShrink(String destColumnsShrink)`
`CreateStreamingJobShrinkRequest`	`setDestDatabase(String destDatabase)`
`CreateStreamingJobShrinkRequest`	`setDestSchema(String destSchema)`
`CreateStreamingJobShrinkRequest`	`setDestTable(String destTable)`
`CreateStreamingJobShrinkRequest`	`setErrorLimitCount(Long errorLimitCount)`
`CreateStreamingJobShrinkRequest`	`setFallbackOffset(String fallbackOffset)`
`CreateStreamingJobShrinkRequest`	`setGroupName(String groupName)`
`CreateStreamingJobShrinkRequest`	`setJobConfig(String jobConfig)`
`CreateStreamingJobShrinkRequest`	`setJobDescription(String jobDescription)`
`CreateStreamingJobShrinkRequest`	`setJobName(String jobName)`
`CreateStreamingJobShrinkRequest`	`setMatchColumnsShrink(String matchColumnsShrink)`
`CreateStreamingJobShrinkRequest`	`setMode(String mode)`
`CreateStreamingJobShrinkRequest`	`setPassword(String password)`
`CreateStreamingJobShrinkRequest`	`setRegionId(String regionId)`
`CreateStreamingJobShrinkRequest`	`setSrcColumnsShrink(String srcColumnsShrink)`
`CreateStreamingJobShrinkRequest`	`setTryRun(Boolean tryRun)`
`CreateStreamingJobShrinkRequest`	`setUpdateColumnsShrink(String updateColumnsShrink)`
`CreateStreamingJobShrinkRequest`	`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:
    gp-bp10g78o9807yv9h3
  - dataSourceId
```
@NameInMap(value="DataSourceId")
public String dataSourceId
```
    The data source ID.
    
    This parameter is required.
    example:
    1
  - 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
```
    The number of allowed error rows. Write failures occur when Kafka data does not match the destination table in AnalyticDB for PostgreSQL. If the specified value is exceeded, the job fails.
    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
  - jobName
```
@NameInMap(value="JobName")
public String jobName
```
    The name of the job.
    
    This parameter is required.
    example:
    test-job
  - matchColumnsShrink
```
@NameInMap(value="MatchColumns")
public String matchColumnsShrink
```
    The update condition columns that are used to join the source data and the destination table. Typically, the columns are all the primary key columns of the destination table. If the values of all columns specified by this parameter in different rows are the same, the rows are considered duplicates.
  - mode
```
@NameInMap(value="Mode")
public String mode
```
    The configuration mode. Valid values:
    1. basic: In basic mode, you must configure the configuration parameters.
    2. professional: In professional mode, you can submit a YAML configuration file.
    example:
    basic / professional
  - 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
```
    The columns to be updated if a row of data meets the update condition. Typically, the columns are all non-primary key columns of the destination table. When the columns specified by the MatchColumns parameter are used as conditions to join the source data and the destination table, data in columns of the UpdateColumns type is updated if data is matched.
  - writeMode
```
@NameInMap(value="WriteMode")
public String writeMode
```
    The write mode.
    
    Valid values:
    - insert
    - update
    - merge
    example:
    insert/update/merge
- 构造器详细资料
  - CreateStreamingJobShrinkRequest
```
public CreateStreamingJobShrinkRequest()
```
- 方法详细资料
  - build
```
public static CreateStreamingJobShrinkRequest build(Map<String,?> map)
                                             throws Exception
```
    抛出:
    
    Exception
  - setAccount
```
public CreateStreamingJobShrinkRequest setAccount(String account)
```
  - getAccount
```
public String getAccount()
```
  - setConsistency
```
public CreateStreamingJobShrinkRequest setConsistency(String consistency)
```
  - getConsistency
```
public String getConsistency()
```
  - setDBInstanceId
```
public CreateStreamingJobShrinkRequest setDBInstanceId(String DBInstanceId)
```
  - getDBInstanceId
```
public String getDBInstanceId()
```
  - setDataSourceId
```
public CreateStreamingJobShrinkRequest setDataSourceId(String dataSourceId)
```
  - getDataSourceId
```
public String getDataSourceId()
```
  - setDestColumnsShrink
```
public CreateStreamingJobShrinkRequest setDestColumnsShrink(String destColumnsShrink)
```
  - getDestColumnsShrink
```
public String getDestColumnsShrink()
```
  - setDestDatabase
```
public CreateStreamingJobShrinkRequest setDestDatabase(String destDatabase)
```
  - getDestDatabase
```
public String getDestDatabase()
```
  - setDestSchema
```
public CreateStreamingJobShrinkRequest setDestSchema(String destSchema)
```
  - getDestSchema
```
public String getDestSchema()
```
  - setDestTable
```
public CreateStreamingJobShrinkRequest setDestTable(String destTable)
```
  - getDestTable
```
public String getDestTable()
```
  - setErrorLimitCount
```
public CreateStreamingJobShrinkRequest setErrorLimitCount(Long errorLimitCount)
```
  - getErrorLimitCount
```
public Long getErrorLimitCount()
```
  - setFallbackOffset
```
public CreateStreamingJobShrinkRequest setFallbackOffset(String fallbackOffset)
```
  - getFallbackOffset
```
public String getFallbackOffset()
```
  - setGroupName
```
public CreateStreamingJobShrinkRequest setGroupName(String groupName)
```
  - getGroupName
```
public String getGroupName()
```
  - setJobConfig
```
public CreateStreamingJobShrinkRequest setJobConfig(String jobConfig)
```
  - getJobConfig
```
public String getJobConfig()
```
  - setJobDescription
```
public CreateStreamingJobShrinkRequest setJobDescription(String jobDescription)
```
  - getJobDescription
```
public String getJobDescription()
```
  - setJobName
```
public CreateStreamingJobShrinkRequest setJobName(String jobName)
```
  - getJobName
```
public String getJobName()
```
  - setMatchColumnsShrink
```
public CreateStreamingJobShrinkRequest setMatchColumnsShrink(String matchColumnsShrink)
```
  - getMatchColumnsShrink
```
public String getMatchColumnsShrink()
```
  - setMode
```
public CreateStreamingJobShrinkRequest setMode(String mode)
```
  - getMode
```
public String getMode()
```
  - setPassword
```
public CreateStreamingJobShrinkRequest setPassword(String password)
```
  - getPassword
```
public String getPassword()
```
  - setRegionId
```
public CreateStreamingJobShrinkRequest setRegionId(String regionId)
```
  - getRegionId
```
public String getRegionId()
```
  - setSrcColumnsShrink
```
public CreateStreamingJobShrinkRequest setSrcColumnsShrink(String srcColumnsShrink)
```
  - getSrcColumnsShrink
```
public String getSrcColumnsShrink()
```
  - setTryRun
```
public CreateStreamingJobShrinkRequest setTryRun(Boolean tryRun)
```
  - getTryRun
```
public Boolean getTryRun()
```
  - setUpdateColumnsShrink
```
public CreateStreamingJobShrinkRequest setUpdateColumnsShrink(String updateColumnsShrink)
```
  - getUpdateColumnsShrink
```
public String getUpdateColumnsShrink()
```
  - setWriteMode
```
public CreateStreamingJobShrinkRequest setWriteMode(String writeMode)
```
  - getWriteMode
```
public String getWriteMode()
```

类 CreateStreamingJobShrinkRequest

字段概要

构造器概要

方法概要

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

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

字段详细资料

account

consistency

DBInstanceId

dataSourceId

destColumnsShrink

destDatabase

destSchema

destTable

errorLimitCount

fallbackOffset

groupName

jobConfig

jobDescription

jobName

matchColumnsShrink

mode

password

regionId

srcColumnsShrink

tryRun

updateColumnsShrink

writeMode

构造器详细资料

CreateStreamingJobShrinkRequest

方法详细资料

build

setAccount

getAccount

setConsistency

getConsistency

setDBInstanceId

getDBInstanceId

setDataSourceId

getDataSourceId

setDestColumnsShrink

getDestColumnsShrink

setDestDatabase

getDestDatabase

setDestSchema

getDestSchema

setDestTable

getDestTable

setErrorLimitCount

getErrorLimitCount

setFallbackOffset

getFallbackOffset

setGroupName

getGroupName

setJobConfig

getJobConfig

setJobDescription

getJobDescription

setJobName

getJobName

setMatchColumnsShrink

getMatchColumnsShrink

setMode

getMode

setPassword

getPassword

setRegionId

getRegionId

setSrcColumnsShrink

getSrcColumnsShrink

setTryRun

getTryRun

setUpdateColumnsShrink

getUpdateColumnsShrink

setWriteMode

getWriteMode