Modifier and Type | Method and Description |
---|---|
NotificationEventResponse |
IMetaStoreClient.getNextNotification(long lastEventId,
int maxEvents,
IMetaStoreClient.NotificationFilter filter)
Get the next set of notifications from the database.
|
NotificationEventResponse |
HiveMetaStoreClient.getNextNotification(long lastEventId,
int maxEvents,
IMetaStoreClient.NotificationFilter filter) |
Modifier and Type | Method and Description |
---|---|
List<NotificationEvent> |
EventUtils.NotificationFetcher.getNextNotificationEvents(long pos,
IMetaStoreClient.NotificationFilter filter) |
List<NotificationEvent> |
EventUtils.MSClientNotificationFetcher.getNextNotificationEvents(long pos,
IMetaStoreClient.NotificationFilter filter) |
Constructor and Description |
---|
NotificationEventIterator(EventUtils.NotificationFetcher nfetcher,
long eventFrom,
int maxEvents,
IMetaStoreClient.NotificationFilter filter) |
Modifier and Type | Class and Description |
---|---|
class |
AndFilter |
class |
BasicFilter |
class |
DatabaseAndTableFilter
Utility function that constructs a notification filter to match a given db name and/or table name.
|
class |
EventBoundaryFilter |
class |
MessageFormatFilter |
Constructor and Description |
---|
AndFilter(IMetaStoreClient.NotificationFilter... filters) |
Modifier and Type | Method and Description |
---|---|
abstract List<HCatNotificationEvent> |
HCatClient.getNextNotification(long lastEventId,
int maxEvents,
IMetaStoreClient.NotificationFilter filter)
Get a list of notifications
|
List<HCatNotificationEvent> |
HCatClientHMSImpl.getNextNotification(long lastEventId,
int maxEvents,
IMetaStoreClient.NotificationFilter filter) |
Constructor and Description |
---|
HCatReplicationTaskIterator(HCatClient hcatClient,
long eventFrom,
int maxEvents,
IMetaStoreClient.NotificationFilter filter) |
Copyright © 2022 The Apache Software Foundation. All rights reserved.