org.apache.tika.pipes.emitter.opensearch

Class OpenSearchEmitter

java.lang.Object

org.apache.tika.pipes.emitter.AbstractEmitter

org.apache.tika.pipes.emitter.opensearch.OpenSearchEmitter

All Implemented Interfaces:

Initializable, Emitter

public class OpenSearchEmitter
extends AbstractEmitter
implements Initializable

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	OpenSearchEmitter.AttachmentStrategy

Constructor Summary

Constructors

Constructor and Description
OpenSearchEmitter()

Method Summary

Modifier and Type	Method and Description
void	checkInitialization(InitializableProblemHandler problemHandler)
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	setOpenSearchUrl(String openSearchUrl)
void	setPassword(String password)
void	setProxyHost(String proxyHost)
void	setProxyPort(int proxyPort)
void	setSocketTimeout(int socketTimeout)
void	setUserName(String userName)

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

emit, getName, setName

Methods inherited from class java.lang.Object

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

Constructor Detail

OpenSearchEmitter

public OpenSearchEmitter()
                  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

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 OpenSearch's parent-child relationship.

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 OpenSearchEmitter.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 -

setOpenSearchUrl

@Field
public void setOpenSearchUrl(String openSearchUrl)

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