edu.iu.dsc.tws.comms.dfw.io.join

Class BulkReceiverWrapper

java.lang.Object

edu.iu.dsc.tws.comms.dfw.io.join.BulkReceiverWrapper

All Implemented Interfaces:

BulkReceiver

public class BulkReceiverWrapper
extends java.lang.Object
implements BulkReceiver

Constructor Summary

Constructors

Constructor and Description
BulkReceiverWrapper(JoinBatchCombinedReceiver joinBatchCombinedReceiver, JoinRelation joinRelation)

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
boolean	sync(int target, byte[] message) A sync event has occurred
static BulkReceiverWrapper	wrap(JoinBatchCombinedReceiver joinBatchCombinedReceiver, JoinRelation joinRelation)

Methods inherited from class java.lang.Object

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

Constructor Detail

BulkReceiverWrapper

public BulkReceiverWrapper(JoinBatchCombinedReceiver joinBatchCombinedReceiver,
                           JoinRelation joinRelation)

Method Detail

wrap

public static BulkReceiverWrapper wrap(JoinBatchCombinedReceiver joinBatchCombinedReceiver,
                                       JoinRelation joinRelation)

init

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

Description copied from interface: BulkReceiver

Initialize the receiver

Specified by:

init in interface BulkReceiver

Parameters:

cfg - configuration

targets - expected targets

receive

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

Description copied from interface: BulkReceiver

Receive to specific target

Specified by:

receive in interface BulkReceiver

Parameters:

target - the target

it - iterator with messages

sync

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

Description copied from interface: BulkReceiver

A sync event has occurred

Specified by:

sync in interface BulkReceiver

Parameters:

target - the target id

Returns:

true if sync event is accepted