com.bigdata.bop.engine

Class BSBundle

java.lang.Object

com.bigdata.bop.engine.BSBundle

All Implemented Interfaces:

Comparable<BSBundle>

public class BSBundle
extends Object
implements Comparable<BSBundle>

An immutable class capturing the evaluation context of an operator against a shard.

Version:

$Id$

Author:

Bryan Thompson

Field Summary

Fields

Modifier and Type	Field and Description
int	bopId
int	shardId

Constructor Summary

Constructors

Constructor and Description
BSBundle(int bopId, int shardId)

Method Summary

Methods

Modifier and Type	Method and Description
int	compareTo(BSBundle o)
boolean	equals(Object o)
int	hashCode()
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Detail

bopId

public final int bopId

shardId

public final int shardId

Constructor Detail

BSBundle

public BSBundle(int bopId,
        int shardId)

Method Detail

toString

public String toString()

Overrides:

toString in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object o)

Overrides:

equals in class Object

compareTo

public int compareTo(BSBundle o)

This orders the BSBundles by reverse bopId and by shardId if the bopId is the same. This order imposes a bias to draw entries with higher bopIds from an ordered collection.

Note: Query plans are assigned bopIds from 0 through N where higher bopIds are assigned to operators that occur later in the query plan. This is not a strict rule, but it is a strong bias. Given that bias and an ordered map, this Comparator will tend to draw from operators that are further along in the query plan. This emphasizes getting results through the pipeline quickly. Whether or not this Comparator has any effect depends on the ChunkedRunningQuery.consumeChunk() method and the backing map over the operator queues. If a hash map is used, then the Comparator is ignored. If a skip list map is used, then the Comparator will influence the manner in which the operator queues are drained.

Specified by:

compareTo in interface Comparable<BSBundle>