Loads a text file stream and returns a DataFrame whose schema starts with a
string column named “value”, and followed by partitioned columns if there
The text files must be encoded as UTF-8.
By default, each line in the text file is a new row in the resulting DataFrame.
New in version 2.0.0.
string, or list of strings, for input path(s).
For the extra options, refer to
Data Source Option
in the version you use.
This API is evolving.
>>> text_sdf = spark.readStream.text(tempfile.mkdtemp())
>>> "value" in str(text_sdf.schema)