Author: croberts
Date: 2012-12-11 15:14:59 +0000 (Tue, 11 Dec 2012)
New Revision: 5576
Modified:
branches/elephant/cumin/python/cumin/gridhadoop/hadoop.py
Log:
Adding checkboxes to the name node table and giving them a proper id value.
Modified: branches/elephant/cumin/python/cumin/gridhadoop/hadoop.py
===================================================================
--- branches/elephant/cumin/python/cumin/gridhadoop/hadoop.py 2012-12-10 23:04:04 UTC (rev
5575)
+++ branches/elephant/cumin/python/cumin/gridhadoop/hadoop.py 2012-12-11 15:14:59 UTC (rev
5576)
@@ -1,6 +1,6 @@
from operator import itemgetter
-from cumin.objectselector import ObjectSelector, ObjectLinkColumn, ObjectTable,
ObjectTableColumn, ObjectQmfTable
+from cumin.objectselector import ObjectSelector, ObjectLinkColumn, ObjectTable,
ObjectTableColumn, ObjectQmfTable, ObjectQmfSelectorTable
from cumin.objectframe import ObjectFrame, ObjectTaskForm
from cumin.stat import StatSet, StatFlashChart
from cumin.formats import fmt_bytes, fmt_datetime
@@ -120,7 +120,8 @@
class HadoopAdapter(ObjectQmfAdapter):
def __init__(self, app, cls, remoteDataMethod):
super(HadoopAdapter, self).__init__(app, cls)
- self.remoteDataMethod = remoteDataMethod
+ self.remoteDataMethod = remoteDataMethod
+ self.cls = cls
def get_count(self, values):
data = self.do_get_data(values)
@@ -161,9 +162,19 @@
return {}
return namenodes
+
+ def process_record(self, key, record):
+ field_data = list()
+ for column in self.columns:
+ try:
+ val = record[column.name]
+ except KeyError:
+ val = record["ID"]
+ field_data.append(val)
+ return field_data
-class NameNodeTable(ObjectQmfTable):
+class NameNodeTable(ObjectQmfSelectorTable):
def __init__(self, app, name, cls):
super(NameNodeTable, self).__init__(app, name, cls)
Show replies by date