edu.iu.dsc.tws.api.comms

Interface BulkReceiver

All Known Implementing Classes:

BAllGatherExample.FinalSingularReceiver, BBroadcastExample.BCastReceiver, BDirectExample.DirectReceiver, BDJoinExample.JoinReceiver, BDKeyedGatherExample.FinalReduceReceiver, BGatherExample.FinalReduceReceiver, BJoinExample.JoinReceiver, BJoinStudentExample.JoinReceiver, BKeyedGatherExample.FinalReduceReceiver, BKeyedPartitionExample.PartitionReceiver, BKeyedReduceExample.FinalBulkReceiver, BPartitionExample.PartitionReceiver, BroadcastBatchOperation.BcastReceiver, BulkReceiverWrapper, DirectBatchOperation.PartitionReceiver, InputDataStreamer.DirectReceiver, KeyedPartitionBatchOperation.PartitionReceiver, PartitionBatchOperation.PartitionReceiver, PartitionOperation.PartitionReceiver, RecordSave, SAllGatherExample.FinalReduceReceiver, SGatherExample.FinalReduceReceiver, SKeyedGatherExample.GatherBulkReceiver, WordAggregator

public interface BulkReceiver

Receiver for multiple values

Method Summary

Modifier and Type	Method and Description
void	init(Config cfg, java.util.Set<java.lang.Integer> targets) Initialize the receiver
boolean	receive(int target, java.util.Iterator<java.lang.Object> it) Receive to specific target
default boolean	sync(int target, byte[] message) A sync event has occurred

Method Detail

init

void init(Config cfg,
          java.util.Set<java.lang.Integer> targets)

Initialize the receiver

Parameters:

cfg - configuration

targets - expected targets

receive

boolean receive(int target,
                java.util.Iterator<java.lang.Object> it)

Receive to specific target

Parameters:

target - the target

it - iterator with messages

sync

default boolean sync(int target,
                     byte[] message)

A sync event has occurred

Parameters:

target - the target id

Returns:

true if sync event is accepted