Skip to content

Commit

Permalink
Replace DataFrameWriter.stream() with startStream() in comments.
Browse files Browse the repository at this point in the history
  • Loading branch information
dongjoon-hyun committed Mar 10, 2016
1 parent 8bcad28 commit 70390ae
Showing 1 changed file with 3 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -32,9 +32,9 @@ abstract class ContinuousQueryListener {
/**
* Called when a query is started.
* @note This is called synchronously with
* [[org.apache.spark.sql.DataFrameWriter `DataFrameWriter.stream()`]],
* that is, `onQueryStart` will be called on all listeners before `DataFrameWriter.stream()`
* returns the corresponding [[ContinuousQuery]].
* [[org.apache.spark.sql.DataFrameWriter `DataFrameWriter.startStream()`]],
* that is, `onQueryStart` will be called on all listeners before
* `DataFrameWriter.startStream()` returns the corresponding [[ContinuousQuery]].
*/
def onQueryStarted(queryStarted: QueryStarted)

Expand Down

0 comments on commit 70390ae

Please sign in to comment.