com.arakelian.elastic.bulk

Class BulkOperationFactoryRegistry

java.lang.Object

com.arakelian.elastic.bulk.BulkOperationFactoryRegistry

All Implemented Interfaces:

BulkOperationFactory

@Value.Immutable
public abstract class BulkOperationFactoryRegistry
extends java.lang.Object
implements BulkOperationFactory

Constructor Summary

Constructors

Constructor and Description
BulkOperationFactoryRegistry()

Method Summary

Modifier and Type	Method and Description
java.util.List<BulkOperation>	createBulkOperations(java.lang.Object document, BulkOperation.Action action) Returns a list of bulk operations to perform, which may include operations that affect different indexes.
java.util.List<BulkOperationFactory>	getFactories()
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

BulkOperationFactoryRegistry

public BulkOperationFactoryRegistry()

Method Detail

createBulkOperations

public java.util.List<BulkOperation> createBulkOperations(java.lang.Object document,
                                                          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:

document - 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

getFactories

@Value.Default
public java.util.List<BulkOperationFactory> getFactories()

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