com.arakelian.elastic.bulk

Class BulkOperation

java.lang.Object

com.arakelian.elastic.bulk.BulkOperation

@Value.Immutable(copy=false)
public abstract class BulkOperation
extends java.lang.Object

Represents a source document that will be indexed into Elastic.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	BulkOperation.Action Bulk actions are INDEX, CREATE, DELETE and UPDATE.
static class	BulkOperation.VersionType

Constructor Summary

Constructors

Constructor and Description
BulkOperation()

Method Summary

Modifier and Type	Method and Description
protected void	checkSource()
abstract BulkOperation.Action	getAction() Returns mapping type within index.
java.lang.String	getCompactSource()
abstract java.lang.String	getId() Returns the id of the document.
abstract Index	getIndex() Returns index that this document will be indexed into.
abstract BulkOperationListener	getListener()
java.lang.String	getOperation()
abstract java.lang.String	getSource() Returns source JSON document that will be indexed by BulkIndexer
abstract java.lang.String	getType() Returns mapping type within index.
abstract java.lang.Long	getVersion()
BulkOperation.VersionType	getVersionType()

Methods inherited from class java.lang.Object

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

Constructor Detail

BulkOperation

public BulkOperation()

Method Detail

getAction

public abstract BulkOperation.Action getAction()

Returns mapping type within index.

Returns:

mapping type within index.

getCompactSource

@Value.Derived
 @Value.Auxiliary
public java.lang.String getCompactSource()

getId

public abstract java.lang.String getId()

Returns the id of the document.

Returns:

id of the document.

getIndex

public abstract Index getIndex()

Returns index that this document will be indexed into.

Returns:

index that this document will be indexed into.

getListener

@Value.Auxiliary
public abstract BulkOperationListener getListener()

getOperation

@Value.Derived
 @Value.Auxiliary
public java.lang.String getOperation()

getSource

@Value.Auxiliary
public abstract java.lang.String getSource()

Returns source JSON document that will be indexed by BulkIndexer

Returns:

source JSON document that will be indexed by BulkIndexer

getType

public abstract java.lang.String getType()

Returns mapping type within index.

Returns:

mapping type within index.

getVersion

public abstract java.lang.Long getVersion()

getVersionType

@Value.Default
public BulkOperation.VersionType getVersionType()

checkSource

@Value.Check
protected void checkSource()