Package org.apache.solr.cli

Class StreamTool.LocalCatStream

java.lang.Object

org.apache.solr.client.solrj.io.stream.TupleStream

org.apache.solr.handler.CatStream

org.apache.solr.cli.StreamTool.LocalCatStream

All Implemented Interfaces:

Closeable, Serializable, AutoCloseable, Expressible, org.apache.solr.common.MapSerializable, org.apache.solr.common.MapWriter, org.apache.solr.common.NavigableObject, org.noggit.JSONWriter.Writable

Enclosing class:

StreamTool

public static class StreamTool.LocalCatStream
extends CatStream

See Also:

• Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.solr.handler.CatStream

CatStream.CrawlFile

Nested classes/interfaces inherited from class org.apache.solr.client.solrj.io.stream.TupleStream

TupleStream.IgnoreException

Nested classes/interfaces inherited from interface org.apache.solr.common.MapWriter

org.apache.solr.common.MapWriter.EntryWriter

Field Summary

Fields inherited from class org.apache.solr.handler.CatStream

commaDelimitedFilepaths

Fields inherited from interface org.apache.solr.common.MapWriter

EMPTY

Constructor Summary

Constructors

Constructor	Description
LocalCatStream(String commaDelimitedFilepaths, int maxLines)
LocalCatStream(StreamExpression expression, StreamFactory factory)

Method Summary

Modifier and Type	Method	Description
void	setStreamContext(StreamContext context)
protected List<CatStream.CrawlFile>	validateAndSetFilepathsInSandbox()

Methods inherited from class org.apache.solr.handler.CatStream

children, close, getStreamSort, open, read, toExplanation, toExpression

Methods inherited from class org.apache.solr.client.solrj.io.stream.TupleStream

getCost, getShards, getShards, getStreamNodeId, writeMap

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.solr.common.MapWriter

jsonStr, toMap, write

Methods inherited from interface org.apache.solr.common.NavigableObject

_forEachEntry, _forEachEntry, _forEachEntry, _get, _get, _getStr, _getStr, _size

Constructor Details

LocalCatStream

public LocalCatStream(StreamExpression expression,
 StreamFactory factory)
               throws IOException

Throws:

IOException

LocalCatStream

public LocalCatStream(String commaDelimitedFilepaths,
 int maxLines)

Method Details

setStreamContext

public void setStreamContext(StreamContext context)

Overrides:

setStreamContext in class CatStream

validateAndSetFilepathsInSandbox

protected List<CatStream.CrawlFile> validateAndSetFilepathsInSandbox()

Overrides:

validateAndSetFilepathsInSandbox in class CatStream