Skip to content

[SPARK-26129][SQL] Instrumentation for per-query planning time #23096

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Closed
rxin wants to merge 6 commits into from
Closed

[SPARK-26129][SQL] Instrumentation for per-query planning time #23096

Changes from 1 commit
Commits
Show all changes
6 commits
Select commit Hold shift + click to select a range
b6a3d02
[SPARK-26129][SQL] Instrumentation for query planning time
rxin Nov 20, 2018
b2a2a01
Add parsing
rxin Nov 20, 2018
dd61273
remove merge
rxin Nov 20, 2018
f36a231
thread local
rxin Nov 20, 2018
2cd069c
fix compile
rxin Nov 20, 2018
34f8bfe
fix Hive test cases
rxin Nov 21, 2018
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
remove merge
  • Loading branch information
@rxin
rxin committed Nov 20, 2018
commit dd61273024bf322bfe03f3cd5e06803eaae62d8f
8 changes: 0 additions & 8 deletions sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/QueryPlanningTracker.scala
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -46,14 +46,6 @@ object QueryPlanningTracker {

def this() = this(totalTimeNs = 0, numInvocations = 0, numEffectiveInvocations = 0)

def merge(other: RuleSummary): RuleSummary = {
new RuleSummary(
this.totalTimeNs + other.totalTimeNs,
this.numInvocations + other.numInvocations,
this.numEffectiveInvocations + other.numEffectiveInvocations
)
}

override def toString: String = {
s"RuleSummary($totalTimeNs, $numInvocations, $numEffectiveInvocations)"
}
Expand Down