Package org.apache.tika.pipes.emitter.es

Class ESEmitter

java.lang.Object

org.apache.tika.plugins.AbstractTikaExtension

org.apache.tika.pipes.api.emitter.AbstractEmitter

org.apache.tika.pipes.emitter.es.ESEmitter

All Implemented Interfaces:

Emitter, TikaExtension

public class ESEmitter
extends AbstractEmitter

Emitter that sends documents to an ES-compatible REST API.

This emitter does not depend on the ES Java client (which changed to a non-ASL license). It uses plain HTTP via Apache HttpClient to call the _bulk endpoint directly.

Supports:

• API key authentication (Authorization: ApiKey <base64>)
• Basic authentication (username/password via httpClientConfig)
• OVERWRITE and UPSERT update strategies
• SEPARATE_DOCUMENTS and PARENT_CHILD attachment strategies

Field Summary

Fields

Modifier and Type	Field	Description
static final String	DEFAULT_EMBEDDED_FILE_FIELD_NAME

Fields inherited from class org.apache.tika.plugins.AbstractTikaExtension

pluginConfig

Constructor Summary

Constructors

Constructor	Description
ESEmitter(ExtensionConfig pluginConfig, ESEmitterConfig config)

Method Summary

Modifier and Type	Method	Description
static ESEmitter	build(ExtensionConfig pluginConfig)
void	emit(String emitKey, List<Metadata> metadataList, ParseContext parseContext)
void	emit(List<? extends EmitData> emitData)

Methods inherited from class org.apache.tika.plugins.AbstractTikaExtension

getExtensionConfig

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.plugins.TikaExtension

getExtensionConfig

Field Details

DEFAULT_EMBEDDED_FILE_FIELD_NAME

public static final String DEFAULT_EMBEDDED_FILE_FIELD_NAME

See Also:

• Constant Field Values

Constructor Details

ESEmitter

public ESEmitter(ExtensionConfig pluginConfig,
 ESEmitterConfig config)
          throws IOException,
TikaConfigException

Throws:

IOException

TikaConfigException

Method Details

build

public static ESEmitter build(ExtensionConfig pluginConfig)
                       throws TikaConfigException,
IOException

Throws:

TikaConfigException

IOException

emit

public void emit(List<? extends EmitData> emitData)
          throws IOException

Specified by:

emit in interface Emitter

Overrides:

emit in class AbstractEmitter

Throws:

IOException

emit

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

Throws:

IOException