Package org.apache.ignite.table

Interface DataStreamerReceiver<T,A,R>

Type Parameters:

T - Payload type.

R - Result type.

A - Receiver job argument type.

public interface DataStreamerReceiver<T,A,R>

Data streamer receiver.

Method Summary

Modifier and Type	Method	Description
@Nullable CompletableFuture<List<R>>	receive(List<T> page, DataStreamerReceiverContext ctx, A arg)	Receives an item from the data streamer (see DataStreamerTarget.streamData(Publisher, Function, Function, ReceiverDescriptor, Subscriber, DataStreamerOptions, Object)).

Method Details

receive

@Nullable
@Nullable CompletableFuture<List<R>> receive(List<T> page,
 DataStreamerReceiverContext ctx,
 @Nullable
 A arg)

Receives an item from the data streamer (see DataStreamerTarget.streamData(Publisher, Function, Function, ReceiverDescriptor, Subscriber, DataStreamerOptions, Object)).

The receiver is called for each page (batch) in the data streamer and is responsible for processing the items, updating zero or more tables, and returning a result.

Parameters:

page - Item batch.

ctx - Receiver context.

arg - Additional argument.

Returns:

Future with the result. Null future for synchronous completion.