MySQL SQL Consumer
MySQL SQL Consumer (com.sap.dh.ds.mysql.sql.consumer) is based on system.externalOperator and uses datahub-flowagent for execution.
Configuration Parameters
|
Parameter |
Type |
Description |
|---|---|---|
| MySQL Connection | object | The object containing the connection parameters to a MySQL database.
|
|
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 MySQL via SQL. Default: None |
| Logical Partition Specification | object | See demo graph documentation Ingest MySQL via SQL. |
| Additional Session Parameters | string | Set session parameters which will affect the connection with the source. |
| 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. |