Datasource Query (Stream)

Impure

Executes a SQL SELECT query and streams rows one-by-one, invoking the loop body for each row.

Pure Function

No

Execute Inputs

Execution

INPUT

Execution Input.

Execute Outputs

Process Row

OUTPUT

Executes once for every row returned by the query.

Loops

Complete

OUTPUT

Fires when the data is successfully inserted into the cube.

Data Inputs

Datasource

INPUT

Name of the datasource to use.

Query

INPUT

The SELECT query to execute.

Parameters

INPUT

Optional list of parameters to substitute for ? placeholders.

Data Outputs

Row

OUTPUTmap

The current row being streamed from the query result.

Multiple

Index

OUTPUTinteger

The zero-based index of the current row in the result set. Starts at 0 and increments with each row streamed.

Settings

Throw on SQL Error

BOOLEAN

If true, will throw an error if a SQL error occurs during query.

Default: true

Fetch Size

INTEGER

Preferred JDBC fetch size for streaming. -1 for JDBC driver default.

Default: 200

Debug

STRING

Break on node when executing.

Default: No

Options:

NoBeforeInputsBeforeProcessingAfterProcessing