Mount CSV Node

M

Data/DataFusion

Mount CSV files from a FlowPath into a DataFusion session as a queryable table. Listing and schema inference are deferred until a query actually uses the session, so cached queries can skip them entirely.

df_mount_csvdata

Inputs7

Outputs1

Security exposure10/10

Packagedata

Ratings

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

SecurityAttack surface and exposure impact.

10/10High

PrivacyPotential sensitivity of processed data.

10/10High

PerformanceRuntime or resource pressure.

8/10High

GovernancePolicy, audit, or compliance impact.

9/10High

ReliabilityOperational stability considerations.

9/10High

CostExternal or compute cost impact.

10/10High

Input Pins

7

Input

Execution

exec_in

Trigger execution

Session

Struct

session

DataFusion session to mount the table into

SchemaDataFusionSessionDataFusionSessionDataFusionSession1 fields

cache_keystringrequired

Path

Struct

path

FlowPath to CSV files (can be a directory prefix or single file)

SchemaFlowPathFlowPathFlowPath3 fields

pathstringrequired

store_refstringrequired

cache_store_refstring | null

Table Name

String

table_name

Name to register the table as in the DataFusion catalog

Has Header

Boolean

has_header

Whether the CSV files have a header row

Default true

Delimiter

String

delimiter

Column delimiter character

Default ,

File Extension

String

file_extension

File extension filter

Default csv

Output Pins

1

Done

Execution

exec_out

Table mounted successfully

Node Info

Internal name

df_mount_csv

Category

Data/DataFusion