public class TopicStream extends CloudSolrStream implements Expressible
CloudSolrStream.StreamOpener, CloudSolrStream.TupleWrapper
TupleStream.IgnoreException
MapWriter.EntryWriter
Modifier and Type | Field and Description |
---|---|
protected long |
checkpointEvery |
cloudSolrClient, collection, comp, eofTuples, fieldMappings, params, solrStreams, streamContext, tuples, zkHost
Constructor and Description |
---|
TopicStream(StreamExpression expression,
StreamFactory factory) |
TopicStream(String zkHost,
String checkpointCollection,
String collection,
String id,
long initialCheckpoint,
long checkpointEvery,
SolrParams params) |
Modifier and Type | Method and Description |
---|---|
List<TupleStream> |
children() |
void |
close()
Closes the CloudSolrStream
|
protected void |
constructStreams() |
int |
getCost() |
void |
open()
Opens the CloudSolrStream
|
Tuple |
read() |
Explanation |
toExplanation(StreamFactory factory)
Returns an explanation about the stream object
|
StreamExpression |
toExpression(StreamFactory factory) |
_read, adjustParams, getEofTuples, getSlices, getStreamSort, init, setFieldMappings, setStreamContext, setTrace
getShards, getStreamNodeId, writeMap
public TopicStream(String zkHost, String checkpointCollection, String collection, String id, long initialCheckpoint, long checkpointEvery, SolrParams params)
public TopicStream(StreamExpression expression, StreamFactory factory) throws IOException
IOException
public StreamExpression toExpression(StreamFactory factory) throws IOException
toExpression
in interface Expressible
toExpression
in class CloudSolrStream
IOException
public Explanation toExplanation(StreamFactory factory) throws IOException
Expressible
toExplanation
in interface Expressible
toExplanation
in class CloudSolrStream
factory
- Stream factory for this, contains information about the function nameIOException
- throw on any errorpublic List<TupleStream> children()
children
in class CloudSolrStream
public void open() throws IOException
CloudSolrStream
open
in class CloudSolrStream
IOException
public void close() throws IOException
CloudSolrStream
close
in interface Closeable
close
in interface AutoCloseable
close
in class CloudSolrStream
IOException
public Tuple read() throws IOException
read
in class CloudSolrStream
IOException
public int getCost()
getCost
in class TupleStream
protected void constructStreams() throws IOException
constructStreams
in class CloudSolrStream
IOException
Copyright © 2000-2017 Apache Software Foundation. All Rights Reserved.