CreateStreamingJobRequest (gpdb20160503 3.0.0 API)

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

public class CreateStreamingJobRequest
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.
`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` 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.
`List<String>`	`matchColumns` 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
`List<String>`	`srcColumns` The source fields.
`Boolean`	`tryRun` Specifies whether to test the real-time job.
`List<String>`	`updateColumns` The columns to be updated if a row of data meets the update condition.
`String`	`writeMode` The write mode.

构造器概要

构造器
构造器和说明

CreateStreamingJobRequest()

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

方法概要

所有方法静态方法实例方法具体方法
限定符和类型	方法和说明
`static CreateStreamingJobRequest`	`build(Map<String,?> map)`
`String`	`getAccount()`
`String`	`getConsistency()`
`String`	`getDataSourceId()`
`String`	`getDBInstanceId()`
`List<String>`	`getDestColumns()`
`String`	`getDestDatabase()`
`String`	`getDestSchema()`
`String`	`getDestTable()`
`Long`	`getErrorLimitCount()`
`String`	`getFallbackOffset()`
`String`	`getGroupName()`
`String`	`getJobConfig()`
`String`	`getJobDescription()`
`String`	`getJobName()`
`List<String>`	`getMatchColumns()`
`String`	`getMode()`
`String`	`getPassword()`
`String`	`getRegionId()`
`List<String>`	`getSrcColumns()`
`Boolean`	`getTryRun()`
`List<String>`	`getUpdateColumns()`
`String`	`getWriteMode()`
`CreateStreamingJobRequest`	`setAccount(String account)`
`CreateStreamingJobRequest`	`setConsistency(String consistency)`
`CreateStreamingJobRequest`	`setDataSourceId(String dataSourceId)`
`CreateStreamingJobRequest`	`setDBInstanceId(String DBInstanceId)`
`CreateStreamingJobRequest`	`setDestColumns(List<String> destColumns)`
`CreateStreamingJobRequest`	`setDestDatabase(String destDatabase)`
`CreateStreamingJobRequest`	`setDestSchema(String destSchema)`
`CreateStreamingJobRequest`	`setDestTable(String destTable)`
`CreateStreamingJobRequest`	`setErrorLimitCount(Long errorLimitCount)`
`CreateStreamingJobRequest`	`setFallbackOffset(String fallbackOffset)`
`CreateStreamingJobRequest`	`setGroupName(String groupName)`
`CreateStreamingJobRequest`	`setJobConfig(String jobConfig)`
`CreateStreamingJobRequest`	`setJobDescription(String jobDescription)`
`CreateStreamingJobRequest`	`setJobName(String jobName)`
`CreateStreamingJobRequest`	`setMatchColumns(List<String> matchColumns)`
`CreateStreamingJobRequest`	`setMode(String mode)`
`CreateStreamingJobRequest`	`setPassword(String password)`
`CreateStreamingJobRequest`	`setRegionId(String regionId)`
`CreateStreamingJobRequest`	`setSrcColumns(List<String> srcColumns)`
`CreateStreamingJobRequest`	`setTryRun(Boolean tryRun)`
`CreateStreamingJobRequest`	`setUpdateColumns(List<String> updateColumns)`
`CreateStreamingJobRequest`	`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
  - 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
```
    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
  - matchColumns
```
@NameInMap(value="MatchColumns")
public List<String> matchColumns
```
    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
  - 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
```
    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
- 构造器详细资料
  - CreateStreamingJobRequest
```
public CreateStreamingJobRequest()
```
- 方法详细资料
  - build
```
public static CreateStreamingJobRequest build(Map<String,?> map)
                                       throws Exception
```
    抛出:
    
    Exception
  - setAccount
```
public CreateStreamingJobRequest setAccount(String account)
```
  - getAccount
```
public String getAccount()
```
  - setConsistency
```
public CreateStreamingJobRequest setConsistency(String consistency)
```
  - getConsistency
```
public String getConsistency()
```
  - setDBInstanceId
```
public CreateStreamingJobRequest setDBInstanceId(String DBInstanceId)
```
  - getDBInstanceId
```
public String getDBInstanceId()
```
  - setDataSourceId
```
public CreateStreamingJobRequest setDataSourceId(String dataSourceId)
```
  - getDataSourceId
```
public String getDataSourceId()
```
  - setDestColumns
```
public CreateStreamingJobRequest setDestColumns(List<String> destColumns)
```
  - getDestColumns
```
public List<String> getDestColumns()
```
  - setDestDatabase
```
public CreateStreamingJobRequest setDestDatabase(String destDatabase)
```
  - getDestDatabase
```
public String getDestDatabase()
```
  - setDestSchema
```
public CreateStreamingJobRequest setDestSchema(String destSchema)
```
  - getDestSchema
```
public String getDestSchema()
```
  - setDestTable
```
public CreateStreamingJobRequest setDestTable(String destTable)
```
  - getDestTable
```
public String getDestTable()
```
  - setErrorLimitCount
```
public CreateStreamingJobRequest setErrorLimitCount(Long errorLimitCount)
```
  - getErrorLimitCount
```
public Long getErrorLimitCount()
```
  - setFallbackOffset
```
public CreateStreamingJobRequest setFallbackOffset(String fallbackOffset)
```
  - getFallbackOffset
```
public String getFallbackOffset()
```
  - setGroupName
```
public CreateStreamingJobRequest setGroupName(String groupName)
```
  - getGroupName
```
public String getGroupName()
```
  - setJobConfig
```
public CreateStreamingJobRequest setJobConfig(String jobConfig)
```
  - getJobConfig
```
public String getJobConfig()
```
  - setJobDescription
```
public CreateStreamingJobRequest setJobDescription(String jobDescription)
```
  - getJobDescription
```
public String getJobDescription()
```
  - setJobName
```
public CreateStreamingJobRequest setJobName(String jobName)
```
  - getJobName
```
public String getJobName()
```
  - setMatchColumns
```
public CreateStreamingJobRequest setMatchColumns(List<String> matchColumns)
```
  - getMatchColumns
```
public List<String> getMatchColumns()
```
  - setMode
```
public CreateStreamingJobRequest setMode(String mode)
```
  - getMode
```
public String getMode()
```
  - setPassword
```
public CreateStreamingJobRequest setPassword(String password)
```
  - getPassword
```
public String getPassword()
```
  - setRegionId
```
public CreateStreamingJobRequest setRegionId(String regionId)
```
  - getRegionId
```
public String getRegionId()
```
  - setSrcColumns
```
public CreateStreamingJobRequest setSrcColumns(List<String> srcColumns)
```
  - getSrcColumns
```
public List<String> getSrcColumns()
```
  - setTryRun
```
public CreateStreamingJobRequest setTryRun(Boolean tryRun)
```
  - getTryRun
```
public Boolean getTryRun()
```
  - setUpdateColumns
```
public CreateStreamingJobRequest setUpdateColumns(List<String> updateColumns)
```
  - getUpdateColumns
```
public List<String> getUpdateColumns()
```
  - setWriteMode
```
public CreateStreamingJobRequest setWriteMode(String writeMode)
```
  - getWriteMode
```
public String getWriteMode()
```

类 CreateStreamingJobRequest

字段概要

构造器概要

方法概要

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

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

字段详细资料

account

consistency

DBInstanceId

dataSourceId

destColumns

destDatabase

destSchema

destTable

errorLimitCount

fallbackOffset

groupName

jobConfig

jobDescription

jobName

matchColumns

mode

password

regionId

srcColumns

tryRun

updateColumns

writeMode

构造器详细资料

CreateStreamingJobRequest

方法详细资料

build

setAccount

getAccount

setConsistency

getConsistency

setDBInstanceId

getDBInstanceId

setDataSourceId

getDataSourceId

setDestColumns

getDestColumns

setDestDatabase

getDestDatabase

setDestSchema

getDestSchema

setDestTable

getDestTable

setErrorLimitCount

getErrorLimitCount

setFallbackOffset

getFallbackOffset

setGroupName

getGroupName

setJobConfig

getJobConfig

setJobDescription

getJobDescription

setJobName

getJobName

setMatchColumns

getMatchColumns

setMode

getMode

setPassword

getPassword

setRegionId

getRegionId

setSrcColumns

getSrcColumns

setTryRun

getTryRun

setUpdateColumns

getUpdateColumns

setWriteMode

getWriteMode