Github user rxin commented on a diff in the pull request:
    --- Diff: 
    @@ -41,24 +41,24 @@ abstract class StreamingQueryListener {
        *       don't block this method as it will block your query.
        * @since 2.0.0
    -  def onQueryStarted(queryStarted: QueryStarted): Unit
    +  def onQueryStarted(queryStarted: QueryStartedEvent): Unit
        * Called when there is some status update (ingestion rate updated, etc.)
        * @note This method is asynchronous. The status in [[StreamingQuery]] 
will always be
        *       latest no matter when this method is called. Therefore, the 
status of [[StreamingQuery]]
        *       may be changed before/when you process the event. E.g., you may 
find [[StreamingQuery]]
    -   *       is terminated when you are processing [[QueryProgress]].
    +   *       is terminated when you are processing [[QueryProgressEvent]].
        * @since 2.0.0
    -  def onQueryProgress(queryProgress: QueryProgress): Unit
    +  def onQueryProgress(queryProgress: QueryProgressEvent): Unit
    --- End diff --
    sry i was referring to just renaming all the arguments to event... but now 
i look at it QueryProgressEvent also sound good!

If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at or file a JIRA ticket
with INFRA.

To unsubscribe, e-mail:
For additional commands, e-mail:

Reply via email to