SQL Query Node

S

Data/DataFusion

SQL Query

Execute a SQL query against a DataFusion session. Returns results as both a CSVTable (for analytics) and array of row objects (for iteration).

df_sql_querydata

Inputs3

Outputs4

Security exposure0/10

Packagedata

Ratings

Scores range from 0 to 10. Higher values mean more impact, exposure, or operational weight.

SecurityAttack surface and exposure impact.

0/10High

PrivacyPotential sensitivity of processed data.

0/10High

PerformanceRuntime or resource pressure.

2/10High

GovernancePolicy, audit, or compliance impact.

1/10High

ReliabilityOperational stability considerations.

2/10High

CostExternal or compute cost impact.

0/10High

Input Pins

3

Input

Execution

exec_in

Trigger execution

Session

Struct

session

DataFusion session with registered tables

SchemaDataFusionSessionDataFusionSessionDataFusionSession1 fields

cache_keystringrequired

Query

String

query

SQL query to execute (e.g., SELECT * FROM mytable WHERE column > 10)

Default SELECT * FROM data LIMIT 100

Output Pins

4

Done

Execution

exec_out

Query executed successfully

Table

Struct

table

Query results as a CSVTable (columnar format, good for analytics)

SchemaCSVTableCSVTableCSVTable4 fields

namestring | null

Optional name/identifier for this table

headersArray<string>required

itemsstringarray item

rowsArray<Array<Cell>>required

itemsArray<Cell>array item

itemsCellarray item

variant 1nullvariant

variant 2booleanvariant

variant 3integer:int64variant

format int64

variant 4number:doublevariant

format double

variant 5stringvariant

+1 more fields

sourceanyOf (2)

variant 1FlowPathvariant

pathstringrequired

store_refstringrequired

cache_store_refstring | null

variant 2nullvariant

Rows

Struct Array

rows

Query results as array of row structs with Flow-Like-compatible values

Row Count

Integer

row_count

Number of rows in the result

Node Info

Internal name

df_sql_query

Category

Data/DataFusion

Version

2