Add Flume 1.6.0 to MapR plugin

Change-Id: I64fb45ec301eac32d84507f6dbd2e8de8334729f
Closes-Bug: #1540914
This commit is contained in:
groghkov
2016-02-02 15:04:02 +02:00
parent 410f963c50
commit 33eb5e0b9f
2 changed files with 14 additions and 2 deletions

View File

@@ -31,6 +31,17 @@ class Flume(s.Service):
super(Flume, self).__init__()
self._name = 'flume'
self._ui_name = 'Flume'
self._version = '1.5.0'
self._node_processes = [FLUME]
self._validation_rules = [vu.at_least(1, FLUME)]
class FlumeV15(Flume):
def __init__(self):
super(FlumeV15, self).__init__()
self._version = '1.5.0'
class FlumeV16(Flume):
def __init__(self):
super(FlumeV16, self).__init__()
self._version = '1.6.0'

View File

@@ -53,7 +53,8 @@ class VersionHandler(bvh.BaseVersionHandler):
impala.ImpalaV141(),
pig.PigV014(),
pig.PigV015(),
flume.Flume(),
flume.FlumeV15(),
flume.FlumeV16(),
spark.SparkOnYarn(),
sqoop2.Sqoop2(),
mahout.MahoutV010(),