public class PartitionManager extends SimplePartitionManager
committedOffset, config, lastOffset, receiver| Constructor and Description |
|---|
PartitionManager(EventHubSpoutConfig spoutConfig,
String partitionId,
IStateStore stateStore,
IEventHubReceiver receiver) |
| Modifier and Type | Method and Description |
|---|---|
void |
ack(String offset) |
void |
fail(String offset) |
protected String |
getCompletedOffset() |
EventDataWrap |
receive() |
checkpoint, close, getMetricsData, openpublic PartitionManager(EventHubSpoutConfig spoutConfig, String partitionId, IStateStore stateStore, IEventHubReceiver receiver)
public EventDataWrap receive()
receive in interface IPartitionManagerreceive in class SimplePartitionManagerpublic void ack(String offset)
ack in interface IPartitionManagerack in class SimplePartitionManagerpublic void fail(String offset)
fail in interface IPartitionManagerfail in class SimplePartitionManagerprotected String getCompletedOffset()
getCompletedOffset in class SimplePartitionManagerCopyright © 2021 The Apache Software Foundation. All rights reserved.