edu.iu.dsc.tws.executor.comms.batch

Class ReduceBatchOperation.FinalSingularReceiver

java.lang.Object

edu.iu.dsc.tws.executor.comms.batch.ReduceBatchOperation.FinalSingularReceiver

All Implemented Interfaces:

SingularReceiver

Enclosing class:

ReduceBatchOperation

public class ReduceBatchOperation.FinalSingularReceiver
extends java.lang.Object
implements SingularReceiver

Constructor Summary

Constructors

Constructor and Description
FinalSingularReceiver()

Method Summary

Modifier and Type	Method and Description
void	init(Config cfg, java.util.Set<java.lang.Integer> expectedIds) Initialize a receiver
boolean	receive(int target, java.lang.Object object) Receive an object for a target id.
boolean	sync(int target, byte[] message) A sync event has occurred

Methods inherited from class java.lang.Object

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

Constructor Detail

FinalSingularReceiver

public FinalSingularReceiver()

Method Detail

init

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

Description copied from interface: SingularReceiver

Initialize a receiver

Specified by:

init in interface SingularReceiver

Parameters:

cfg - configuration

expectedIds - the target ids

receive

public boolean receive(int target,
                       java.lang.Object object)

Description copied from interface: SingularReceiver

Receive an object for a target id.

Specified by:

receive in interface SingularReceiver

Parameters:

target - target id

object - object

Returns:

true if the receive is accepted

sync

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

Description copied from interface: SingularReceiver

A sync event has occurred

Specified by:

sync in interface SingularReceiver

Parameters:

target - the target id

Returns:

true if sync event is accepted