Interface ReceivePump.IPartitionReceiver
-
- Enclosing class:
- ReceivePump
public static interface ReceivePump.IPartitionReceiver
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description String
getPartitionId()
CompletableFuture<Iterable<EventData>>
receive(int maxBatchSize)
-
-
-
Method Detail
-
getPartitionId
String getPartitionId()
-
receive
CompletableFuture<Iterable<EventData>> receive(int maxBatchSize)
-
-