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