com.bigdata.bop.join

Class FastRangeCountOp.ChunkTask<E>

java.lang.Object

com.bigdata.bop.join.FastRangeCountOp.ChunkTask<E>

All Implemented Interfaces:

Callable<Void>

Enclosing class:

FastRangeCountOp<E>

protected static class FastRangeCountOp.ChunkTask<E>
extends Object
implements Callable<Void>

Copy the source to the sink.

Field Summary

Fields

Modifier and Type	Field and Description
protected BOpContext<IBindingSet>	context
protected IVariable<?>	countVar The variable that gets bound to the fast range count.
protected FastRangeCountOp<E>	op
protected IPredicate<E>	predicate The source for the elements to be joined.
protected IRelation<E>	relation The relation associated with the predicate operand.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	FastRangeCountOp.ChunkTask(FastRangeCountOp<E> op, BOpContext<IBindingSet> context)

Method Summary

Methods

Modifier and Type	Method and Description
Void	call()
protected long	determineRangeCount(IPredicate<E> pred)

Methods inherited from class java.lang.Object

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

Field Detail

op

protected final FastRangeCountOp<E> op

context

protected final BOpContext<IBindingSet> context

countVar

protected final IVariable<?> countVar

The variable that gets bound to the fast range count.

predicate

protected final IPredicate<E> predicate

The source for the elements to be joined.

relation

protected final IRelation<E> relation

The relation associated with the predicate operand.

Constructor Detail

FastRangeCountOp.ChunkTask

protected FastRangeCountOp.ChunkTask(FastRangeCountOp<E> op,
                          BOpContext<IBindingSet> context)

Method Detail

call

public Void call()
          throws Exception

Specified by:

call in interface Callable<Void>

Throws:

Exception

determineRangeCount

protected long determineRangeCount(IPredicate<E> pred)