Package | Description |
---|---|
org.apache.storm.pmml | |
org.apache.storm.pmml.model.jpmml | |
org.apache.storm.pmml.runner.jpmml |
Constructor and Description |
---|
PMMLPredictorBolt(ModelRunnerFactory modelRunnerFactory,
ModelOutputs modelOutputs)
Creates an instance of
PMMLPredictorBolt that executes, for every tuple, the runner constructed with the ModelRunnerFactory specified in the parameter The PMMLPredictorBolt instantiated with this constructor declares the output fields as specified by the ModelOutputs parameter |
Modifier and Type | Class and Description |
---|---|
class |
JpmmlModelOutputs |
Modifier and Type | Method and Description |
---|---|
static ModelOutputs |
JpmmlModelOutputs.toDefaultStream(File pmmlModel) |
static ModelOutputs |
JpmmlModelOutputs.toDefaultStream(InputStream pmmlModel) |
static ModelOutputs |
JpmmlModelOutputs.toDefaultStream(org.dmg.pmml.PMML pmmlModel)
Factory method that creates an instance of
ModelOutputs that declares the predicted and output fields specified in the PMML model specified as argument into the default stream |
static ModelOutputs |
JpmmlModelOutputs.toDefaultStream(String blobKey) |
static ModelOutputs |
JpmmlModelOutputs.toDefaultStream(String blobKey,
Map<String,Object> config) |
static ModelOutputs |
JpmmlModelOutputs.toStreams(File pmmlModel,
List<String> streams) |
static ModelOutputs |
JpmmlModelOutputs.toStreams(InputStream pmmlModel,
List<String> streams) |
static ModelOutputs |
JpmmlModelOutputs.toStreams(org.dmg.pmml.PMML pmmlModel,
List<String> streams)
Factory method that creates an instance of
ModelOutputs that declares the predicted and output fields specified in the PMML model specified as argument into the list of streams specified |
static ModelOutputs |
JpmmlModelOutputs.toStreams(String blobKey,
List<String> streams) |
static ModelOutputs |
JpmmlModelOutputs.toStreams(String blobKey,
Map<String,Object> config,
List<String> streams) |
Modifier and Type | Method and Description |
---|---|
ModelOutputs |
JPmmlModelRunner.getModelOutputs() |
Constructor and Description |
---|
JPmmlModelRunner(org.jpmml.evaluator.Evaluator evaluator,
ModelOutputs modelOutputs) |
ModelRunnerFromBlobStore(String blobKey,
ModelOutputs modelOutputs)
Uses Storm config as returned by
Utils.readStormConfig() |
ModelRunnerFromBlobStore(String blobKey,
ModelOutputs modelOutputs,
Map<String,Object> config) |
ModelRunnerFromFile(File model,
ModelOutputs modelOutputs) |
Copyright © 2019 The Apache Software Foundation. All rights reserved.