Package org.apache.polaris.service.events.jsonEventListener

Class PropertyMapEventListener

java.lang.Object

org.apache.polaris.service.events.jsonEventListener.PropertyMapEventListener

All Implemented Interfaces:

PolarisEventListener

Direct Known Subclasses:

AwsCloudWatchEventListener

public abstract class PropertyMapEventListener
extends Object
implements PolarisEventListener

This class provides a common framework for transforming Polaris events into a HashMap, which can be used to transform the event further, such as transforming into a JSON string, and send them to various destinations. Concrete implementations should override the {@link#transformAndSendEvent(HashMap)} method to define how the event data should be transformed into a JSON string, transmitted, and/or stored.

Constructor Summary

Constructors

Constructor	Description
PropertyMapEventListener()

Method Summary

Modifier and Type	Method	Description
void	onAfterRefreshTable(IcebergRestCatalogEvents.AfterRefreshTableEvent event)
protected abstract void	transformAndSendEvent(HashMap<String,Object> properties)

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, onAfterCreateCatalog, onAfterCreateCatalogRole, onAfterCreateGenericTable, onAfterCreateNamespace, onAfterCreatePolicy, onAfterCreatePrincipal, onAfterCreatePrincipalRole, onAfterCreateTable, 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, 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

PropertyMapEventListener

public PropertyMapEventListener()

Method Details

transformAndSendEvent

protected abstract void transformAndSendEvent(HashMap<String,Object> properties)

onAfterRefreshTable

public void onAfterRefreshTable(IcebergRestCatalogEvents.AfterRefreshTableEvent event)

Specified by:

onAfterRefreshTable in interface PolarisEventListener