Skip to content

Commit 1d87cb3

Browse files
committed
refactor: renamed query trigger start event to query execution start event
1 parent bd4bb4b commit 1d87cb3

2 files changed

Lines changed: 3 additions & 0 deletions

File tree

sql/catalyst/src/main/scala/org/apache/spark/sql/internal/SQLConf.scala

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -6756,6 +6756,7 @@ object SQLConf {
67566756
.booleanConf
67576757
.createWithDefault(Utils.isTesting)
67586758

6759+
val STREAMING_QUERY_EXECUTION_START_EVENT_ENABLED =
67596760
val STREAMING_QUERY_EXECUTION_START_EVENT_ENABLED =
67606761
buildConf("spark.sql.streaming.query.trigger.start.event.enabled")
67616762
.internal()

sql/core/src/test/scala/org/apache/spark/sql/streaming/StreamingQueryListenerSuite.scala

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -962,6 +962,8 @@ class StreamingQueryListenerSuite extends StreamTest with BeforeAndAfter {
962962

963963
override def onQueryProgress(event: QueryProgressEvent): Unit = handleOnQueryProgress(event)
964964

965+
override def onQueryExecutionStart(event: QueryExecutionStartEvent): Unit = handleOnQueryExecutionStart(event)
966+
965967
override def onQueryIdle(event: QueryIdleEvent): Unit = handleOnQueryIdle(event)
966968

967969
override def onQueryTerminated(event: QueryTerminatedEvent): Unit =

0 commit comments

Comments
 (0)