Skip to content

Register Iceberg Table Node

Data/DataFusion/Lakes

Register Iceberg Table

Register an Apache Iceberg table in DataFusion from a metadata file. Supports schema evolution and partition pruning.

df_register_icebergdata
Inputs5
Outputs4
Security exposure2/10
Packagedata

Ratings

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

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

Input Pins

5

Input

Execution
exec_in

Trigger execution

Session

Struct
session

DataFusion session

DataFusionSessionDataFusionSession1 fields
cache_keystringrequired

Warehouse Path

Struct
warehouse_path

FlowPath to the Iceberg table metadata directory

FlowPathFlowPath3 fields
pathstringrequired
store_refstringrequired
cache_store_refstring | null

Metadata File

String
metadata_file

Relative path to metadata JSON file (e.g., 'metadata/v1.metadata.json')

DataFusion Name

String
table_name

Name to register in DataFusion

Output Pins

4

Done

Execution
exec_out

Table registered

Session

Struct
session_out

DataFusion session

DataFusionSessionDataFusionSession1 fields
cache_keystringrequired

Current Snapshot

String
current_snapshot

Current snapshot ID

Schema Info

Integer
schema_info

Table schema field count

Node Info

Internal name
df_register_iceberg
Category
Data/DataFusion/Lakes