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 -
Method Summary
Modifier and TypeMethodDescriptionprotected io.smallrye.mutiny.operators.multi.processors.UnicastProcessor<org.apache.polaris.core.entity.PolarisEvent> createProcessor(String realmId) protected voidprotected Stringprotected voidonFlushError(String realmId, List<org.apache.polaris.core.entity.PolarisEvent> events, Throwable error) protected voidonProcessorError(String realmId, Throwable error) protected voidprocessEvent(String realmId, org.apache.polaris.core.entity.PolarisEvent event) protected voidprocessEvent(org.apache.polaris.core.entity.PolarisEvent event) voidshutdown()Methods inherited from class org.apache.polaris.service.events.listeners.PolarisPersistenceEventListener
onAfterCreateCatalog, onAfterCreateTableMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods 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:
processEventin classPolarisPersistenceEventListener
-
processEvent
-
getContextSpecificInformation
protected PolarisPersistenceEventListener.ContextSpecificInformation getContextSpecificInformation()- Specified by:
getContextSpecificInformationin classPolarisPersistenceEventListener
-
getRequestId
- Specified by:
getRequestIdin classPolarisPersistenceEventListener
-
shutdown
@PreDestroy public void shutdown() -
createProcessor
protected io.smallrye.mutiny.operators.multi.processors.UnicastProcessor<org.apache.polaris.core.entity.PolarisEvent> createProcessor(String realmId) -
flush
-
onFlushError
-
onProcessorError
-