Modeling Guide

Oracle Table Consumer

The Oracle Table Consumer operator is based on system.externalOperator and uses datahub-flowagent for execution.

Configuration Parameters

Parameter

Type

Description

Oracle Connection object The object containing the connection parameters to an Oracle database.
Version (type enum)
Oracle database version.
Default: Oracle 12c
Host (type string)
Oracle host name.
Port (type number)
Oracle port.
Default: 1521
SID or Service Name (type string)
Oracle database name.
User (type string)
Oracle user.
Password (type string)
Oracle password.

Source Table

string

Oracle table name from which the data will be read, usually in <Schema>.<TableName> format.

Partition Type

string

Partition Type can be either Logical (User Defined), Physical (Source Based) or Row ID. Partitioning is used to enable data reading in parallel.

In this case, the producer must be inside a group with multiplicity equal to the number of partitions (only the producer, i.e., Flowagent File Producer). For more information about partitioning, check the documentation presented in the demo graph "Ingest Oracle Table".

Default: None

Logical Partition Specification object See demo graph documentation "Ingest Oracle Table".
Number of partitions number If Partition Type is set to Row ID Partitioning, this field will be visible and it will define the number of partitions which will be generated based on the row ids of the table. For more info, see demo graph documentation "Ingest Oracle Table".
Fetch Size

integer

Indicates the number of rows that will be fetched from the source in each request. For wide tables, smaller values are better. For tables with fewer columns, larger values are better.

Default: 100

Input

Input

Type

Description

inTableName

string

Source table name from which the data will be read, usually in <Schema>.<Tablename> format.

Output

Output

Type

Description

outConfig

string.flowagent.config

Flowagent type port, which only Flowagent producers can consume (i.e., Flowagent File Producer). In order to get the data as string, Flowagent CSV Producer can be used as producer.

outError

string

Operator error. If mapped, the operator error will be sent to the operator this port is mapped to and the graph will remain running. If not mapped, the graph will terminate with the operator error.