PostgreSqlV2Source Class

public final class PostgreSqlV2Source
extends TabularSource

A copy activity source for PostgreSQL databases.

Constructor Summary

Constructor Description
PostgreSqlV2Source()

Creates an instance of PostgreSqlV2Source class.

Method Summary

Modifier and Type Method and Description
static PostgreSqlV2Source fromJson(JsonReader jsonReader)

Reads an instance of PostgreSqlV2Source from the JsonReader.

Object getQuery()

Get the query property: Database query.

String getType()

Get the type property: Copy source type.

PostgreSqlV2Source setAdditionalColumns(Object additionalColumns)

Set the additionalColumns property: Specifies the additional columns to be added to source data.

PostgreSqlV2Source setMaxConcurrentConnections(Object maxConcurrentConnections)

Set the maxConcurrentConnections property: The maximum concurrent connection count for the source data store.

PostgreSqlV2Source setQuery(Object query)

Set the query property: Database query.

PostgreSqlV2Source setQueryTimeout(Object queryTimeout)

Set the queryTimeout property: Query timeout.

PostgreSqlV2Source setSourceRetryCount(Object sourceRetryCount)

Set the sourceRetryCount property: Source retry count.

PostgreSqlV2Source setSourceRetryWait(Object sourceRetryWait)

Set the sourceRetryWait property: Source retry wait.

JsonWriter toJson(JsonWriter jsonWriter)

Methods inherited from CopySource

Methods inherited from TabularSource

Methods inherited from java.lang.Object

Constructor Details

PostgreSqlV2Source

public PostgreSqlV2Source()

Creates an instance of PostgreSqlV2Source class.

Method Details

fromJson

public static PostgreSqlV2Source fromJson(JsonReader jsonReader)

Reads an instance of PostgreSqlV2Source from the JsonReader.

Parameters:

jsonReader - The JsonReader being read.

Returns:

An instance of PostgreSqlV2Source if the JsonReader was pointing to an instance of it, or null if it was pointing to JSON null.

Throws:

IOException

- If an error occurs while reading the PostgreSqlV2Source.

getQuery

public Object getQuery()

Get the query property: Database query. Type: string (or Expression with resultType string).

Returns:

the query value.

getType

public String getType()

Get the type property: Copy source type.

Overrides:

PostgreSqlV2Source.getType()

Returns:

the type value.

setAdditionalColumns

public PostgreSqlV2Source setAdditionalColumns(Object additionalColumns)

Set the additionalColumns property: Specifies the additional columns to be added to source data. Type: array of objects(AdditionalColumns) (or Expression with resultType array of objects).

Overrides:

PostgreSqlV2Source.setAdditionalColumns(Object additionalColumns)

Parameters:

additionalColumns

setMaxConcurrentConnections

public PostgreSqlV2Source setMaxConcurrentConnections(Object maxConcurrentConnections)

Set the maxConcurrentConnections property: The maximum concurrent connection count for the source data store. Type: integer (or Expression with resultType integer).

Overrides:

PostgreSqlV2Source.setMaxConcurrentConnections(Object maxConcurrentConnections)

Parameters:

maxConcurrentConnections

setQuery

public PostgreSqlV2Source setQuery(Object query)

Set the query property: Database query. Type: string (or Expression with resultType string).

Parameters:

query - the query value to set.

Returns:

the PostgreSqlV2Source object itself.

setQueryTimeout

public PostgreSqlV2Source setQueryTimeout(Object queryTimeout)

Set the queryTimeout property: Query timeout. Type: string (or Expression with resultType string), pattern: ((\d+)\.)?(\d\d):(60|([0-5][0-9])):(60|([0-5][0-9])).

Overrides:

PostgreSqlV2Source.setQueryTimeout(Object queryTimeout)

Parameters:

queryTimeout

setSourceRetryCount

public PostgreSqlV2Source setSourceRetryCount(Object sourceRetryCount)

Set the sourceRetryCount property: Source retry count. Type: integer (or Expression with resultType integer).

Overrides:

PostgreSqlV2Source.setSourceRetryCount(Object sourceRetryCount)

Parameters:

sourceRetryCount

setSourceRetryWait

public PostgreSqlV2Source setSourceRetryWait(Object sourceRetryWait)

Set the sourceRetryWait property: Source retry wait. Type: string (or Expression with resultType string), pattern: ((\d+)\.)?(\d\d):(60|([0-5][0-9])):(60|([0-5][0-9])).

Overrides:

PostgreSqlV2Source.setSourceRetryWait(Object sourceRetryWait)

Parameters:

sourceRetryWait

toJson

public JsonWriter toJson(JsonWriter jsonWriter)

Overrides:

PostgreSqlV2Source.toJson(JsonWriter jsonWriter)

Parameters:

jsonWriter

Throws:

Applies to