com.spotify.zoltar.examples.mlengine

Class MlEnginePredictorExample

java.lang.Object

com.spotify.zoltar.examples.mlengine.MlEnginePredictorExample

All Implemented Interfaces:

Predictor<com.spotify.zoltar.IrisFeaturesSpec.Iris,Integer>

public final class MlEnginePredictorExample
extends Object
implements Predictor<com.spotify.zoltar.IrisFeaturesSpec.Iris,Integer>

Cloud Machine Learning Engine online prediction example.

Method Summary

Modifier and Type	Method and Description
static MlEnginePredictorExample	create(String projectId, String modelId, String versionId) Runs a simple Iris prediction against the running Iris ml-engine instance.
CompletionStage<List<Prediction<com.spotify.zoltar.IrisFeaturesSpec.Iris,Integer>>>	predict(ScheduledExecutorService scheduler, Duration timeout, com.spotify.zoltar.IrisFeaturesSpec.Iris... input) Functional interface.

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.spotify.zoltar.Predictor

predict, predict, timeoutScheduler

Method Detail

create

public static MlEnginePredictorExample create(String projectId,
                                              String modelId,
                                              String versionId)
                                       throws Exception

Runs a simple Iris prediction against the running Iris ml-engine instance.

Throws:

Exception

predict

public CompletionStage<List<Prediction<com.spotify.zoltar.IrisFeaturesSpec.Iris,Integer>>> predict(ScheduledExecutorService scheduler,
                                                                                                   Duration timeout,
                                                                                                   com.spotify.zoltar.IrisFeaturesSpec.Iris... input)

Description copied from interface: Predictor

Functional interface. You should perform E2E feature extraction and prediction. See DefaultPredictorBuilder#create(ModelLoader, FeatureExtractor, AsyncPredictFn) for an example of usage.

Specified by:

predict in interface Predictor<com.spotify.zoltar.IrisFeaturesSpec.Iris,Integer>

Parameters:

scheduler - implementation specific scheduler.

timeout - implementation specific timeout.

input - a list of inputs to perform feature extraction and prediction on.