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() |
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 List<NotificationEvent> getNextNotificationEvents(long pos, IMetaStoreClient.NotificationFilter filter) throws IOException
getNextNotificationEvents
in interface EventUtils.NotificationFetcher
IOException
Copyright © 2021 The Apache Software Foundation. All rights reserved.