org.apache.storm.eventhubs.trident

Interface ITridentPartitionManager

All Known Implementing Classes:

TridentPartitionManager

public interface ITridentPartitionManager

Method Summary

Modifier and Type	Method and Description
void	close()
boolean	open(String offset)
List<EventDataWrap>	receiveBatch(String offset, int count) receive a batch of messages from EvenHub up to “count” messages.

Method Detail

open

boolean open(String offset)

close

void close()

receiveBatch

List<EventDataWrap> receiveBatch(String offset,
                                 int count)

receive a batch of messages from EvenHub up to “count” messages.

Parameters:

offset - the starting offset

count - max number of messages in this batch

Returns:

list of EventData, if failed to receive, return empty list