Added support of Mahout 0.10 to MapR plugin

Change-Id: Ibb2f1a0f20c6e58782fc7ad9d15861ce2ec7a1c5
Implements: blueprint mapr-mahout-010
This commit is contained in:
Artem Osadchyi 2015-08-03 12:56:42 +03:00
parent 7c13e80cda
commit 14f8b02258
6 changed files with 19 additions and 7 deletions

View File

@ -19,7 +19,6 @@ import sahara.plugins.mapr.domain.node_process as np
import sahara.plugins.mapr.domain.service as s import sahara.plugins.mapr.domain.service as s
import sahara.plugins.mapr.util.validation_utils as vu import sahara.plugins.mapr.util.validation_utils as vu
MAHOUT = np.NodeProcess( MAHOUT = np.NodeProcess(
name='mahout', name='mahout',
ui_name='Mahout', ui_name='Mahout',
@ -34,6 +33,19 @@ class Mahout(s.Service):
super(Mahout, self).__init__() super(Mahout, self).__init__()
self._name = 'mahout' self._name = 'mahout'
self._ui_name = 'Mahout' self._ui_name = 'Mahout'
self._version = '0.9'
self._node_processes = [MAHOUT] self._node_processes = [MAHOUT]
self._validation_rules = [vu.at_least(1, MAHOUT)] self._validation_rules = [vu.at_least(1, MAHOUT)]
@six.add_metaclass(s.Single)
class MahoutV09(Mahout):
def __init__(self):
super(MahoutV09, self).__init__()
self._version = '0.9'
@six.add_metaclass(s.Single)
class MahoutV010(Mahout):
def __init__(self):
super(MahoutV010, self).__init__()
self._version = '0.10.0'

View File

@ -54,7 +54,7 @@ class VersionHandler(bvh.BaseVersionHandler):
hbase.HBaseV094(), hbase.HBaseV094(),
hbase.HBaseV0987(), hbase.HBaseV0987(),
httpfs.HttpFS(), httpfs.HttpFS(),
mahout.Mahout(), mahout.MahoutV09(),
pig.PigV013(), pig.PigV013(),
pig.PigV014(), pig.PigV014(),
swift.Swift(), swift.Swift(),

View File

@ -52,7 +52,7 @@ class VersionHandler(bvh.BaseVersionHandler):
hbase.HBaseV0987(), hbase.HBaseV0987(),
hbase.HBaseV0989(), hbase.HBaseV0989(),
httpfs.HttpFS(), httpfs.HttpFS(),
mahout.Mahout(), mahout.MahoutV09(),
pig.PigV013(), pig.PigV013(),
pig.PigV014(), pig.PigV014(),
swift.Swift(), swift.Swift(),

View File

@ -53,7 +53,7 @@ class VersionHandler(bvh.BaseVersionHandler):
hbase.HBaseV0987(), hbase.HBaseV0987(),
hbase.HBaseV0989(), hbase.HBaseV0989(),
httpfs.HttpFS(), httpfs.HttpFS(),
mahout.Mahout(), mahout.MahoutV09(),
pig.PigV013(), pig.PigV013(),
pig.PigV014(), pig.PigV014(),
swift.Swift(), swift.Swift(),

View File

@ -58,7 +58,7 @@ class VersionHandler(bvh.BaseVersionHandler):
hue.HueV360(), hue.HueV360(),
hue.HueV370(), hue.HueV370(),
httpfs.HttpFS(), httpfs.HttpFS(),
mahout.Mahout(), mahout.MahoutV09(),
pig.PigV013(), pig.PigV013(),
pig.PigV014(), pig.PigV014(),
sqoop2.Sqoop2(), sqoop2.Sqoop2(),

View File

@ -59,7 +59,7 @@ class VersionHandler(bvh.BaseVersionHandler):
hue.HueV360(), hue.HueV360(),
hue.HueV370(), hue.HueV370(),
httpfs.HttpFS(), httpfs.HttpFS(),
mahout.Mahout(), mahout.MahoutV09(),
pig.PigV013(), pig.PigV013(),
pig.PigV014(), pig.PigV014(),
sqoop2.Sqoop2(), sqoop2.Sqoop2(),