org.apache.tika.pipes.pipesiterator.solr

Class SolrPipesIterator

java.lang.Object

org.apache.tika.config.ConfigBase

org.apache.tika.pipes.pipesiterator.PipesIterator

org.apache.tika.pipes.pipesiterator.solr.SolrPipesIterator

All Implemented Interfaces:

Iterable<FetchEmitTuple>, Callable<Integer>, Initializable

public class SolrPipesIterator
extends PipesIterator
implements Initializable

Iterates through results from a Solr query.

Field Summary

Fields inherited from class org.apache.tika.pipes.pipesiterator.PipesIterator

COMPLETED_SEMAPHORE, DEFAULT_MAX_WAIT_MS, DEFAULT_QUEUE_SIZE

Constructor Summary

Constructors

Constructor and Description
SolrPipesIterator()

Method Summary

Modifier and Type	Method and Description
void	checkInitialization(InitializableProblemHandler problemHandler)
protected void	enqueue()
void	setAdditionalFields(List<String> additionalFields)
void	setAuthScheme(String authScheme)
void	setConnectionTimeout(int connectionTimeout)
void	setFailCountField(String failCountField)
void	setFilters(List<String> filters)
void	setIdField(String idField)
void	setParsingIdField(String parsingIdField)
void	setPassword(String password)
void	setProxyHost(String proxyHost)
void	setProxyPort(int proxyPort)
void	setRows(int rows)
void	setSizeFieldName(String sizeFieldName)
void	setSocketTimeout(int socketTimeout)
void	setSolrCollection(String solrCollection)
void	setSolrUrls(List<String> solrUrls)
void	setSolrZkChroot(String solrZkChroot)
void	setSolrZkHosts(List<String> solrZkHosts)
void	setUserName(String userName)

Methods inherited from class org.apache.tika.pipes.pipesiterator.PipesIterator

build, call, getEmitterName, getFetcherName, getHandlerConfig, getOnParseException, initialize, iterator, setEmitterName, setFetcherName, setHandlerType, setMaxEmbeddedResources, setMaxWaitMs, setOnParseException, setOnParseException, setParseMode, setParseMode, setQueueSize, setWriteLimit, tryToAdd

Methods inherited from class org.apache.tika.config.ConfigBase

buildComposite, buildComposite, buildSingle, configure, handleSettings

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.tika.config.Initializable

initialize

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Detail

SolrPipesIterator

public SolrPipesIterator()
                  throws TikaConfigException

Throws:

TikaConfigException

Method Detail

setSolrZkHosts

@Field
public void setSolrZkHosts(List<String> solrZkHosts)

setSolrZkChroot

@Field
public void setSolrZkChroot(String solrZkChroot)

setSolrCollection

@Field
public void setSolrCollection(String solrCollection)

setSolrUrls

@Field
public void setSolrUrls(List<String> solrUrls)

setFilters

@Field
public void setFilters(List<String> filters)

setAdditionalFields

@Field
public void setAdditionalFields(List<String> additionalFields)

setIdField

@Field
public void setIdField(String idField)

setParsingIdField

@Field
public void setParsingIdField(String parsingIdField)

setFailCountField

@Field
public void setFailCountField(String failCountField)

setSizeFieldName

@Field
public void setSizeFieldName(String sizeFieldName)

setRows

@Field
public void setRows(int rows)

setConnectionTimeout

@Field
public void setConnectionTimeout(int connectionTimeout)

setSocketTimeout

@Field
public void setSocketTimeout(int socketTimeout)

setUserName

@Field
public void setUserName(String userName)

setPassword

@Field
public void setPassword(String password)

setAuthScheme

@Field
public void setAuthScheme(String authScheme)

setProxyHost

@Field
public void setProxyHost(String proxyHost)

setProxyPort

@Field
public void setProxyPort(int proxyPort)

enqueue

protected void enqueue()
                throws InterruptedException,
                       IOException,
                       TimeoutException

Specified by:

enqueue in class PipesIterator

Throws:

InterruptedException

IOException

TimeoutException

checkInitialization

public void checkInitialization(InitializableProblemHandler problemHandler)
                         throws TikaConfigException

Specified by:

checkInitialization in interface Initializable

Overrides:

checkInitialization in class PipesIterator

Parameters:

problemHandler - if there is a problem and no custom initializableProblemHandler has been configured via Initializable parameters, this is called to respond.

Throws:

TikaConfigException