StreamingQueryWrapper — Serializable StreamExecution
StreamingQueryWrapper
is a serializable interface of a StreamExecution.
StreamingQueryWrapper
has the same StreamExecution API and simply passes all the method calls along to the underlying StreamExecution.
StreamingQueryWrapper
takes a single StreamExecution when created.
StreamingQueryWrapper
is created when StreamingQueryManager
is requested to create a streaming query (when DataStreamWriter
is requested to start an execution of the streaming query).