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 |
---|---|
static IMetaStoreClient.NotificationFilter |
EventUtils.andFilter(IMetaStoreClient.NotificationFilter... filters) |
static IMetaStoreClient.NotificationFilter |
EventUtils.getDbTblNotificationFilter(String dbName,
String tableName)
Utility function that constructs a notification filter to match a given db name and/or table name.
|
static IMetaStoreClient.NotificationFilter |
EventUtils.getEventBoundaryFilter(Long eventFrom,
Long eventTo) |
static IMetaStoreClient.NotificationFilter |
EventUtils.restrictByMessageFormat(String messageFormat) |
Modifier and Type | Method and Description |
---|---|
static IMetaStoreClient.NotificationFilter |
EventUtils.andFilter(IMetaStoreClient.NotificationFilter... filters) |
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 | 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 © 2021 The Apache Software Foundation. All rights reserved.