be.SIRAPRISE.typeimplementations

Class RANGEJOIN_TUPLE_TUPLE_STRING

java.lang.Object

be.SIRAPRISE.typeimplementations.RANGEJOIN_TUPLE_TUPLE_STRING

public abstract class RANGEJOIN_TUPLE_TUPLE_STRING
extends java.lang.Object

Class providing a utility method for calculating relational USING<...> joins between individual tuples. Some future version will hold a full-blown operator implementation for this tuple operator.

Author:

Erwin

Method Summary

Modifier and Type	Method and Description
static java.util.Collection<TupleBuffer>	computeRangeJoin(TupleBuffer t1, TupleBuffer t2, MyReadOnlyLinkedHashMap<NameIdentifier,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations) Gets the USING...
static java.util.Collection<TupleBuffer>	computeRangeJoin(TupleBuffer t1, TupleBuffer t2, MyReadOnlyLinkedHashMap<NameIdentifier,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations, java.util.Map<NameIdentifier,ValueBuffer> wrkAttributeValueMap, java.util.LinkedList<ValueBuffer> wrkArgList) Gets the USING...
static java.util.Collection<TupleBuffer>	computeRangeJoinForSamePartitionTuples(TupleBuffer t1, TupleBuffer t2, MyReadOnlyLinkedHashMap<NameIdentifier,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations) Gets the USING...
static java.util.Collection<TupleBuffer>	computeRangeJoinForSamePartitionTuples(TupleBuffer t1, TupleBuffer t2, MyReadOnlyLinkedHashMap<NameIdentifier,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations, java.util.Map<NameIdentifier,ValueBuffer> wrkAttributeValueMap, java.util.LinkedList<ValueBuffer> wrkArgList) Gets the USING...
static TupleBuffer	computeTupleIntersection(TupleBuffer t1, TupleBuffer t2, java.util.Map<java.lang.String,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations, java.util.LinkedList<ValueBuffer> wrkArgList, java.util.HashMap<java.lang.String,ValueBuffer> workMap) Deprecated. - replace with computeRangeJoinForSamePartitionTuples. The catch(IntersectionWithEmptyIntervalException e) is to be replaced with a check on the returned collection being empty.

Methods inherited from class java.lang.Object

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

Method Detail

computeRangeJoin

public static java.util.Collection<TupleBuffer> computeRangeJoin(TupleBuffer t1,
                                                                 TupleBuffer t2,
                                                                 MyReadOnlyLinkedHashMap<NameIdentifier,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations)

Gets the USING... join between t1 and t2, if it exists (that is, iff all attribute values for the common attributes between t1 and t2 that are not named in intervalTypedAttributesIntervalOperatorImplementations are equal between t1 and t2, and all the other corresponding attribute values between t1 and t2 (which are intervals by definition) OVERLAP.

Parameters:

t1 - The first tuple, to be range-joined with the second

t2 - The second tuple, to be range-joined with the first

intervalTypedAttributesIntervalOperatorImplementations - A map mapping the interval join attribute names to a corresponding collection of interval operators (this collection takes itself the form of a mapping from operator names to interval operator implementations). The map is required to hold at least the IINTERSECT and ISEMPTYINTERVAL implementations for each attribute.

Returns:

A TupleBuffer collection that is either empty or singleton. It is a singleton iff the USING... join between t1 and t2 is a tuple with all interval values for the attributes named in the USING... argument (intervalTypedAttributesIntervalOperatorImplementations) nonempty intervals.

computeRangeJoin

public static java.util.Collection<TupleBuffer> computeRangeJoin(TupleBuffer t1,
                                                                 TupleBuffer t2,
                                                                 MyReadOnlyLinkedHashMap<NameIdentifier,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations,
                                                                 java.util.Map<NameIdentifier,ValueBuffer> wrkAttributeValueMap,
                                                                 java.util.LinkedList<ValueBuffer> wrkArgList)

Gets the USING... join between t1 and t2, if it exists (that is, iff all attribute values for the common attributes between t1 and t2 that are not named in intervalTypedAttributesIntervalOperatorImplementations are equal between t1 and t2, and all the other corresponding attribute values between t1 and t2 (which are intervals by definition) OVERLAP.

Parameters:

t1 - The first tuple, to be range-joined with the second

t2 - The second tuple, to be range-joined with the first

intervalTypedAttributesIntervalOperatorImplementations - A map mapping the interval join attribute names to a corresponding collection of interval operators (this collection takes itself the form of a mapping from operator names to interval operator implementations). The map is required to hold at least the IINTERSECT and ISEMPTYINTERVAL implementations for each attribute.

wrkAttributeValueMap - A working map that can be used for internal tuple building. Avoids the need to allocate new attributeValueMaps inside the method.

wrkArgList - A List object that can be used for parameter passing in internal invocations of other operators. Prevents having to re-allocate new working objects on each invocation.

Returns:

A TupleBuffer collection that is either empty or singleton. It is a singleton iff the USING... join between t1 and t2 is a tuple with all interval values for the attributes named in the USING... argument (intervalTypedAttributesIntervalOperatorImplementations) nonempty intervals.

computeRangeJoinForSamePartitionTuples

public static java.util.Collection<TupleBuffer> computeRangeJoinForSamePartitionTuples(TupleBuffer t1,
                                                                                       TupleBuffer t2,
                                                                                       MyReadOnlyLinkedHashMap<NameIdentifier,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations)

Gets the USING... join between t1 and t2, if it exists (that is, iff all attribute values for the common attributes between t1 and t2 that are not named in intervalTypedAttributesIntervalOperatorImplementations are equal between t1 and t2, and all the other corresponding attribute values between t1 and t2 (which are intervals by definition) OVERLAP.

Parameters:

t1 - The first tuple, to be range-joined with the second

t2 - The second tuple, to be range-joined with the first. t2 is presumed to have equal attribute values to t1 for all attributes not mentioned in the ranges argument (intervalTypedAttributesIntervalOperatorImplementations).

intervalTypedAttributesIntervalOperatorImplementations - A map mapping the interval join attribute names to a corresponding collection of interval operators (this collection takes itself the form of a mapping from operator names to interval operator implementations). The map is required to hold at least the IINTERSECT and ISEMPTYINTERVAL implementations for each attribute.

Returns:

A TupleBuffer collection that is either empty or singleton. It is a singleton iff the USING... join between t1 and t2 is a tuple with all interval values for the attributes named in the USING... argument (intervalTypedAttributesIntervalOperatorImplementations) nonempty intervals.

computeRangeJoinForSamePartitionTuples

public static java.util.Collection<TupleBuffer> computeRangeJoinForSamePartitionTuples(TupleBuffer t1,
                                                                                       TupleBuffer t2,
                                                                                       MyReadOnlyLinkedHashMap<NameIdentifier,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations,
                                                                                       java.util.Map<NameIdentifier,ValueBuffer> wrkAttributeValueMap,
                                                                                       java.util.LinkedList<ValueBuffer> wrkArgList)

Gets the USING... join between t1 and t2, if it exists (that is, iff all attribute values for the common attributes between t1 and t2 that are not named in intervalTypedAttributesIntervalOperatorImplementations are equal between t1 and t2, and all the other corresponding attribute values between t1 and t2 (which are intervals by definition) OVERLAP.

Parameters:

t1 - The first tuple, to be range-joined with the second

t2 - The second tuple, to be range-joined with the first. t2 is presumed to have equal attribute values to t1 for all attributes not mentioned in the ranges argument (intervalTypedAttributesIntervalOperatorImplementations).

intervalTypedAttributesIntervalOperatorImplementations - A map mapping the interval join attribute names to a corresponding collection of interval operators (this collection takes itself the form of a mapping from operator names to interval operator implementations). The map is required to hold at least the IINTERSECT and ISEMPTYINTERVAL implementations for each attribute.

wrkAttributeValueMap - A working map that can be used for internal tuple building. Avoids the need to allocate new attributeValueMaps inside the method.

wrkArgList - A List object that can be used for parameter passing in internal invocations of other operators (IINTERSECT and ISEMPTYINTERVAL). Prevents having to re-allocate new working objects on each invocation.

Returns:

A TupleBuffer collection that is either empty or singleton. It is a singleton iff the USING... join between t1 and t2 is a tuple with all interval values for the attributes named in the USING... argument (intervalTypedAttributesIntervalOperatorImplementations) nonempty intervals.

computeTupleIntersection

@Deprecated
public static TupleBuffer computeTupleIntersection(TupleBuffer t1,
                                                               TupleBuffer t2,
                                                               java.util.Map<java.lang.String,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations,
                                                               java.util.LinkedList<ValueBuffer> wrkArgList,
                                                               java.util.HashMap<java.lang.String,ValueBuffer> workMap)
                                                        throws IntersectionWithEmptyIntervalException

Deprecated. - replace with computeRangeJoinForSamePartitionTuples. The catch(IntersectionWithEmptyIntervalException e) is to be replaced with a check on the returned collection being empty.

Computes the "interval intersection" between the two given tuples over the given set of interval-typed attributes (the ones that are names as a key in intervalTypedAttributesIntervalOperatorImplementations). The precondition for invoking this method is that the two given tuples must, pairwise, hold the same value for all attributes that are not mentioned in intervalTypedAttributesIntervalOperatorImplementations. This precondition is not checked.

Parameters:

t1 - The first tuple, to be intersected with the second

t2 - The second tuple, to be intersected with the first

intervalTypedAttributesIntervalOperatorImplementations - The map holding the Interval OperatorImplementation objects for all of the interval-typed attributes, through which the needed interval operators can be accessed

wrkArgList - A working list that can be used for invoking the interval operators

workMap - A workmap that can be used for placing the intersected atttribute values on when constructing the intersected tuple

Returns:

The tuple that is the "interval intersection" between the given tuples t1 and t2

Throws:

IntersectionWithEmptyIntervalException - If the intersection between the tuples over the given interval-typed attributes yielded an empty interval value.