IEventProcessor.onEvents(PartitionContext context, Iterable<EventData> events) 方法

定义

Called by the processor host when a batch of events has arrived.

This is where the real work of the event processor is done. It is normally called when one or more events have arrived. If the EventProcessorHost instance was set up with an EventProcessorOptions on which setInvokeProcessorAfterReceiveTimeout(true) has been called, then when a receive times out, onEvents will be called with an empty iterable. By default this option is false and receive timeouts do not cause a call to this method.

public void onEvents(PartitionContext context, Iterable<EventData> events)

参数

context
PartitionContext

Information about the partition.

events
Iterable<EventData>

The events to be processed. May be empty.

例外

Exception

to indicate failure.

适用于