Package org.apache.spark.sql.streaming

Interface PythonStreamingQueryListener

public interface PythonStreamingQueryListener

Py4J allows a pure interface so this proxy is required.

Method Summary

Modifier and Type	Method	Description
void	onQueryIdle(StreamingQueryListener.QueryIdleEvent event)
void	onQueryProgress(StreamingQueryListener.QueryProgressEvent event)
void	onQueryStarted(StreamingQueryListener.QueryStartedEvent event)
void	onQueryTerminated(StreamingQueryListener.QueryTerminatedEvent event)

Method Details

onQueryIdle

void onQueryIdle(StreamingQueryListener.QueryIdleEvent event)

onQueryProgress

void onQueryProgress(StreamingQueryListener.QueryProgressEvent event)

onQueryStarted

void onQueryStarted(StreamingQueryListener.QueryStartedEvent event)

onQueryTerminated

void onQueryTerminated(StreamingQueryListener.QueryTerminatedEvent event)