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/interfaces inherited from class org.apache.polaris.service.events.listeners.PolarisPersistenceEventListener

PolarisPersistenceEventListener.ContextSpecificInformation

Constructor Summary

Constructors

Constructor	Description
InMemoryBufferEventListener()

Method Summary

Modifier and Type	Method	Description
protected io.smallrye.mutiny.operators.multi.processors.UnicastProcessor<org.apache.polaris.core.entity.PolarisEvent>	createProcessor(String realmId)
protected void	flush(String realmId, List<org.apache.polaris.core.entity.PolarisEvent> events)
protected PolarisPersistenceEventListener.ContextSpecificInformation	getContextSpecificInformation()
protected String	getRequestId()
protected void	onFlushError(String realmId, List<org.apache.polaris.core.entity.PolarisEvent> events, Throwable error)
protected void	onProcessorError(String realmId, Throwable error)
protected void	processEvent(String realmId, org.apache.polaris.core.entity.PolarisEvent event)
protected void	processEvent(org.apache.polaris.core.entity.PolarisEvent event)
void	shutdown()

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

onAfterCreateCatalog, onAfterCreateTable

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.polaris.service.events.listeners.PolarisEventListener

onAfterAddGrantToCatalogRole, onAfterAssignCatalogRoleToPrincipalRole, onAfterAssignPrincipalRole, onAfterAttachPolicy, onAfterAttemptTask, onAfterCheckExistsNamespace, onAfterCheckExistsTable, onAfterCheckExistsView, onAfterCommitTable, onAfterCommitTransaction, onAfterCommitView, onAfterCreateCatalogRole, onAfterCreateGenericTable, onAfterCreateNamespace, onAfterCreatePolicy, onAfterCreatePrincipal, onAfterCreatePrincipalRole, onAfterCreateView, onAfterDeleteCatalog, onAfterDeleteCatalogRole, onAfterDeletePrincipal, onAfterDeletePrincipalRole, onAfterDetachPolicy, onAfterDropGenericTable, onAfterDropNamespace, onAfterDropPolicy, onAfterDropTable, onAfterDropView, onAfterGetApplicablePolicies, onAfterGetCatalog, onAfterGetCatalogRole, onAfterGetConfig, onAfterGetPrincipal, onAfterGetPrincipalRole, onAfterListAssignedPrincipalRoles, onAfterListAssigneePrincipalRolesForCatalogRole, onAfterListAssigneePrincipalsForPrincipalRole, onAfterListCatalogRoles, onAfterListCatalogRolesForPrincipalRole, onAfterListCatalogs, onAfterListGenericTables, onAfterListGrantsForCatalogRole, onAfterListNamespaces, onAfterListPolicies, onAfterListPrincipalRoles, onAfterListPrincipals, onAfterListTables, onAfterListViews, onAfterLoadCredentials, onAfterLoadGenericTable, onAfterLoadNamespaceMetadata, onAfterLoadPolicy, onAfterLoadTable, onAfterLoadView, onAfterRefreshTable, onAfterRefreshView, onAfterRegisterTable, onAfterRenameTable, onAfterRenameView, onAfterReplaceView, onAfterResetCredentials, onAfterRevokeCatalogRoleFromPrincipalRole, onAfterRevokeGrantFromCatalogRole, onAfterRevokePrincipalRole, onAfterRotateCredentials, onAfterSendNotification, onAfterUpdateCatalog, onAfterUpdateCatalogRole, onAfterUpdateNamespaceProperties, onAfterUpdatePolicy, onAfterUpdatePrincipal, onAfterUpdatePrincipalRole, onAfterUpdateTable, onBeforeAddGrantToCatalogRole, onBeforeAssignCatalogRoleToPrincipalRole, onBeforeAssignPrincipalRole, onBeforeAttachPolicy, onBeforeAttemptTask, onBeforeCheckExistsNamespace, onBeforeCheckExistsTable, onBeforeCheckExistsView, onBeforeCommitTable, onBeforeCommitTransaction, onBeforeCommitView, onBeforeCreateCatalog, onBeforeCreateCatalogRole, onBeforeCreateGenericTable, onBeforeCreateNamespace, onBeforeCreatePolicy, onBeforeCreatePrincipal, onBeforeCreatePrincipalRole, onBeforeCreateTable, onBeforeCreateView, onBeforeDeleteCatalog, onBeforeDeleteCatalogRole, onBeforeDeletePrincipal, onBeforeDeletePrincipalRole, onBeforeDetachPolicy, onBeforeDropGenericTable, onBeforeDropNamespace, onBeforeDropPolicy, onBeforeDropTable, onBeforeDropView, onBeforeGetApplicablePolicies, onBeforeGetCatalog, onBeforeGetCatalogRole, onBeforeGetConfig, onBeforeGetPrincipal, onBeforeGetPrincipalRole, onBeforeLimitRequestRate, onBeforeListAssignedPrincipalRoles, onBeforeListAssigneePrincipalRolesForCatalogRole, onBeforeListAssigneePrincipalsForPrincipalRole, onBeforeListCatalogRoles, onBeforeListCatalogRolesForPrincipalRole, onBeforeListCatalogs, onBeforeListGenericTables, onBeforeListGrantsForCatalogRole, onBeforeListNamespaces, onBeforeListPolicies, onBeforeListPrincipalRoles, onBeforeListPrincipals, onBeforeListTables, onBeforeListViews, onBeforeLoadCredentials, onBeforeLoadGenericTable, onBeforeLoadNamespaceMetadata, onBeforeLoadPolicy, onBeforeLoadTable, onBeforeLoadView, onBeforeRefreshTable, onBeforeRefreshView, onBeforeRegisterTable, onBeforeRenameTable, onBeforeRenameView, onBeforeReplaceView, onBeforeResetCredentials, onBeforeRevokeCatalogRoleFromPrincipalRole, onBeforeRevokeGrantFromCatalogRole, onBeforeRevokePrincipalRole, onBeforeRotateCredentials, onBeforeSendNotification, onBeforeUpdateCatalog, onBeforeUpdateCatalogRole, onBeforeUpdateNamespaceProperties, onBeforeUpdatePolicy, onBeforeUpdatePrincipal, onBeforeUpdatePrincipalRole, onBeforeUpdateTable

Constructor Details

InMemoryBufferEventListener

public InMemoryBufferEventListener()

Method Details

processEvent

protected void processEvent(org.apache.polaris.core.entity.PolarisEvent event)

Specified by:

processEvent in class PolarisPersistenceEventListener

processEvent

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

getContextSpecificInformation

protected PolarisPersistenceEventListener.ContextSpecificInformation getContextSpecificInformation()

Specified by:

getContextSpecificInformation in class PolarisPersistenceEventListener

getRequestId

@Nullable
protected String getRequestId()

Specified by:

getRequestId in class PolarisPersistenceEventListener

shutdown

@PreDestroy
public void shutdown()

createProcessor

protected io.smallrye.mutiny.operators.multi.processors.UnicastProcessor<org.apache.polaris.core.entity.PolarisEvent> createProcessor(String realmId)

flush

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

onFlushError

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

onProcessorError

protected void onProcessorError(String realmId,
 Throwable error)