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

Class PolarisPersistenceEventListener

java.lang.Object

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

All Implemented Interfaces:

PolarisEventListener

Direct Known Subclasses:

InMemoryBufferEventListener

public abstract class PolarisPersistenceEventListener
extends Object
implements PolarisEventListener

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final record	PolarisPersistenceEventListener.ContextSpecificInformation

Constructor Summary

Constructors

Constructor	Description
PolarisPersistenceEventListener()

Method Summary

Modifier and Type	Method	Description
protected abstract PolarisPersistenceEventListener.ContextSpecificInformation	getContextSpecificInformation()
protected abstract String	getRequestId()
void	onAfterCreateCatalog(CatalogsServiceEvents.AfterCreateCatalogEvent event)
void	onAfterCreateTable(IcebergRestCatalogEvents.AfterCreateTableEvent event)
protected abstract void	processEvent(org.apache.polaris.core.entity.PolarisEvent event)

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

PolarisPersistenceEventListener

public PolarisPersistenceEventListener()

Method Details

onAfterCreateTable

public void onAfterCreateTable(IcebergRestCatalogEvents.AfterCreateTableEvent event)

Specified by:

onAfterCreateTable in interface PolarisEventListener

onAfterCreateCatalog

public void onAfterCreateCatalog(CatalogsServiceEvents.AfterCreateCatalogEvent event)

Specified by:

onAfterCreateCatalog in interface PolarisEventListener

getContextSpecificInformation

protected abstract PolarisPersistenceEventListener.ContextSpecificInformation getContextSpecificInformation()

getRequestId

@Nullable
protected abstract String getRequestId()

processEvent

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