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

Class AwsCloudWatchEventListener

java.lang.Object

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

org.apache.polaris.service.events.jsonEventListener.aws.cloudwatch.AwsCloudWatchEventListener

All Implemented Interfaces:

PolarisEventListener

@ApplicationScoped
@Identifier("aws-cloudwatch")
public class AwsCloudWatchEventListener
extends PropertyMapEventListener

Constructor Summary

Constructors

Constructor	Description
AwsCloudWatchEventListener(AwsCloudWatchConfiguration config, Clock clock, PolarisIcebergObjectMapperCustomizer customizer)

Method Summary

Modifier and Type	Method	Description
protected software.amazon.awssdk.services.cloudwatchlogs.CloudWatchLogsAsyncClient	createCloudWatchAsyncClient()
protected void	transformAndSendEvent(HashMap<String,Object> properties)

Methods inherited from class org.apache.polaris.service.events.jsonEventListener.PropertyMapEventListener

onAfterRefreshTable

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

AwsCloudWatchEventListener

@Inject
public AwsCloudWatchEventListener(AwsCloudWatchConfiguration config,
 Clock clock,
 PolarisIcebergObjectMapperCustomizer customizer)

Method Details

createCloudWatchAsyncClient

protected software.amazon.awssdk.services.cloudwatchlogs.CloudWatchLogsAsyncClient createCloudWatchAsyncClient()

transformAndSendEvent

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

Specified by:

transformAndSendEvent in class PropertyMapEventListener