com.bigdata.relation.rule.eval.pipeline
Class JoinTaskSink

java.lang.Object
  com.bigdata.relation.rule.eval.pipeline.JoinTaskSink

public class JoinTaskSink
extends Object

An object used by a JoinTask to write on another JoinTask providing a sink for a specific index partition.

Version:

$Id: JoinTaskSink.java 6130 2012-03-15 10:31:25Z thompsonbry $

Author:

Bryan Thompson

Field Summary

protected static boolean	DEBUG True iff the log level is DEBUG or less.
protected static boolean	INFO True iff the log level is INFO or less.
protected static org.apache.log4j.Logger	log

Constructor Summary

JoinTaskSink(IBigdataFederation fed, PartitionLocator locator, JoinTask sourceJoinTask)
Setups up the local buffers for a downstream JoinTask.

Method Summary

Future	getFuture() The Future of the downstream JoinTask.
protected void	setFuture(Future f)
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

log

protected static final org.apache.log4j.Logger log

INFO

protected static final boolean INFO

True iff the log level is INFO or less.

DEBUG

protected static final boolean DEBUG

True iff the log level is DEBUG or less.

Constructor Detail

JoinTaskSink

public JoinTaskSink(IBigdataFederation fed,
                    PartitionLocator locator,
                    JoinTask sourceJoinTask)

Setups up the local buffers for a downstream JoinTask.

Note: The caller MUST create the task using a factory pattern on the target data service and assign its future to the returned object using setFuture(Future).

Parameters:

fed - The federation.

locator - The locator for the index partition.

sourceJoinTask - The current join dimension.

Method Detail

getFuture

public Future getFuture()

The Future of the downstream JoinTask. This may be used to cancel or interrupt that JoinTask.

setFuture

protected void setFuture(Future f)

toString

public String toString()

Overrides:

toString in class Object