com.aliyun.gpdb20160503.models

类 ListStreamingJobsResponseBody.ListStreamingJobsResponseBodyJobItems

java.lang.Object

com.aliyun.tea.TeaModel

com.aliyun.gpdb20160503.models.ListStreamingJobsResponseBody.ListStreamingJobsResponseBodyJobItems

封闭类:

ListStreamingJobsResponseBody

public static class ListStreamingJobsResponseBody.ListStreamingJobsResponseBodyJobItems
extends com.aliyun.tea.TeaModel

字段概要

字段

限定符和类型	字段和说明
String	account The name of the database account.
String	consistency The delivery guarantee setting.
String	createTime The time when the job was created.
String	dataSourceId The data source ID.
String	dataSourceName The name of the data source.
List<String>	destColumns The mapped fields in the destination table.
String	destDatabase The name of the destination database.
String	destSchema The name of the destination namespace.
String	destTable The name of the destination table.
String	errorMessage The error message returned.
String	fallbackOffset The fallback offset for data consumption.
String	jobDescription The description of the job.
String	jobId The job ID.
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	modifyTime The time when the job was last modified.
String	password The password of the database account.
List<String>	srcColumns The source fields.
String	status The status of the job.
List<String>	updateColumns The columns to be updated if a row of data meets the update condition.
String	writeMode The write mode.

构造器概要

构造器

构造器和说明
ListStreamingJobsResponseBodyJobItems()

方法概要

限定符和类型	方法和说明
static ListStreamingJobsResponseBody.ListStreamingJobsResponseBodyJobItems	build(Map<String,?> map)
String	getAccount()
String	getConsistency()
String	getCreateTime()
String	getDataSourceId()
String	getDataSourceName()
List<String>	getDestColumns()
String	getDestDatabase()
String	getDestSchema()
String	getDestTable()
String	getErrorMessage()
String	getFallbackOffset()
String	getJobDescription()
String	getJobId()
String	getJobName()
List<String>	getMatchColumns()
String	getMode()
String	getModifyTime()
String	getPassword()
List<String>	getSrcColumns()
String	getStatus()
List<String>	getUpdateColumns()
String	getWriteMode()
ListStreamingJobsResponseBody.ListStreamingJobsResponseBodyJobItems	setAccount(String account)
ListStreamingJobsResponseBody.ListStreamingJobsResponseBodyJobItems	setConsistency(String consistency)
ListStreamingJobsResponseBody.ListStreamingJobsResponseBodyJobItems	setCreateTime(String createTime)
ListStreamingJobsResponseBody.ListStreamingJobsResponseBodyJobItems	setDataSourceId(String dataSourceId)
ListStreamingJobsResponseBody.ListStreamingJobsResponseBodyJobItems	setDataSourceName(String dataSourceName)
ListStreamingJobsResponseBody.ListStreamingJobsResponseBodyJobItems	setDestColumns(List<String> destColumns)
ListStreamingJobsResponseBody.ListStreamingJobsResponseBodyJobItems	setDestDatabase(String destDatabase)
ListStreamingJobsResponseBody.ListStreamingJobsResponseBodyJobItems	setDestSchema(String destSchema)
ListStreamingJobsResponseBody.ListStreamingJobsResponseBodyJobItems	setDestTable(String destTable)
ListStreamingJobsResponseBody.ListStreamingJobsResponseBodyJobItems	setErrorMessage(String errorMessage)
ListStreamingJobsResponseBody.ListStreamingJobsResponseBodyJobItems	setFallbackOffset(String fallbackOffset)
ListStreamingJobsResponseBody.ListStreamingJobsResponseBodyJobItems	setJobDescription(String jobDescription)
ListStreamingJobsResponseBody.ListStreamingJobsResponseBodyJobItems	setJobId(String jobId)
ListStreamingJobsResponseBody.ListStreamingJobsResponseBodyJobItems	setJobName(String jobName)
ListStreamingJobsResponseBody.ListStreamingJobsResponseBodyJobItems	setMatchColumns(List<String> matchColumns)
ListStreamingJobsResponseBody.ListStreamingJobsResponseBodyJobItems	setMode(String mode)
ListStreamingJobsResponseBody.ListStreamingJobsResponseBodyJobItems	setModifyTime(String modifyTime)
ListStreamingJobsResponseBody.ListStreamingJobsResponseBodyJobItems	setPassword(String password)
ListStreamingJobsResponseBody.ListStreamingJobsResponseBodyJobItems	setSrcColumns(List<String> srcColumns)
ListStreamingJobsResponseBody.ListStreamingJobsResponseBodyJobItems	setStatus(String status)
ListStreamingJobsResponseBody.ListStreamingJobsResponseBodyJobItems	setUpdateColumns(List<String> updateColumns)
ListStreamingJobsResponseBody.ListStreamingJobsResponseBodyJobItems	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.

example:

ATLEAST / EXACTLY

createTime

@NameInMap(value="CreateTime")
public String createTime

The time when the job was created.

example:

2019-09-08T16:00:00Z

dataSourceId

@NameInMap(value="DataSourceId")
public String dataSourceId

The data source ID.

example:

58

dataSourceName

@NameInMap(value="DataSourceName")
public String dataSourceName

The name of the data source.

example:

test-kafka

destColumns

@NameInMap(value="DestColumns")
public List<String> destColumns

The mapped fields in the destination table.

destDatabase

@NameInMap(value="DestDatabase")
public String destDatabase

The name of the destination database.

example:

dest-db

destSchema

@NameInMap(value="DestSchema")
public String destSchema

The name of the destination namespace.

example:

dest-schema

destTable

@NameInMap(value="DestTable")
public String destTable

The name of the destination table.

example:

dest-table

errorMessage

@NameInMap(value="ErrorMessage")
public String errorMessage

The error message returned.

This parameter is returned only when the return value of Status is false.

example:

""

fallbackOffset

@NameInMap(value="FallbackOffset")
public String fallbackOffset

The fallback offset for data consumption.

• This parameter indicates the starting offset from which data consumption resumes when a consumer does not request a consumption offset or requests a consumption offset that is beyond the range of the offset information recorded in the current Kafka cluster. Valid values: EARLIEST and LATEST.

example:

EARLIEST / LATEST

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

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

modifyTime

@NameInMap(value="ModifyTime")
public String modifyTime

The time when the job was last modified.

example:

2019-09-08T17:00:00Z

password

@NameInMap(value="Password")
public String password

The password of the database account.

example:

pwd123

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
• Running
• Exception
• Paused

example:

Running

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.

example:

INSERT/UPDATE/MERGE

构造器详细资料

ListStreamingJobsResponseBodyJobItems

public ListStreamingJobsResponseBodyJobItems()

方法详细资料

build

public static ListStreamingJobsResponseBody.ListStreamingJobsResponseBodyJobItems build(Map<String,?> map)
                                                                                 throws Exception

抛出:

Exception

setAccount

public ListStreamingJobsResponseBody.ListStreamingJobsResponseBodyJobItems setAccount(String account)

getAccount

public String getAccount()

setConsistency

public ListStreamingJobsResponseBody.ListStreamingJobsResponseBodyJobItems setConsistency(String consistency)

getConsistency

public String getConsistency()

setCreateTime

public ListStreamingJobsResponseBody.ListStreamingJobsResponseBodyJobItems setCreateTime(String createTime)

getCreateTime

public String getCreateTime()

setDataSourceId

public ListStreamingJobsResponseBody.ListStreamingJobsResponseBodyJobItems setDataSourceId(String dataSourceId)

getDataSourceId

public String getDataSourceId()

setDataSourceName

public ListStreamingJobsResponseBody.ListStreamingJobsResponseBodyJobItems setDataSourceName(String dataSourceName)

getDataSourceName

public String getDataSourceName()

setDestColumns

public ListStreamingJobsResponseBody.ListStreamingJobsResponseBodyJobItems setDestColumns(List<String> destColumns)

getDestColumns

public List<String> getDestColumns()

setDestDatabase

public ListStreamingJobsResponseBody.ListStreamingJobsResponseBodyJobItems setDestDatabase(String destDatabase)

getDestDatabase

public String getDestDatabase()

setDestSchema

public ListStreamingJobsResponseBody.ListStreamingJobsResponseBodyJobItems setDestSchema(String destSchema)

getDestSchema

public String getDestSchema()

setDestTable

public ListStreamingJobsResponseBody.ListStreamingJobsResponseBodyJobItems setDestTable(String destTable)

getDestTable

public String getDestTable()

setErrorMessage

public ListStreamingJobsResponseBody.ListStreamingJobsResponseBodyJobItems setErrorMessage(String errorMessage)

getErrorMessage

public String getErrorMessage()

setFallbackOffset

public ListStreamingJobsResponseBody.ListStreamingJobsResponseBodyJobItems setFallbackOffset(String fallbackOffset)

getFallbackOffset

public String getFallbackOffset()

setJobDescription

public ListStreamingJobsResponseBody.ListStreamingJobsResponseBodyJobItems setJobDescription(String jobDescription)

getJobDescription

public String getJobDescription()

setJobId

public ListStreamingJobsResponseBody.ListStreamingJobsResponseBodyJobItems setJobId(String jobId)

getJobId

public String getJobId()

setJobName

public ListStreamingJobsResponseBody.ListStreamingJobsResponseBodyJobItems setJobName(String jobName)

getJobName

public String getJobName()

setMatchColumns

public ListStreamingJobsResponseBody.ListStreamingJobsResponseBodyJobItems setMatchColumns(List<String> matchColumns)

getMatchColumns

public List<String> getMatchColumns()

setMode

public ListStreamingJobsResponseBody.ListStreamingJobsResponseBodyJobItems setMode(String mode)

getMode

public String getMode()

setModifyTime

public ListStreamingJobsResponseBody.ListStreamingJobsResponseBodyJobItems setModifyTime(String modifyTime)

getModifyTime

public String getModifyTime()

setPassword

public ListStreamingJobsResponseBody.ListStreamingJobsResponseBodyJobItems setPassword(String password)

getPassword

public String getPassword()

setSrcColumns

public ListStreamingJobsResponseBody.ListStreamingJobsResponseBodyJobItems setSrcColumns(List<String> srcColumns)

getSrcColumns

public List<String> getSrcColumns()

setStatus

public ListStreamingJobsResponseBody.ListStreamingJobsResponseBodyJobItems setStatus(String status)

getStatus

public String getStatus()

setUpdateColumns

public ListStreamingJobsResponseBody.ListStreamingJobsResponseBodyJobItems setUpdateColumns(List<String> updateColumns)

getUpdateColumns

public List<String> getUpdateColumns()

setWriteMode

public ListStreamingJobsResponseBody.ListStreamingJobsResponseBodyJobItems setWriteMode(String writeMode)

getWriteMode

public String getWriteMode()