This is an automated email from the ASF dual-hosted git repository.
hvanhovell pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/spark.git.
from 075ae1e [SPARK-29537][SQL] throw exception when user defined a wrong
base path
add d7b268a [SPARK-29348][SQL] Add observable Metrics for Streaming
queries
No new revisions were added by this update.
Summary of changes:
project/MimaExcludes.scala | 5 +-
.../spark/sql/catalyst/analysis/Analyzer.scala | 10 +++
.../sql/catalyst/analysis/CheckAnalysis.scala | 71 +++++++++++++++-
.../sql/catalyst/plans/logical/PlanHelper.scala | 4 +-
.../plans/logical/basicLogicalOperators.scala | 22 +++++
.../org/apache/spark/sql/internal/SQLConf.scala | 7 +-
.../org/apache/spark/sql/types/DataType.scala | 35 ++++++++
.../sql/catalyst/analysis/AnalysisSuite.scala | 87 +++++++++++++++++++-
.../main/scala/org/apache/spark/sql/Dataset.scala | 48 +++++++++++
.../sql/execution/AggregatingAccumulator.scala | 15 +++-
.../spark/sql/execution/CollectMetricsExec.scala | 95 ++++++++++++++++++++++
.../spark/sql/execution/QueryExecution.scala | 5 +-
.../spark/sql/execution/SparkStrategies.scala | 2 +
.../sql/execution/streaming/ProgressReporter.scala | 16 +++-
.../org/apache/spark/sql/streaming/progress.scala | 10 ++-
.../execution/AggregatingAccumulatorSuite.scala | 9 +-
.../streaming/StreamingQueryListenerSuite.scala | 63 +++++++++++++-
.../StreamingQueryStatusAndProgressSuite.scala | 52 +++++++++++-
.../spark/sql/util/DataFrameCallbackSuite.scala | 50 +++++++++++-
19 files changed, 586 insertions(+), 20 deletions(-)
create mode 100644
sql/core/src/main/scala/org/apache/spark/sql/execution/CollectMetricsExec.scala
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
