Reads a CSV stream as a Spark dataframe stream.
stream_read_csv( sc, path, name = NULL, header = TRUE, columns = NULL, delimiter = ",", quote = "\"", escape = "\\", charset = "UTF-8", null_value = NULL, options = list(), ... )
The path to the file. Needs to be accessible from the cluster. Supports the "hdfs://", "s3a://" and "file://" protocols.
The name to assign to the newly generated stream.
Boolean; should the first row of data be used as a header?
A vector of column names or a named vector of column types.
If specified, the elements can be
The character used to delimit each column. Defaults to ','.
The character used as a quote. Defaults to '"'.
The character used to escape other characters. Defaults to '\'.
The character set. Defaults to "UTF-8".
The character to use for null, or missing, values. Defaults to
A list of strings with additional options.
Optional arguments; currently unused.
Other Spark stream serialization: