DataFramecontains one or more sources that continuously return data as it arrives. A
DataFramethat reads data from a streaming source must be executed as a
DataStreamWriter. Methods that return a single answer, (e.g.,
collect()) will throw an
AnalysisExceptionwhen there is a streaming source present.
This API is evolving.