Package org.hibernate.search.mapper.orm.automaticindexing.impl

Class AutomaticIndexingQueueEventProcessingPlanImpl

java.lang.Object

org.hibernate.search.mapper.orm.automaticindexing.impl.AutomaticIndexingQueueEventProcessingPlanImpl

All Implemented Interfaces:

AutomaticIndexingQueueEventProcessingPlan

public class AutomaticIndexingQueueEventProcessingPlanImpl
extends Object
implements AutomaticIndexingQueueEventProcessingPlan

Constructor Summary

Constructors

Constructor	Description
AutomaticIndexingQueueEventProcessingPlanImpl(PojoIndexingQueueEventProcessingPlan delegate)

Method Summary

Modifier and Type	Method	Description
void	append(String entityName, String serializedId, PojoIndexingQueueEventPayload payload)	Appends an event to the plan, received from a AutomaticIndexingQueueEventSendingPlan.
CompletableFuture<MultiEntityOperationExecutionReport>	executeAndReport(OperationSubmitter operationSubmitter)	Writes all pending changes to the index now, and clears the plan so that it can be re-used.
Object	toIdentifier(String entityName, String serializedId)	Convert the serialized id to the original identifier.
String	toSerializedId(String entityName, Object identifier)	Convert the identifier to its serialized form.

Methods inherited from class java.lang.Object

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

Constructor Detail

AutomaticIndexingQueueEventProcessingPlanImpl

public AutomaticIndexingQueueEventProcessingPlanImpl(PojoIndexingQueueEventProcessingPlan delegate)

Method Detail

append

public void append(String entityName,
                   String serializedId,
                   PojoIndexingQueueEventPayload payload)

Description copied from interface: AutomaticIndexingQueueEventProcessingPlan

Appends an event to the plan, received from a AutomaticIndexingQueueEventSendingPlan.

Specified by:

append in interface AutomaticIndexingQueueEventProcessingPlan

Parameters:

entityName - The name of the entity type.

serializedId - The serialized entity identifier.

payload - The payload as passed to the sending plan.

See Also:

AutomaticIndexingQueueEventSendingPlan.append(String, Object, String, PojoIndexingQueueEventPayload)

executeAndReport

public CompletableFuture<MultiEntityOperationExecutionReport> executeAndReport(OperationSubmitter operationSubmitter)

Description copied from interface: AutomaticIndexingQueueEventProcessingPlan

Writes all pending changes to the index now, and clears the plan so that it can be re-used.

Specified by:

executeAndReport in interface AutomaticIndexingQueueEventProcessingPlan

Parameters:

operationSubmitter - How to handle request to submit operation when the queue is full.

Returns:

A CompletableFuture that will be completed with an execution report when all the works are complete.

toSerializedId

public String toSerializedId(String entityName,
                             Object identifier)

Description copied from interface: AutomaticIndexingQueueEventProcessingPlan

Convert the identifier to its serialized form. The identifier type must be the one used by the entity having name entityName.

Specified by:

toSerializedId in interface AutomaticIndexingQueueEventProcessingPlan

Parameters:

entityName - The name of the entity.

identifier - The provided identifier.

Returns:

The serialized for of the provided identifier.

toIdentifier

public Object toIdentifier(String entityName,
                           String serializedId)

Description copied from interface: AutomaticIndexingQueueEventProcessingPlan

Convert the serialized id to the original identifier.

Specified by:

toIdentifier in interface AutomaticIndexingQueueEventProcessingPlan

Parameters:

entityName - The name of the entity.

serializedId - The serialized id.

Returns:

The original entity identifier.