Class: HadoopMetrics::TaskTracker
- Inherits:
-
Object
- Object
- HadoopMetrics::TaskTracker
show all
- Includes:
- API
- Defined in:
- lib/hadoop_metrics/task_tracker.rb
Constant Summary
collapse
- NODE_TYPE =
'tt'
- JSON_FILED_VALUES =
%W(TasksInfoJson)
Constants included
from API
API::GCNameMap, API::MegaByte
Instance Attribute Summary
Attributes included from API
#name
Instance Method Summary
collapse
Methods included from API
#gc, #get_jmx, #initialize, #memory, #metrics, #query_jmx, #via_jmx
Dynamic Method Handling
This class handles dynamic methods through the method_missing method
in the class HadoopMetrics::API
Instance Method Details
#info ⇒ Object
10
11
12
|
# File 'lib/hadoop_metrics/task_tracker.rb', line 10
def info
query_jmx('hadoop:service=TaskTracker,name=TaskTrackerInfo', JSON_FILED_VALUES).first
end
|
#mapred(opts = {}) ⇒ Object
20
21
22
23
24
|
# File 'lib/hadoop_metrics/task_tracker.rb', line 20
def mapred(opts = {})
column = get_column(opts)
column = HadoopMetrics.to_snake_case(column) if @snake_case
group_by('mapred', 'tasktracker', column, get_force(opts))
end
|
#shuffle_output(opts = {}) ⇒ Object
14
15
16
17
18
|
# File 'lib/hadoop_metrics/task_tracker.rb', line 14
def shuffle_output(opts = {})
column = get_column(opts)
column = HadoopMetrics.to_snake_case(column) if @snake_case
group_by('mapred', 'shuffleOutput', column, get_force(opts))
end
|