Input/Output¶
|
Loads a CSV file stream and returns the result as a |
|
Specifies the input data source format. |
|
Loads a JSON file stream and returns the results as a |
|
Loads a data stream from a data source and returns it as a |
|
Adds an input option for the underlying data source. |
|
Adds input options for the underlying data source. |
|
Loads a ORC file stream, returning the result as a |
|
Loads a Parquet file stream, returning the result as a |
|
Specifies the input schema. |
|
Define a Streaming DataFrame on a Table. |
|
Loads a text file stream and returns a |
Sets the output of the streaming query to be processed using the provided writer |
|
Sets the output of the streaming query to be processed using the provided function. |
|
|
Specifies the underlying output data source. |
|
Adds an output option for the underlying data source. |
|
Adds output options for the underlying data source. |
|
Specifies how data of a streaming DataFrame/Dataset is written to a streaming sink. |
|
Partitions the output by the given columns on the file system. |
|
Specifies the name of the |
|
Streams the contents of the |
|
Starts the execution of the streaming query, which will continually output results to the given table as new data arrives. |
|
Set the trigger for the stream query. |