public class ModelTupleStream
extends org.apache.solr.client.solrj.io.stream.TupleStream
implements org.apache.solr.client.solrj.io.stream.expr.Expressible
Model
to compute output scores.
Tuple
fields are the model inputs and the model output(s) are added to the returned tuple.
Illustrative configuration snippet:
<expressible name="emailModel" class="org.deeplearning4j.nn.modelexport.solr.handler.ModelTupleStream"/>
Illustrative expression snippet:
emailModel(search(myCollection, q="*:*", fl="id,fieldX,fieldY,fieldZ", sort="id asc", qt="/export"), serializedModelFileName="mySerializedModel", inputKeys="fieldX,fieldY,fieldZ", outputKeys="modelScoreField1,modelScoreField2")
Apache Solr Reference Guide:
Constructor and Description |
---|
ModelTupleStream(org.apache.solr.client.solrj.io.stream.expr.StreamExpression streamExpression,
org.apache.solr.client.solrj.io.stream.expr.StreamFactory streamFactory) |
Modifier and Type | Method and Description |
---|---|
protected org.apache.solr.client.solrj.io.Tuple |
applyOutputsToTuple(org.apache.solr.client.solrj.io.Tuple tuple,
INDArray output) |
List<org.apache.solr.client.solrj.io.stream.TupleStream> |
children() |
void |
close() |
protected INDArray |
getInputsFromTuple(org.apache.solr.client.solrj.io.Tuple tuple) |
org.apache.solr.client.solrj.io.comp.StreamComparator |
getStreamSort() |
void |
open() |
protected InputStream |
openInputStream() |
org.apache.solr.client.solrj.io.Tuple |
read() |
protected Model |
restoreModel(InputStream inputStream)
Uses the
ModelGuesser.loadModelGuess(InputStream) method. |
void |
setStreamContext(org.apache.solr.client.solrj.io.stream.StreamContext streamContext) |
org.apache.solr.client.solrj.io.stream.expr.Explanation |
toExplanation(org.apache.solr.client.solrj.io.stream.expr.StreamFactory streamFactory) |
org.apache.solr.client.solrj.io.stream.expr.StreamExpressionParameter |
toExpression(org.apache.solr.client.solrj.io.stream.expr.StreamFactory streamFactory) |
Map |
toMap(Map<String,Object> map) |
getCost, getShards, getStreamNodeId, writeMap
public ModelTupleStream(org.apache.solr.client.solrj.io.stream.expr.StreamExpression streamExpression, org.apache.solr.client.solrj.io.stream.expr.StreamFactory streamFactory) throws IOException
IOException
public Map toMap(Map<String,Object> map)
toMap
in interface org.apache.solr.common.MapSerializable
toMap
in interface org.apache.solr.common.MapWriter
public void setStreamContext(org.apache.solr.client.solrj.io.stream.StreamContext streamContext)
setStreamContext
in class org.apache.solr.client.solrj.io.stream.TupleStream
public List<org.apache.solr.client.solrj.io.stream.TupleStream> children()
children
in class org.apache.solr.client.solrj.io.stream.TupleStream
public void open() throws IOException
open
in class org.apache.solr.client.solrj.io.stream.TupleStream
IOException
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
close
in class org.apache.solr.client.solrj.io.stream.TupleStream
IOException
public org.apache.solr.client.solrj.io.Tuple read() throws IOException
read
in class org.apache.solr.client.solrj.io.stream.TupleStream
IOException
public org.apache.solr.client.solrj.io.comp.StreamComparator getStreamSort()
getStreamSort
in class org.apache.solr.client.solrj.io.stream.TupleStream
public org.apache.solr.client.solrj.io.stream.expr.Explanation toExplanation(org.apache.solr.client.solrj.io.stream.expr.StreamFactory streamFactory) throws IOException
toExplanation
in interface org.apache.solr.client.solrj.io.stream.expr.Expressible
toExplanation
in class org.apache.solr.client.solrj.io.stream.TupleStream
IOException
public org.apache.solr.client.solrj.io.stream.expr.StreamExpressionParameter toExpression(org.apache.solr.client.solrj.io.stream.expr.StreamFactory streamFactory) throws IOException
toExpression
in interface org.apache.solr.client.solrj.io.stream.expr.Expressible
IOException
protected InputStream openInputStream() throws IOException
IOException
protected Model restoreModel(InputStream inputStream) throws IOException
ModelGuesser.loadModelGuess(InputStream)
method.IOException
protected INDArray getInputsFromTuple(org.apache.solr.client.solrj.io.Tuple tuple)
protected org.apache.solr.client.solrj.io.Tuple applyOutputsToTuple(org.apache.solr.client.solrj.io.Tuple tuple, INDArray output)
Copyright © 2020. All rights reserved.