public static class StreamingQueryListener.QueryTerminatedEvent extends Object implements StreamingQueryListener.Event, scala.Serializable
param: id A unique query id that persists across restarts. See StreamingQuery.id()
.
param: runId A query id that is unique for every start/restart. See StreamingQuery.runId()
.
param: exception The exception message of the query if the query was terminated
with an exception. Otherwise, it will be None
.
param: errorClassOnException The error class from the exception if the query was terminated
with an exception which is a part of error class framework.
If the query was terminated without an exception, or the
exception is not a part of error class framework, it will be
None
.
Constructor and Description |
---|
QueryTerminatedEvent(java.util.UUID id,
java.util.UUID runId,
scala.Option<String> exception) |
Modifier and Type | Method and Description |
---|---|
scala.Option<String> |
errorClassOnException() |
scala.Option<String> |
exception() |
java.util.UUID |
id() |
String |
json() |
java.util.UUID |
runId() |
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
logEvent