For example, put the generated query into a list and start every one, then
use the method awaitTermination() on the last one .
Abhisheks 于2020年5月1日周五 上午10:32写道:
> I hope you are using the Query object that is returned by the Structured
> streaming, right?
> Returned object contains a lot of inf
I hope you are using the Query object that is returned by the Structured
streaming, right?
Returned object contains a lot of information about each query and tracking
state of the object should be helpful.
Hope this may help, if not can you please share more details with examples?
Best,
A
--