Modeling Guide

Oracle SQL Consumer

The Oracle SQL 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.

Native SQL

string

SQL statement which will be used to read from the source. The syntax depends on the underlying source.

Partition Type

string

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 SQL".

Default: None

Logical Partition Specification object See demo graph documentation "Ingest Oracle via SQL".
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

inSQL

string

SQL statement which will be used to read from the source. The syntax depends on the underlying source.

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.