OracleSource Class

public final class OracleSource
extends CopySource

A copy activity Oracle source.

Constructor Summary

Constructor Description
OracleSource()

Creates an instance of OracleSource class.

Method Summary

Modifier and Type Method and Description
Object additionalColumns()

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

static OracleSource fromJson(JsonReader jsonReader)

Reads an instance of OracleSource from the JsonReader.

Object oracleReaderQuery()

Get the oracleReaderQuery property: Oracle reader query.

Object partitionOption()

Get the partitionOption property: The partition mechanism that will be used for Oracle read in parallel.

OraclePartitionSettings partitionSettings()

Get the partitionSettings property: The settings that will be leveraged for Oracle source partitioning.

Object queryTimeout()

Get the queryTimeout property: Query timeout.

JsonWriter toJson(JsonWriter jsonWriter)
String type()

Get the type property: Copy source type.

void validate()

Validates the instance.

OracleSource withAdditionalColumns(Object additionalColumns)

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

OracleSource withDisableMetricsCollection(Object disableMetricsCollection)

Set the disableMetricsCollection property: If true, disable data store metrics collection.

OracleSource withMaxConcurrentConnections(Object maxConcurrentConnections)

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

OracleSource withOracleReaderQuery(Object oracleReaderQuery)

Set the oracleReaderQuery property: Oracle reader query.

OracleSource withPartitionOption(Object partitionOption)

Set the partitionOption property: The partition mechanism that will be used for Oracle read in parallel.

OracleSource withPartitionSettings(OraclePartitionSettings partitionSettings)

Set the partitionSettings property: The settings that will be leveraged for Oracle source partitioning.

OracleSource withQueryTimeout(Object queryTimeout)

Set the queryTimeout property: Query timeout.

OracleSource withSourceRetryCount(Object sourceRetryCount)

Set the sourceRetryCount property: Source retry count.

OracleSource withSourceRetryWait(Object sourceRetryWait)

Set the sourceRetryWait property: Source retry wait.

Methods inherited from CopySource

Methods inherited from java.lang.Object

Constructor Details

OracleSource

public OracleSource()

Creates an instance of OracleSource class.

Method Details

additionalColumns

public Object additionalColumns()

Get 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).

Returns:

the additionalColumns value.

fromJson

public static OracleSource fromJson(JsonReader jsonReader)

Reads an instance of OracleSource from the JsonReader.

Parameters:

jsonReader - The JsonReader being read.

Returns:

An instance of OracleSource 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 OracleSource.

oracleReaderQuery

public Object oracleReaderQuery()

Get the oracleReaderQuery property: Oracle reader query. Type: string (or Expression with resultType string).

Returns:

the oracleReaderQuery value.

partitionOption

public Object partitionOption()

Get the partitionOption property: The partition mechanism that will be used for Oracle read in parallel. Possible values include: "None", "PhysicalPartitionsOfTable", "DynamicRange".

Returns:

the partitionOption value.

partitionSettings

public OraclePartitionSettings partitionSettings()

Get the partitionSettings property: The settings that will be leveraged for Oracle source partitioning.

Returns:

the partitionSettings value.

queryTimeout

public Object queryTimeout()

Get 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])).

Returns:

the queryTimeout value.

toJson

public JsonWriter toJson(JsonWriter jsonWriter)

Overrides:

OracleSource.toJson(JsonWriter jsonWriter)

Parameters:

jsonWriter

Throws:

type

public String type()

Get the type property: Copy source type.

Overrides:

OracleSource.type()

Returns:

the type value.

validate

public void validate()

Validates the instance.

Overrides:

OracleSource.validate()

withAdditionalColumns

public OracleSource withAdditionalColumns(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).

Parameters:

additionalColumns - the additionalColumns value to set.

Returns:

the OracleSource object itself.

withDisableMetricsCollection

public OracleSource withDisableMetricsCollection(Object disableMetricsCollection)

Set the disableMetricsCollection property: If true, disable data store metrics collection. Default is false. Type: boolean (or Expression with resultType boolean).

Overrides:

OracleSource.withDisableMetricsCollection(Object disableMetricsCollection)

Parameters:

disableMetricsCollection

withMaxConcurrentConnections

public OracleSource withMaxConcurrentConnections(Object maxConcurrentConnections)

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

Overrides:

OracleSource.withMaxConcurrentConnections(Object maxConcurrentConnections)

Parameters:

maxConcurrentConnections

withOracleReaderQuery

public OracleSource withOracleReaderQuery(Object oracleReaderQuery)

Set the oracleReaderQuery property: Oracle reader query. Type: string (or Expression with resultType string).

Parameters:

oracleReaderQuery - the oracleReaderQuery value to set.

Returns:

the OracleSource object itself.

withPartitionOption

public OracleSource withPartitionOption(Object partitionOption)

Set the partitionOption property: The partition mechanism that will be used for Oracle read in parallel. Possible values include: "None", "PhysicalPartitionsOfTable", "DynamicRange".

Parameters:

partitionOption - the partitionOption value to set.

Returns:

the OracleSource object itself.

withPartitionSettings

public OracleSource withPartitionSettings(OraclePartitionSettings partitionSettings)

Set the partitionSettings property: The settings that will be leveraged for Oracle source partitioning.

Parameters:

partitionSettings - the partitionSettings value to set.

Returns:

the OracleSource object itself.

withQueryTimeout

public OracleSource withQueryTimeout(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])).

Parameters:

queryTimeout - the queryTimeout value to set.

Returns:

the OracleSource object itself.

withSourceRetryCount

public OracleSource withSourceRetryCount(Object sourceRetryCount)

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

Overrides:

OracleSource.withSourceRetryCount(Object sourceRetryCount)

Parameters:

sourceRetryCount

withSourceRetryWait

public OracleSource withSourceRetryWait(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:

OracleSource.withSourceRetryWait(Object sourceRetryWait)

Parameters:

sourceRetryWait

Applies to