Constructor and Description |
---|
SparkMLDriver() |
Modifier and Type | Method and Description |
---|---|
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.
|
public void useSparkContext(org.apache.spark.api.java.JavaSparkContext jsc)
jsc
- the jscpublic boolean isAlgoSupported(String name)
MLDriver
isAlgoSupported
in interface MLDriver
name
- the algopublic MLAlgo getAlgoInstance(String name) throws LensException
MLDriver
getAlgoInstance
in interface MLDriver
name
- the algoLensException
- the lens exceptionpublic void init(LensConf conf) throws LensException
MLDriver
init
in interface MLDriver
conf
- the confLensException
- the lens exceptionpublic void start() throws LensException
MLDriver
start
in interface MLDriver
LensException
- the lens exceptionpublic void stop() throws LensException
MLDriver
stop
in interface MLDriver
LensException
- the lens exceptionpublic List<String> getAlgoNames()
getAlgoNames
in interface MLDriver
public void checkStarted() throws LensException
LensException
- the lens exceptionpublic org.apache.spark.api.java.JavaSparkContext getSparkContext()
Copyright © 2014–2018 Apache Software Foundation. All rights reserved.