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
default @Nullable Marshaller<A,byte[]>	argumentMarshaller()	Marshaller for the input argument.
default @Nullable Marshaller<T,byte[]>	payloadMarshaller()	Marshaller for the receiver payload (batch items).
@Nullable CompletableFuture<List<R>>	receive(List<T> page, DataStreamerReceiverContext ctx, A arg)	Receives an item from the data streamer (see DataStreamerTarget.streamData(Publisher, DataStreamerReceiverDescriptor, Function, Function, Object, Subscriber, DataStreamerOptions)).
default @Nullable Marshaller<R,byte[]>	resultMarshaller()	Marshaller for the job result.

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, DataStreamerReceiverDescriptor, Function, Function, Object, Subscriber, DataStreamerOptions)).

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.

payloadMarshaller

@Nullable
default @Nullable Marshaller<T,byte[]> payloadMarshaller()

Marshaller for the receiver payload (batch items).

Returns:

Payload marshaller.

argumentMarshaller

@Nullable
default @Nullable Marshaller<A,byte[]> argumentMarshaller()

Marshaller for the input argument.

Returns:

Input marshaller.

resultMarshaller

@Nullable
default @Nullable Marshaller<R,byte[]> resultMarshaller()

Marshaller for the job result.

Returns:

Result marshaller.