Iceberg Time Travel Node

Data/DataFusion/Lakes

Iceberg Time Travel

Load a specific snapshot of an Iceberg table for point-in-time queries.

df_iceberg_time_traveldata

Inputs8

Outputs3

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.

2/10High

GovernancePolicy, audit, or compliance impact.

0/10High

ReliabilityOperational stability considerations.

1/10High

CostExternal or compute cost impact.

2/10High

Input Pins

Input

Execution

exec_in

Trigger execution

Session

Struct

session

DataFusion session

Warehouse Path

Struct

warehouse_path

FlowPath to the Iceberg table directory

Metadata File

String

metadata_file

Relative path to metadata JSON file

DataFusion Name

String

table_name

Name to register in DataFusion

Travel Mode

String

travel_mode

Mode: 'snapshot' or 'timestamp'

Default snapshot

Snapshot ID

String

snapshot_id

Snapshot ID (when mode is 'snapshot')

Timestamp

Integer

timestamp_ms

Unix timestamp in milliseconds (when mode is 'timestamp')

Default 0

Output Pins

Done

Execution

exec_out

Table registered

Session

Struct

session_out

DataFusion session

Loaded Snapshot

String

loaded_snapshot

Actual snapshot ID that was loaded

Node Info

Internal name: df_iceberg_time_travel
Category: Data/DataFusion/Lakes