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)
cumin-developers@lists.fedorahosted.org