| Package | Description |
|---|---|
| org.apache.storm.eventhubs.spout | |
| org.apache.storm.eventhubs.trident |
| Modifier and Type | Method and Description |
|---|---|
static EventDataWrap |
EventDataWrap.create(com.microsoft.azure.eventhubs.EventData eventData,
MessageId messageId) |
EventDataWrap |
IPartitionManager.receive() |
EventDataWrap |
SimplePartitionManager.receive() |
EventDataWrap |
IEventHubReceiver.receive() |
EventDataWrap |
EventHubReceiverImpl.receive() |
EventDataWrap |
PartitionManager.receive() |
| Modifier and Type | Method and Description |
|---|---|
int |
EventDataWrap.compareTo(EventDataWrap ed) |
| Modifier and Type | Method and Description |
|---|---|
List<EventDataWrap> |
TridentPartitionManager.receiveBatch(String offset,
int count) |
List<EventDataWrap> |
ITridentPartitionManager.receiveBatch(String offset,
int count)
receive a batch of messages from EvenHub up to “count” messages.
|
Copyright © 2021 The Apache Software Foundation. All rights reserved.