com.bigdata.relation.rule.eval.pipeline

Interface IJoinMaster

All Superinterfaces:

Remote

All Known Implementing Classes:

DistributedJoinMasterTask, JoinMasterTask, LocalJoinMasterTask

public interface IJoinMaster
extends Remote

Interface exported by the JoinMasterTask.

Version:

$Id$

Author:

Bryan Thompson

Method Summary

Methods

Modifier and Type	Method and Description
IBuffer<ISolution[]>	getSolutionBuffer() A proxy for the buffer on which the last DistributedJoinTask must write its query solutions.
UUID	getUUID() Return a unique identifier for the JoinMasterTask instance.
void	report(JoinStats joinStats) Used to send join stats to the master.

Method Detail

getUUID

UUID getUUID()
             throws IOException

Return a unique identifier for the JoinMasterTask instance. This is used to concentrate all DistributedJoinTask that target the same tail predicate and index partition onto the same DistributedJoinTask sink.

Returns:

The unique identifier.

Throws:

IOException

getSolutionBuffer

IBuffer<ISolution[]> getSolutionBuffer()
                                       throws IOException

A proxy for the buffer on which the last DistributedJoinTask must write its query solutions. Note that mutation operations DO NOT use this buffer in order to avoid sending all data through the master.

Throws:

UnsupportedOperationException - if the operation is not a query.

IOException

report

void report(JoinStats joinStats)
            throws IOException

Used to send join stats to the master.

Throws:

IOException