org.apache.tika.pipes.emitter.solr

Class SolrEmitter

java.lang.Object

org.apache.tika.pipes.emitter.AbstractEmitter

org.apache.tika.pipes.emitter.solr.SolrEmitter

All Implemented Interfaces:

Initializable, Emitter

public class SolrEmitter
extends AbstractEmitter
implements Initializable

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SolrEmitter.AttachmentStrategy
static class	SolrEmitter.UpdateStrategy

Constructor Summary

Constructors

Constructor and Description
SolrEmitter()

Method Summary

Modifier and Type	Method and Description
void	checkInitialization(InitializableProblemHandler problemHandler)
void	emit(List<? extends EmitData> batch) The default behavior is to call Emitter.emit(String, List) on each item.
void	emit(String emitKey, List<Metadata> metadataList)
int	getCommitWithin()
String	getContentField()
void	initialize(Map<String,Param> params)
void	setAttachmentStrategy(String attachmentStrategy) Options: SKIP, CONCATENATE_CONTENT, PARENT_CHILD.
void	setAuthScheme(String authScheme)
void	setCommitWithin(int commitWithin)
void	setConnectionTimeout(int connectionTimeout)
void	setContentField(String contentField) This is the field _after_ metadata mappings have been applied that contains the "content" for each metadata object.
void	setIdField(String idField) Specify the field in the first Metadata that should be used as the id field for the document.
void	setPassword(String password)
void	setProxyHost(String proxyHost)
void	setProxyPort(int proxyPort)
void	setSocketTimeout(int socketTimeout)
void	setSolrCollection(String solrCollection)
void	setSolrUrls(List<String> solrUrls)
void	setSolrZkChroot(String solrZkChroot)
void	setSolrZkHosts(List<String> solrZkHosts)
void	setUpdateStrategy(String updateStrategy)
void	setUserName(String userName)

Methods inherited from class org.apache.tika.pipes.emitter.AbstractEmitter

getName, setName

Methods inherited from class java.lang.Object

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

Constructor Detail

SolrEmitter

public SolrEmitter()
            throws TikaConfigException

Throws:

TikaConfigException

Method Detail

emit

public void emit(String emitKey,
                 List<Metadata> metadataList)
          throws IOException,
                 TikaEmitterException

Specified by:

emit in interface Emitter

Throws:

IOException

TikaEmitterException

emit

public void emit(List<? extends EmitData> batch)
          throws IOException,
                 TikaEmitterException

Description copied from class: AbstractEmitter

The default behavior is to call Emitter.emit(String, List) on each item. Some implementations, e.g. Solr/ES/vespa, can benefit from subclassing this and emitting a bunch of docs at once.

Specified by:

emit in interface Emitter

Overrides:

emit in class AbstractEmitter

Throws:

IOException

TikaEmitterException

setAttachmentStrategy

@Field
public void setAttachmentStrategy(String attachmentStrategy)

Options: SKIP, CONCATENATE_CONTENT, PARENT_CHILD. Default is "PARENT_CHILD". If set to "SKIP", this will index only the main file and ignore all info in the attachments. If set to "CONCATENATE_CONTENT", this will concatenate the content extracted from the attachments into the main document and then index the main document with the concatenated content _and_ the main document's metadata (metadata from attachments will be thrown away). If set to "PARENT_CHILD", this will index the attachments as children of the parent document via Solr's parent-child relationship.

setUpdateStrategy

@Field
public void setUpdateStrategy(String updateStrategy)

setConnectionTimeout

@Field
public void setConnectionTimeout(int connectionTimeout)

setSocketTimeout

@Field
public void setSocketTimeout(int socketTimeout)

getContentField

public String getContentField()

setContentField

@Field
public void setContentField(String contentField)

This is the field _after_ metadata mappings have been applied that contains the "content" for each metadata object.

This is the field that is used if attachmentStrategy is SolrEmitter.AttachmentStrategy.CONCATENATE_CONTENT.

Parameters:

contentField -

getCommitWithin

public int getCommitWithin()

setCommitWithin

@Field
public void setCommitWithin(int commitWithin)

setIdField

@Field
public void setIdField(String idField)

Specify the field in the first Metadata that should be used as the id field for the document.

Parameters:

idField -

setSolrCollection

@Field
public void setSolrCollection(String solrCollection)

setSolrUrls

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

setSolrZkHosts

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

setSolrZkChroot

@Field
public void setSolrZkChroot(String solrZkChroot)

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)

initialize

public void initialize(Map<String,Param> params)
                throws TikaConfigException

Specified by:

initialize in interface Initializable

Parameters:

params - params to use for initialization

Throws:

TikaConfigException

checkInitialization

public void checkInitialization(InitializableProblemHandler problemHandler)
                         throws TikaConfigException

Specified by:

checkInitialization in interface Initializable

Parameters:

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

Throws:

TikaConfigException