public interface QueryExecutionListener
Note that implementations should guarantee thread-safety as they can be invoked by multiple different threads.
Modifier and Type | Method and Description |
---|---|
void |
onFailure(java.lang.String funcName,
org.apache.spark.sql.execution.QueryExecution qe,
java.lang.Exception exception)
A callback function that will be called when a query execution failed.
|
void |
onSuccess(java.lang.String funcName,
org.apache.spark.sql.execution.QueryExecution qe,
long durationNs)
A callback function that will be called when a query executed successfully.
|
void onSuccess(java.lang.String funcName, org.apache.spark.sql.execution.QueryExecution qe, long durationNs)
funcName
- name of the action that triggered this query.qe
- the QueryExecution object that carries detail information like logical plan,
physical plan, etc.durationNs
- the execution time for this query in nanoseconds.void onFailure(java.lang.String funcName, org.apache.spark.sql.execution.QueryExecution qe, java.lang.Exception exception)
funcName
- the name of the action that triggered this query.qe
- the QueryExecution object that carries detail information like logical plan,
physical plan, etc.exception
- the exception that failed this query.