Author: croberts
Date: 2013-01-02 19:45:26 +0000 (Wed, 02 Jan 2013)
New Revision: 5629
Modified:
branches/elephant/cumin/python/cumin/gridhadoop/datanode.py
branches/elephant/cumin/python/cumin/gridhadoop/jobtracker.py
branches/elephant/cumin/python/cumin/gridhadoop/namenode.py
branches/elephant/cumin/python/cumin/gridhadoop/tasktracker.py
Log:
Now passing "list" of users to the hadoop get* methods. Still need to figure
out if user is an admin, then remove user filter.
Modified: branches/elephant/cumin/python/cumin/gridhadoop/datanode.py
===================================================================
--- branches/elephant/cumin/python/cumin/gridhadoop/datanode.py 2013-01-02 19:07:17 UTC
(rev 5628)
+++ branches/elephant/cumin/python/cumin/gridhadoop/datanode.py 2013-01-02 19:45:26 UTC
(rev 5629)
@@ -13,7 +13,7 @@
class DataNodeAdapter(HadoopAdapter):
def get_sage_results(self, values):
- results = self.app.remote.get_data_node_list()
+ results = self.app.remote.get_data_node_list(owner=["condor",
self.app.user]) #condor is a temporary hack
return results
class DataNodeSelector(ObjectSelector):
Modified: branches/elephant/cumin/python/cumin/gridhadoop/jobtracker.py
===================================================================
--- branches/elephant/cumin/python/cumin/gridhadoop/jobtracker.py 2013-01-02 19:07:17 UTC
(rev 5628)
+++ branches/elephant/cumin/python/cumin/gridhadoop/jobtracker.py 2013-01-02 19:45:26 UTC
(rev 5629)
@@ -13,7 +13,7 @@
class JobTrackerAdapter(HadoopAdapter):
def get_sage_results(self, values):
- results = self.app.remote.get_job_tracker_list()
+ results = self.app.remote.get_job_tracker_list(owner=["condor",
self.app.user]) #condor is a temporary hack
return results
class JobTrackerSelector(ObjectSelector):
@@ -137,9 +137,6 @@
self.binfile = BinFileLoc(app, "binfile")
self.add_field(self.binfile)
- self.count = self.CountField(app, "count")
- self.add_field(self.count)
-
self.hadoophost = HadoopHostField(app, "hadoophost")
self.add_field(self.hadoophost)
@@ -157,13 +154,9 @@
owner = session.app.user
hadoophost = self.hadoophost.get(session)
name_node = self.nameNode.get(session)
- count = self.count.get(session)
+ count = 1
self.task.invoke(session, None, (binfile, owner, hadoophost, name_node,
count))
self.task.exit_with_redirect(session, url)
def render_title(self, session):
- return "Create a job tracker"
-
- class CountField(StringField):
- def render_title(self, session):
- return "Number of job trackers to start"
\ No newline at end of file
+ return "Create a job tracker"
\ No newline at end of file
Modified: branches/elephant/cumin/python/cumin/gridhadoop/namenode.py
===================================================================
--- branches/elephant/cumin/python/cumin/gridhadoop/namenode.py 2013-01-02 19:07:17 UTC
(rev 5628)
+++ branches/elephant/cumin/python/cumin/gridhadoop/namenode.py 2013-01-02 19:45:26 UTC
(rev 5629)
@@ -12,7 +12,7 @@
class NameNodeAdapter(HadoopAdapter):
def get_sage_results(self, values):
- results = self.app.remote.get_name_node_list()
+ results = self.app.remote.get_name_node_list(owner=["condor",
self.app.user]) #condor is a temporary hack
return results
class NameNodeSelector(ObjectSelector):
Modified: branches/elephant/cumin/python/cumin/gridhadoop/tasktracker.py
===================================================================
--- branches/elephant/cumin/python/cumin/gridhadoop/tasktracker.py 2013-01-02 19:07:17 UTC
(rev 5628)
+++ branches/elephant/cumin/python/cumin/gridhadoop/tasktracker.py 2013-01-02 19:45:26 UTC
(rev 5629)
@@ -13,7 +13,7 @@
class TaskTrackerAdapter(HadoopAdapter):
def get_sage_results(self, values):
- results = self.app.remote.get_task_tracker_list()
+ results = self.app.remote.get_task_tracker_list(owner=["condor",
self.app.user]) #condor is a temporary hack
return results
class TaskTrackerSelector(ObjectSelector):
Show replies by date