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).

results matching ""

    No results matching ""