Structured Streaming File Sink¶
It writes the DataFrame to files with Structured Streaming
Input¶
It takes in DataFrame as input
Output¶
It writes the incoming DataFrame to files.
Type¶
transform
Class¶
fire.nodes.structuredstreaming.NodeStructuredStreamingFileSink
Fields¶
Name |
Title |
Description |
|---|---|---|
path |
Path |
Path where to write the files |
outputMode |
Output Mode |
Output Mode for saving to Files |
checkpointLocation |
Checkpoint Location |
Checkpoint Location on HDFS compatible file system for Streaming |
format |
Format |
File Format |
awaitTermination |
Await Termination |
|
triggerIntervalInSeconds |
Trigger Interval In Seconds |
|
partitionBy |
Partition By Columns |
Partition By Columns separated by space (can be empty in which case partitionBy would not be applied) |