public class TextLogitStream extends TupleStream implements Expressible
Modifier and Type | Class and Description |
---|---|
protected class |
TextLogitStream.LogitCall |
protected static class |
TextLogitStream.TermsStream |
TupleStream.IgnoreException
MapWriter.EntryWriter
Modifier and Type | Field and Description |
---|---|
protected SolrClientCache |
cache |
protected CloudSolrClient |
cloudSolrClient |
protected String |
collection |
protected double |
error |
protected ClassificationEvaluation |
evaluation |
protected ExecutorService |
executorService |
protected String |
field |
protected List<Double> |
idfs |
protected boolean |
isCloseCache |
protected int |
iteration |
protected int |
maxIterations |
protected String |
name |
protected String |
outcome |
protected Map<String,String> |
params |
protected int |
positiveLabel |
protected StreamContext |
streamContext |
protected TupleStream |
termsStream |
protected double |
threshold |
protected List<Double> |
weights |
protected String |
zkHost |
Constructor and Description |
---|
TextLogitStream(StreamExpression expression,
StreamFactory factory)
logit(collection, zkHost="", features="a,b,c,d,e,f,g", outcome="y", maxIteration="20")
|
TextLogitStream(String zkHost,
String collectionName,
Map params,
String name,
String field,
TupleStream termsStream,
List<Double> weights,
String outcome,
int positiveLabel,
double threshold,
int maxIterations) |
Modifier and Type | Method and Description |
---|---|
List<TupleStream> |
children() |
void |
close() |
protected List<String> |
getShardUrls() |
StreamComparator |
getStreamSort()
Return the stream sort - ie, the order in which records are returned
|
void |
loadTerms() |
void |
open()
Opens the CloudSolrStream
|
Tuple |
read() |
void |
setStreamContext(StreamContext context) |
Explanation |
toExplanation(StreamFactory factory)
Returns an explanation about the stream object
|
StreamExpressionParameter |
toExpression(StreamFactory factory) |
getCost, getShards, getStreamNodeId, writeMap
protected String zkHost
protected String collection
protected String field
protected String name
protected String outcome
protected int positiveLabel
protected double threshold
protected int maxIterations
protected int iteration
protected double error
protected ClassificationEvaluation evaluation
protected transient SolrClientCache cache
protected transient boolean isCloseCache
protected transient CloudSolrClient cloudSolrClient
protected transient StreamContext streamContext
protected ExecutorService executorService
protected TupleStream termsStream
public TextLogitStream(String zkHost, String collectionName, Map params, String name, String field, TupleStream termsStream, List<Double> weights, String outcome, int positiveLabel, double threshold, int maxIterations) throws IOException
IOException
public TextLogitStream(StreamExpression expression, StreamFactory factory) throws IOException
IOException
public StreamExpressionParameter toExpression(StreamFactory factory) throws IOException
toExpression
in interface Expressible
IOException
public void setStreamContext(StreamContext context)
setStreamContext
in class TupleStream
public void open() throws IOException
open
in class TupleStream
IOException
public List<TupleStream> children()
children
in class TupleStream
protected List<String> getShardUrls() throws IOException
IOException
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
close
in class TupleStream
IOException
public StreamComparator getStreamSort()
getStreamSort
in class TupleStream
public Explanation toExplanation(StreamFactory factory) throws IOException
Expressible
toExplanation
in interface Expressible
toExplanation
in class TupleStream
factory
- Stream factory for this, contains information about the function nameIOException
- throw on any errorpublic void loadTerms() throws IOException
IOException
public Tuple read() throws IOException
read
in class TupleStream
IOException
Copyright © 2000-2017 Apache Software Foundation. All Rights Reserved.