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

Class JoinBatchCombinedReceiver

java.lang.Object

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

public class JoinBatchCombinedReceiver
extends java.lang.Object

This class performs the join operation when all the relations are ready

For now, twister2 support only joining two relations. This class is written to support more than two relations in future.

Constructor Summary

Constructors

Constructor and Description
JoinBatchCombinedReceiver(BulkReceiver recvr, CommunicationContext.JoinAlgorithm algorithm, CommunicationContext.JoinType joinType, KeyComparatorWrapper keyComparator, MessageType keyType)

Method Summary

Modifier and Type	Method and Description
void	init(Config cfg, java.util.Set<java.lang.Integer> targets)
boolean	receive(int target, java.lang.Object object, JoinRelation joinRelation)
boolean	sync(int target, byte[] message, JoinRelation joinRelation)

Methods inherited from class java.lang.Object

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

Constructor Detail

JoinBatchCombinedReceiver

public JoinBatchCombinedReceiver(BulkReceiver recvr,
                                 CommunicationContext.JoinAlgorithm algorithm,
                                 CommunicationContext.JoinType joinType,
                                 KeyComparatorWrapper keyComparator,
                                 MessageType keyType)

Method Detail

init

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

receive

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

sync

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