public static interface EventUtils.NotificationFetcher
Modifier and Type | Method and Description |
---|---|
int |
getBatchSize() |
long |
getCurrentNotificationEventId() |
long |
getDbNotificationEventsCount(long fromEventId,
String dbName) |
List<NotificationEvent> |
getNextNotificationEvents(long pos,
IMetaStoreClient.NotificationFilter filter) |
int getBatchSize() throws IOException
IOException
long getCurrentNotificationEventId() throws IOException
IOException
long getDbNotificationEventsCount(long fromEventId, String dbName) throws IOException
IOException
List<NotificationEvent> getNextNotificationEvents(long pos, IMetaStoreClient.NotificationFilter filter) throws IOException
IOException
Copyright © 2022 The Apache Software Foundation. All rights reserved.