StreamingExecutionRelation is a leaf logical operator (i.e.
LogicalPlan) that represents a streaming source in the logical query plan of a streaming
The main use of
StreamingExecutionRelation logical operator is to be a "placeholder" in a logical query plan that will be replaced with the real relation (with new data that has arrived since the last batch) or an empty
StreamExecution runs a single streaming batch.
StreamingExecutionRelation takes the following when created:
apply(source: Source): StreamingExecutionRelation
apply creates a
StreamingExecutionRelation for the input
source and with the attributes of the schema of the