Package org.apache.ignite.example.streaming

Class DistributedComputeWithReceiverExample.FraudDetectorReceiver

java.lang.Object

org.apache.ignite.example.streaming.DistributedComputeWithReceiverExample.FraudDetectorReceiver

All Implemented Interfaces:

org.apache.ignite.table.DataStreamerReceiver<org.apache.ignite.table.Tuple,Void,org.apache.ignite.table.Tuple>

Enclosing class:

DistributedComputeWithReceiverExample

public static class DistributedComputeWithReceiverExample.FraudDetectorReceiver
extends Object
implements org.apache.ignite.table.DataStreamerReceiver<org.apache.ignite.table.Tuple,Void,org.apache.ignite.table.Tuple>

Receiver that processes transactions and detects potential fraud.

Constructor Summary

Constructors

Constructor	Description
FraudDetectorReceiver()

Method Summary

Modifier and Type	Method	Description
CompletableFuture<List<org.apache.ignite.table.Tuple>>	receive(List<org.apache.ignite.table.Tuple> page, org.apache.ignite.table.DataStreamerReceiverContext ctx, Void arg)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.ignite.table.DataStreamerReceiver

argumentMarshaller, payloadMarshaller, resultMarshaller

Constructor Details

FraudDetectorReceiver

public FraudDetectorReceiver()

Method Details

receive

public CompletableFuture<List<org.apache.ignite.table.Tuple>> receive(List<org.apache.ignite.table.Tuple> page,
 org.apache.ignite.table.DataStreamerReceiverContext ctx,
 Void arg)

Specified by:

receive in interface org.apache.ignite.table.DataStreamerReceiver<org.apache.ignite.table.Tuple,Void,org.apache.ignite.table.Tuple>