-
Notifications
You must be signed in to change notification settings - Fork 1
/
Copy pathmetadata.json.template
23 lines (23 loc) · 2.61 KB
/
metadata.json.template
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
{
"databases": {
"APP" : {
"queries" : {
"plan-metrics" : {
"sql" : "select * from (select accumulables.plan_node, accumulables.accumulatorId, nodeName, case metricType when 'nsTiming' then 'timing' else metricType end as metricType, name, case metricType when 'nsTiming' then sum([Metric Value] / 1000000) else sum([Metric Value]) end as Value, [Task ID], [Stage ID], [Job ID], simpleString, accumulables.[Application ID] from accumulables join plans on accumulables.plan_node = plans.plan_node join task_metrics on accumulables.accumulatorId = task_metrics.accumulatorId group by accumulables.plan_node, accumulables.accumulatorId)"
},
"plan-metrics-of-type" : {
"sql" : "select * from (select accumulables.plan_node, accumulables.accumulatorId, nodeName, case metricType when 'nsTiming' then 'timing' else metricType end as metricType, name, case metricType when 'nsTiming' then sum([Metric Value] / 1000000) else sum([Metric Value]) end as Value, [Task ID], [Stage ID], [Job ID], simpleString, accumulables.[Application ID] from accumulables join plans on accumulables.plan_node = plans.plan_node join task_metrics on accumulables.accumulatorId = task_metrics.accumulatorId group by accumulables.plan_node, accumulables.accumulatorId) where metricType = :type"
},
"plan-timing-metrics" : {
"sql" : "select * from (select accumulables.plan_node, accumulables.accumulatorId, nodeName, case metricType when 'nsTiming' then 'timing' else metricType end as metricType, name, case metricType when 'nsTiming' then sum([Metric Value] / 1000000) else sum([Metric Value]) end as Value, [Task ID], [Stage ID], [Job ID], simpleString, accumulables.[Application ID] from accumulables join plans on accumulables.plan_node = plans.plan_node join task_metrics on accumulables.accumulatorId = task_metrics.accumulatorId group by accumulables.plan_node, accumulables.accumulatorId) where metricType = 'timing'"
},
"plan-graph" : {
"sql" : "select execution_id, description, plan_node, parent, simpleString from plans join sql_info on plans.execution_id = sql_info.executionId "
},
"byte-stage-metrics": {
"sql": "select rowid, [Stage ID], min([Metric Name]) as [Metric Name], accumulatorId, sum([Metric Value]) as Value, [Application ID], [Application Name], kind, unit, [Job ID] from task_metrics where [Metric Name] like \"%bytes%\" group by [Stage ID], [Metric Name]"
}
}
}
}
}