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 © 2023 The Apache Software Foundation. All rights reserved.