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

Class BJoinStudentExample

java.lang.Object

edu.iu.dsc.tws.examples.comms.KeyedBenchWorker

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

All Implemented Interfaces:

Twister2Worker

public class BJoinStudentExample
extends KeyedBenchWorker

This example join performs a join between two tables, 1 : | Student ID | Name | and 2 : | Student ID | Course ID |. The result will produce a joined (inner join) result of | Student ID | Name | Course ID |

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	BJoinStudentExample.JoinReceiver 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
protected class	BJoinStudentExample.MapWorker This class is responsible of generating and sending the message to the join operation, This is essentially the source task for this join example.

Field Summary

Fields inherited from class edu.iu.dsc.tws.examples.comms.KeyedBenchWorker

experimentData, finishedSources, inputDataArray, jobParameters, logicalPlan, resultsRecorder, sourcesDone, workerId

Constructor Summary

Constructors

Constructor and Description
BJoinStudentExample()

Method Summary

Modifier and Type	Method and Description
void	close()
protected void	compute(WorkerEnvironment workerEnv)
protected void	finishCommunication(int src)
protected boolean	isDone()
protected boolean	progressCommunication()
protected boolean	sendMessages(int task, java.lang.Object key, java.lang.Object data, int flag)
protected boolean	sendMessages(int task, java.lang.Object key, java.lang.Object data, int flag, int tag) Messages that are sent to the join operation are sent to the communication layer

Methods inherited from class edu.iu.dsc.tws.examples.comms.KeyedBenchWorker

execute, progress, verifyResults

Methods inherited from class java.lang.Object

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

Constructor Detail

BJoinStudentExample

public BJoinStudentExample()

Method Detail

compute

protected void compute(WorkerEnvironment workerEnv)

Specified by:

compute in class KeyedBenchWorker

sendMessages

protected boolean sendMessages(int task,
                               java.lang.Object key,
                               java.lang.Object data,
                               int flag,
                               int tag)

Messages that are sent to the join operation are sent to the communication layer

Parameters:

task - task id

key - the key of the message

data - the data for this message

flag - flag that holds indicators such as SYNC_EMPTY

tag - Specifies which partition of the join this message belongs to

Returns:

true, this method will wait till the message is accepted by the communication layer

close

public void close()

Overrides:

close in class KeyedBenchWorker

progressCommunication

protected boolean progressCommunication()

Specified by:

progressCommunication in class KeyedBenchWorker

isDone

protected boolean isDone()

Specified by:

isDone in class KeyedBenchWorker

sendMessages

protected boolean sendMessages(int task,
                               java.lang.Object key,
                               java.lang.Object data,
                               int flag)

Specified by:

sendMessages in class KeyedBenchWorker

finishCommunication

protected void finishCommunication(int src)

Overrides:

finishCommunication in class KeyedBenchWorker