edu.iu.dsc.tws.examples.comms.batch

Class BJoinStudentExample.JoinReceiver

java.lang.Object

edu.iu.dsc.tws.examples.comms.batch.BJoinStudentExample.JoinReceiver

All Implemented Interfaces:

BulkReceiver

Enclosing class:

BJoinStudentExample

public class BJoinStudentExample.JoinReceiver
extends java.lang.Object
implements BulkReceiver

The final result receiver class, it will get an iterator object which contains the key and value pairs of each result from the join operation

Constructor Summary

Constructors

Constructor and Description
JoinReceiver()

Method Summary

Modifier and Type	Method and Description
void	init(Config cfg, java.util.Set<java.lang.Integer> expectedIds) Initialize the receiver
boolean	receive(int target, java.util.Iterator<java.lang.Object> it) Receive to specific target

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.BulkReceiver

sync

Constructor Detail

JoinReceiver

public JoinReceiver()

Method Detail

init

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

Description copied from interface: BulkReceiver

Initialize the receiver

Specified by:

init in interface BulkReceiver

Parameters:

cfg - configuration

expectedIds - 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