org.apache.storm.pmml.runner

Interface ModelRunner

All Known Subinterfaces:

PmmlModelRunner<I,R,P,S>

All Known Implementing Classes:

JPmmlModelRunner

public interface ModelRunner

Method Summary

Modifier and Type	Method and Description
Map<String,List<Object>>	scoredTuplePerStream(Tuple input) Creates and returns a map with the predicted scores that are to be emitted on each stream.

Method Detail

scoredTuplePerStream

Map<String,List<Object>> scoredTuplePerStream(Tuple input)

Creates and returns a map with the predicted scores that are to be emitted on each stream. The keys of this map are the stream ids, and the values the predicted scores. It's up to the implementation to guarantee that the streams ids match the stream ids defined in ModelOutputs. Namely, the set of keys of the Map<String, List<Object>> returned by this method should be a subset of ModelOutputs.streams()

Returns:

The map with the predicted scores that are to be emitted on each stream