com.arakelian.elastic.bulk

Class SimpleBulkOperationFactory<T>

java.lang.Object

com.arakelian.elastic.bulk.SimpleBulkOperationFactory<T>

All Implemented Interfaces:

BulkOperationFactory

@Value.Immutable
public abstract class SimpleBulkOperationFactory<T>
extends java.lang.Object
implements BulkOperationFactory

Constructor Summary

Constructors

Constructor and Description
SimpleBulkOperationFactory()

Method Summary

Modifier and Type	Method and Description
protected BulkOperation	createBulkOperation(BulkOperation.Action action, java.lang.String type, java.lang.String id, java.lang.String source, java.lang.Long version)
java.util.List<BulkOperation>	createBulkOperations(java.lang.Object doc, BulkOperation.Action action) Returns a list of bulk operations to perform, which may include operations that affect different indexes.
java.util.function.Function<T,java.time.ZonedDateTime>	getDeleteVersion() Returns the date that we should use as delete version passed to Elastic.
abstract java.lang.Class<T>	getDocumentClass()
abstract ElasticDocBuilder	getElasticDocBuilder()
java.util.function.Function<T,java.lang.String>	getElasticDocument()
abstract java.util.function.Function<T,java.lang.String>	getId()
abstract Index	getIndex()
java.util.function.Function<T,java.lang.String>	getJson()
java.util.function.Predicate<T>	getPredicate()
java.util.function.Function<T,java.lang.String>	getType()
abstract java.util.function.Function<T,java.time.ZonedDateTime>	getVersion() Returns the date that we should use as index version passed to Elastic.
boolean	supports(java.lang.Object document) Returns true if this factory supports the given document.

Methods inherited from class java.lang.Object

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

Constructor Detail

SimpleBulkOperationFactory

public SimpleBulkOperationFactory()

Method Detail

createBulkOperations

public java.util.List<BulkOperation> createBulkOperations(java.lang.Object doc,
                                                          BulkOperation.Action action)
                                                   throws java.io.IOException

Description copied from interface: BulkOperationFactory

Returns a list of bulk operations to perform, which may include operations that affect different indexes.

Specified by:

createBulkOperations in interface BulkOperationFactory

Parameters:

doc - document

action - action to perform

Returns:

a list of bulk operations to perform

Throws:

java.io.IOException - if there is an error creating bulk operations from the given document

getDeleteVersion

@Value.Default
public java.util.function.Function<T,java.time.ZonedDateTime> getDeleteVersion()

Returns the date that we should use as delete version passed to Elastic.

Returns:

date that we should use as delete version

getDocumentClass

public abstract java.lang.Class<T> getDocumentClass()

getElasticDocBuilder

public abstract ElasticDocBuilder getElasticDocBuilder()

getElasticDocument

@Value.Default
public java.util.function.Function<T,java.lang.String> getElasticDocument()

getId

public abstract java.util.function.Function<T,java.lang.String> getId()

getIndex

public abstract Index getIndex()

getJson

@Value.Default
public java.util.function.Function<T,java.lang.String> getJson()

getPredicate

@Value.Default
public java.util.function.Predicate<T> getPredicate()

getType

@Value.Default
public java.util.function.Function<T,java.lang.String> getType()

getVersion

public abstract java.util.function.Function<T,java.time.ZonedDateTime> getVersion()

Returns the date that we should use as index version passed to Elastic.

Returns:

date that we should use as index version

supports

public boolean supports(java.lang.Object document)

Description copied from interface: BulkOperationFactory

Returns true if this factory supports the given document.

Specified by:

supports in interface BulkOperationFactory

Parameters:

document - document to be indexed

Returns:

true if this factory supports the given document

createBulkOperation

protected BulkOperation createBulkOperation(BulkOperation.Action action,
                                            java.lang.String type,
                                            java.lang.String id,
                                            java.lang.String source,
                                            java.lang.Long version)