Write Delta Table Node

Data/DataFusion/Lakes

Write query results to a new or existing Delta Lake table using FlowPath. Supports append, overwrite modes.

df_write_deltadata

Inputs7

Outputs4

Security exposure7/10

Packagedata

Ratings

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

SecurityAttack surface and exposure impact.

7/10High

PrivacyPotential sensitivity of processed data.

7/10High

PerformanceRuntime or resource pressure.

8/10High

GovernancePolicy, audit, or compliance impact.

9/10High

ReliabilityOperational stability considerations.

9/10High

CostExternal or compute cost impact.

8/10High

Input Pins

Input

Execution

exec_in

Trigger execution

Session

Struct

session

DataFusion session

Query

String

query

SQL query to execute. Use $placeholders for values that come from the flow (SELECT * FROM events WHERE day = $day) — each one adds an input pin to wire the value into. Placeholders stand for values only; table and column names cannot be parameterized.

Params

Struct

params

Values for the query's $placeholders, as an object keyed by placeholder name without the $ (e.g. {"customer_id": 42}). Only needed when the query itself comes from a wire — a literal query derives one pin per placeholder instead. Where both supply the same name, the derived pin wins unless it is empty.

Default {}

Path

Struct

path

FlowPath for the Delta table directory

Mode

String

mode

Write mode: append, overwrite, error, ignore

Default append

Partition By

String

partition_by

Columns to partition by (comma-separated)

Output Pins

Done

Execution

exec_out

Write completed

Session

Struct

session_out

DataFusion session

Rows Written

Integer

rows_written

Number of rows written

New Version

Integer

new_version

Version number after write

Node Info

Internal name: df_write_delta
Category: Data/DataFusion/Lakes