public interface QueryExecutionListener
Modifier and Type | Method and Description |
---|---|
void |
onFailure(String funcName,
org.apache.spark.sql.execution.QueryExecution qe,
Exception exception)
A callback function that will be called when a query execution failed.
|
void |
onSuccess(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(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(String funcName, org.apache.spark.sql.execution.QueryExecution qe, 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.