Skip to content

Write Delta Table Node

Data/DataFusion/Lakes

Write Delta Table

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

df_write_deltadata
Inputs6
Outputs4
Security exposure3/10
Packagedata

Ratings

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

SecurityAttack surface and exposure impact.
3/10High
PrivacyPotential sensitivity of processed data.
3/10High
PerformanceRuntime or resource pressure.
2/10High
GovernancePolicy, audit, or compliance impact.
1/10High
ReliabilityOperational stability considerations.
1/10High
CostExternal or compute cost impact.
2/10High

Input Pins

6

Input

Execution
exec_in

Trigger execution

Session

Struct
session

DataFusion session

DataFusionSessionDataFusionSession1 fields
cache_keystringrequired

Query

String
query

SQL query to execute

Path

Struct
path

FlowPath for the Delta table directory

FlowPathFlowPath3 fields
pathstringrequired
store_refstringrequired
cache_store_refstring | null

Mode

String
mode

Write mode: append, overwrite, error, ignore

Default append

Partition By

String
partition_by

Columns to partition by (comma-separated)

Output Pins

4

Done

Execution
exec_out

Write completed

Session

Struct
session_out

DataFusion session

DataFusionSessionDataFusionSession1 fields
cache_keystringrequired

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