This project has retired. For details please refer to its Attic page.

org.apache.lens.ml.spark
Class SparkMLDriver

java.lang.Object
  org.apache.lens.ml.spark.SparkMLDriver

All Implemented Interfaces:

MLDriver

public class SparkMLDriver
extends Object
implements MLDriver

The Class SparkMLDriver.

Field Summary

static org.apache.commons.logging.Log

LOG The Constant LOG.

Constructor Summary

SparkMLDriver()

Method Summary

void	checkStarted() Check started.
MLAlgo	getAlgoInstance(String name) Gets the algo instance.
List<String>	getAlgoNames()
org.apache.spark.api.java.JavaSparkContext	getSparkContext()
void	init(LensConf conf) Inits the.
boolean	isAlgoSupported(String name) Checks if is algo supported.
void	start() Start.
void	stop() Stop.
void	useSparkContext(org.apache.spark.api.java.JavaSparkContext jsc) Use spark context.

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

LOG

public static final org.apache.commons.logging.Log LOG

The Constant LOG.

Constructor Detail

SparkMLDriver

public SparkMLDriver()

Method Detail

useSparkContext

public void useSparkContext(org.apache.spark.api.java.JavaSparkContext jsc)

Use spark context.

Parameters:

jsc - the jsc

isAlgoSupported

public boolean isAlgoSupported(String name)

Description copied from interface: MLDriver

Checks if is algo supported.

Specified by:

isAlgoSupported in interface MLDriver

Parameters:

name - the algo

Returns:

true, if is algo supported

getAlgoInstance

public MLAlgo getAlgoInstance(String name)
                       throws LensException

Description copied from interface: MLDriver

Gets the algo instance.

Specified by:

getAlgoInstance in interface MLDriver

Parameters:

name - the algo

Returns:

the algo instance

Throws:

LensException - the lens exception

init

public void init(LensConf conf)
          throws LensException

Description copied from interface: MLDriver

Inits the.

Specified by:

init in interface MLDriver

Parameters:

conf - the conf

Throws:

LensException - the lens exception

start

public void start()
           throws LensException

Description copied from interface: MLDriver

Start.

Specified by:

start in interface MLDriver

Throws:

LensException - the lens exception

stop

public void stop()
          throws LensException

Description copied from interface: MLDriver

Stop.

Specified by:

stop in interface MLDriver

Throws:

LensException - the lens exception

getAlgoNames

public List<String> getAlgoNames()

Specified by:

getAlgoNames in interface MLDriver

checkStarted

public void checkStarted()
                  throws LensException

Check started.

Throws:

LensException - the lens exception

getSparkContext

public org.apache.spark.api.java.JavaSparkContext getSparkContext()