org.apache.lens.ml.server

Class MLServiceResource

java.lang.Object

org.apache.lens.ml.server.MLServiceResource

public class MLServiceResource
extends Object

Machine Learning service.

Field Summary

Fields

Modifier and Type	Field and Description
static String	ML_UP_MESSAGE Message indicating if ML service is up

Constructor Summary

Constructors

Constructor and Description
MLServiceResource() Instantiates a new ML service resource.

Method Summary

Methods

Modifier and Type	Method and Description
javax.ws.rs.core.Response	clearModelCache() Clear model cache (for admin use).
String	deleteModel(String algorithm, String modelID) Delete a model given model ID and algorithm name.
String	deleteTestReport(String algorithm, String reportID) DELETE a report given the algorithm name and report ID.
StringList	getAlgoNames() Get a list of algos available
ModelMetadata	getModelMetadata(String algorithm, String modelID) Get metadata of the model given algorithm and model ID.
StringList	getModelsForAlgo(String algorithm) Get model ID list for a given algorithm.
StringList	getParamDescription(String algorithm) Gets the human readable param description of an algorithm
StringList	getReportsForAlgorithm(String algoritm) Get list of reports for a given algorithm.
TestReport	getTestReport(String algorithm, String reportID) Get a single test report given the algorithm name and report id.
String	mlResourceUp() Indicates if ML resource is up
String	predict(String algorithm, String modelID, javax.ws.rs.core.UriInfo uriInfo) Predict.
String	test(String algorithm, String modelID, String table, LensSessionHandle session, String outputTable) Run a test on a model for an algorithm.
String	train(String algorithm, javax.ws.rs.core.MultivaluedMap<String,String> form) Train a model given an algorithm name and algorithm parameters

Methods inherited from class java.lang.Object

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

Field Detail

ML_UP_MESSAGE

public static final String ML_UP_MESSAGE

Message indicating if ML service is up

See Also:

Constant Field Values

Constructor Detail

MLServiceResource

public MLServiceResource()

Instantiates a new ML service resource.

Method Detail

mlResourceUp

public String mlResourceUp()

Indicates if ML resource is up

Returns:

getAlgoNames

public StringList getAlgoNames()

Get a list of algos available

Returns:

getParamDescription

public StringList getParamDescription(String algorithm)

Gets the human readable param description of an algorithm

Parameters:

algorithm - the algorithm

Returns:

the param description

getModelsForAlgo

public StringList getModelsForAlgo(String algorithm)
                            throws LensException

Get model ID list for a given algorithm.

Parameters:

algorithm - algorithm name

Returns:

the models for algo

Throws:

LensException - the lens exception

getModelMetadata

public ModelMetadata getModelMetadata(String algorithm,
                             String modelID)
                               throws LensException

Get metadata of the model given algorithm and model ID.

Parameters:

algorithm - algorithm name

modelID - model ID

Returns:

model metadata

Throws:

LensException - the lens exception

deleteModel

public String deleteModel(String algorithm,
                 String modelID)
                   throws LensException

Delete a model given model ID and algorithm name.

Parameters:

algorithm - the algorithm

modelID - the model id

Returns:

confirmation text

Throws:

LensException - the lens exception

train

public String train(String algorithm,
           javax.ws.rs.core.MultivaluedMap<String,String> form)
             throws LensException

Train a model given an algorithm name and algorithm parameters

Following parameters are mandatory and must be passed as part of the form

1. table - input Hive table to load training data from
2. label - name of the labelled column
3. feature - one entry per feature column. At least one feature column is required

Parameters:

algorithm - algorithm name

form - form data

Returns:

if model is successfully trained, the model ID will be returned

Throws:

LensException - the lens exception

clearModelCache

public javax.ws.rs.core.Response clearModelCache()

Clear model cache (for admin use).

Returns:

OK if the cache was cleared

test

public String test(String algorithm,
          String modelID,
          String table,
          LensSessionHandle session,
          String outputTable)
            throws LensException

Run a test on a model for an algorithm.

Parameters:

algorithm - algorithm name

modelID - model ID

table - Hive table to run test on

session - Lens session ID. This session ID will be used to run the test query

Returns:

Test report ID

Throws:

LensException - the lens exception

getReportsForAlgorithm

public StringList getReportsForAlgorithm(String algoritm)
                                  throws LensException

Get list of reports for a given algorithm.

Parameters:

algoritm - the algoritm

Returns:

the reports for algorithm

Throws:

LensException - the lens exception

getTestReport

public TestReport getTestReport(String algorithm,
                       String reportID)
                         throws LensException

Get a single test report given the algorithm name and report id.

Parameters:

algorithm - the algorithm

reportID - the report id

Returns:

the test report

Throws:

LensException - the lens exception

deleteTestReport

public String deleteTestReport(String algorithm,
                      String reportID)
                        throws LensException

DELETE a report given the algorithm name and report ID.

Parameters:

algorithm - the algorithm

reportID - the report id

Returns:

the string

Throws:

LensException - the lens exception

predict

public String predict(String algorithm,
             String modelID,
             @Context
             javax.ws.rs.core.UriInfo uriInfo)
               throws LensException

Predict.

Parameters:

algorithm - the algorithm

modelID - the model id

uriInfo - the uri info

Returns:

the string

Throws:

LensException - the lens exception