edu.iu.dsc.tws.executor.comms.streaming

Class PartitionStreamingOperation.PartitionBulkReceiver

java.lang.Object

edu.iu.dsc.tws.executor.comms.streaming.PartitionStreamingOperation.PartitionBulkReceiver

All Implemented Interfaces:

SingularReceiver

Enclosing class:

PartitionStreamingOperation

public class PartitionStreamingOperation.PartitionBulkReceiver
extends java.lang.Object
implements SingularReceiver

Constructor Summary

Constructors

Constructor and Description
PartitionBulkReceiver()

Method Summary

Modifier and Type	Method and Description
void	init(Config cfg, java.util.Set<java.lang.Integer> targets) Initialize a receiver
boolean	receive(int target, java.lang.Object data) Receive an object for a target id.

Methods inherited from class java.lang.Object

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

Methods inherited from interface edu.iu.dsc.tws.api.comms.SingularReceiver

sync

Constructor Detail

PartitionBulkReceiver

public PartitionBulkReceiver()

Method Detail

init

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

Description copied from interface: SingularReceiver

Initialize a receiver

Specified by:

init in interface SingularReceiver

Parameters:

cfg - configuration

targets - the target ids

receive

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

Description copied from interface: SingularReceiver

Receive an object for a target id.

Specified by:

receive in interface SingularReceiver

Parameters:

target - target id

data - object

Returns:

true if the receive is accepted