@InterfaceAudience.Private public class MetaStoreListenerNotifier extends Object
Constructor and Description |
---|
MetaStoreListenerNotifier() |
Modifier and Type | Method and Description |
---|---|
static Map<String,String> |
notifyEvent(List<? extends MetaStoreEventListener> listeners,
EventMessage.EventType eventType,
ListenerEvent event)
Notify a list of listeners about a specific metastore event.
|
static Map<String,String> |
notifyEvent(List<? extends MetaStoreEventListener> listeners,
EventMessage.EventType eventType,
ListenerEvent event,
EnvironmentContext environmentContext)
Notify a list of listeners about a specific metastore event.
|
static Map<String,String> |
notifyEvent(List<? extends MetaStoreEventListener> listeners,
EventMessage.EventType eventType,
ListenerEvent event,
EnvironmentContext environmentContext,
Map<String,String> parameters,
RawStore ms)
Notify a list of listeners about a specific metastore event.
|
static Map<String,String> |
notifyEventWithDirectSql(List<? extends MetaStoreEventListener> listeners,
EventMessage.EventType eventType,
ListenerEvent event,
Connection dbConn,
SQLGenerator sqlGenerator)
Notify a list of listeners about a specific metastore event to be executed within a txn.
|
public static Map<String,String> notifyEvent(List<? extends MetaStoreEventListener> listeners, EventMessage.EventType eventType, ListenerEvent event) throws MetaException
listeners
- List of MetaStoreEventListener listeners.eventType
- Type of the notification event.event
- The ListenerEvent with information about the event.MetaException
- If an error occurred while calling the listeners.public static Map<String,String> notifyEventWithDirectSql(List<? extends MetaStoreEventListener> listeners, EventMessage.EventType eventType, ListenerEvent event, Connection dbConn, SQLGenerator sqlGenerator) throws MetaException
listeners
- List of MetaStoreEventListener listeners.eventType
- Type of the notification event.event
- The ListenerEvent with information about the event.dbConn
- The JDBC connection to the remote meta store db.sqlGenerator
- The helper class to generate db specific SQL string.MetaException
- If an error occurred while calling the listeners.public static Map<String,String> notifyEvent(List<? extends MetaStoreEventListener> listeners, EventMessage.EventType eventType, ListenerEvent event, EnvironmentContext environmentContext) throws MetaException
listeners
- List of MetaStoreEventListener listeners.eventType
- Type of the notification event.event
- The ListenerEvent with information about the event.environmentContext
- An EnvironmentContext object with parameters sent by the HMS client.MetaException
- If an error occurred while calling the listeners.public static Map<String,String> notifyEvent(List<? extends MetaStoreEventListener> listeners, EventMessage.EventType eventType, ListenerEvent event, EnvironmentContext environmentContext, Map<String,String> parameters, RawStore ms) throws MetaException
listeners
- List of MetaStoreEventListener listeners.eventType
- Type of the notification event.event
- The ListenerEvent with information about the event.environmentContext
- An EnvironmentContext object with parameters sent by the HMS client.parameters
- A list of key/value pairs with the new parameters to add.ms
- The RawStore object from where to check if a transaction is active.MetaException
- If an error occurred while calling the listeners.Copyright © 2022 The Apache Software Foundation. All rights reserved.