Package org.apache.polaris.service.events.listeners.inmemory

Class InMemoryBufferEventListener

java.lang.Object

org.apache.polaris.service.events.listeners.PolarisPersistenceEventListener

org.apache.polaris.service.events.listeners.inmemory.InMemoryBufferEventListener

All Implemented Interfaces:

PolarisEventListener

@ApplicationScoped
@Identifier("persistence-in-memory-buffer")
public class InMemoryBufferEventListener
extends PolarisPersistenceEventListener

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected final class	InMemoryBufferEventListener.EventProcessor	Wraps a UnicastProcessor together with its own lock, so that mutual exclusion between onNext (from processEvent(java.lang.String, org.apache.polaris.core.entity.EventEntity)) and onComplete (from eviction or shutdown) does not depend on smallrye-mutiny's internal synchronized on UnicastProcessor.onNext.

Constructor Summary

Constructors

Constructor	Description
InMemoryBufferEventListener()

Method Summary

Modifier and Type	Method	Description
protected InMemoryBufferEventListener.EventProcessor	createProcessor(String realmId)
protected void	flush(String realmId, List<org.apache.polaris.core.entity.EventEntity> events)
protected void	onFlushError(String realmId, List<org.apache.polaris.core.entity.EventEntity> events, Throwable error)
protected void	onProcessorError(String realmId, Throwable error)
protected void	processEvent(String realmId, org.apache.polaris.core.entity.EventEntity event)
void	shutdown()

Methods inherited from class org.apache.polaris.service.events.listeners.PolarisPersistenceEventListener

onEvent

Methods inherited from class java.lang.Object

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

Constructor Details

InMemoryBufferEventListener

public InMemoryBufferEventListener()

Method Details

createProcessor

protected InMemoryBufferEventListener.EventProcessor createProcessor(String realmId)

processEvent

protected void processEvent(String realmId,
 org.apache.polaris.core.entity.EventEntity event)

Specified by:

processEvent in class PolarisPersistenceEventListener

shutdown

@PreDestroy
public void shutdown()

flush

@Retry(maxRetries=5,
       delay=1000L,
       jitter=100L)
@Fallback(fallbackMethod="onFlushError")
protected void flush(String realmId,
 List<org.apache.polaris.core.entity.EventEntity> events)

onFlushError

protected void onFlushError(String realmId,
 List<org.apache.polaris.core.entity.EventEntity> events,
 Throwable error)

onProcessorError

protected void onProcessorError(String realmId,
 Throwable error)