be.SIRAPRISE.ra

Class JOIN

java.lang.Object

be.SIRAPRISE.ra.RelationalOperator

be.SIRAPRISE.ra.JOIN

public abstract class JOIN
extends RelationalOperator

JOIN

Author:

erwin

Constructor Summary

Constructors

Constructor and Description
JOIN()

Method Summary

Modifier and Type	Method and Description
static Relation	computeJoin(Relation relation, Relation joinWith)
static RelationBuffer	computePlainJoin(RelationBuffer relationBuffer, RelationBuffer relationBuffer2)
static RelationBuffer	computeUsingJoin(RelationBuffer relationBuffer, RelationBuffer relationBuffer2, java.util.Set<NameIdentifier> partitioningKeys, MyReadOnlyLinkedHashMap<NameIdentifier,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations)
static Relation	computeUsingJoin(Relation relation, Relation joinWith, java.util.LinkedHashSet<NameIdentifier> usingAttributes)
int	getMaximumArgumentCount() Gets the maximum argument count for this operator.
int	getMinimumArgumentCount() Gets the minimum argument count for this operator.
java.lang.String	getName() Gets the operator name
boolean	isMonoRelationOperator() Checks if the operator takes only one Relation as input
static JOINInvocationResultDetails	validateExpressionDetails(Heading arg1Heading, Heading arg2Heading, java.util.LinkedHashSet<NameIdentifier> usingAttributes, java.lang.String predicate1, java.lang.String predicate2, java.util.Collection<? extends KeyDef> arg1KeySpecifications, java.util.Collection<? extends KeyDef> arg2KeySpecifications)

Methods inherited from class be.SIRAPRISE.ra.RelationalOperator

toString

Methods inherited from class java.lang.Object

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

Constructor Detail

JOIN

public JOIN()

Method Detail

computeJoin

public static Relation computeJoin(Relation relation,
                                   Relation joinWith)
                            throws EvaluationException

Parameters:

relation - A relation to be joined with the other one

joinWith - The other relation, to be joined with the former one

Returns:

the result of joining the two given relations

Throws:

EvaluationException - If the evaluation fails for any reason

computePlainJoin

public static RelationBuffer computePlainJoin(RelationBuffer relationBuffer,
                                              RelationBuffer relationBuffer2)

Parameters:

relationBuffer - A relation to be joined with the other one

relationBuffer2 - The other relation, to be joined with the former one

Returns:

the result of joining the two given relations

computeUsingJoin

public static Relation computeUsingJoin(Relation relation,
                                        Relation joinWith,
                                        java.util.LinkedHashSet<NameIdentifier> usingAttributes)
                                 throws EvaluationException

Parameters:

relation - A relation to be joined with the other one

joinWith - The other relation, to be joined with the former one

usingAttributes - the interval-typed attributes, in-order, that are to be applied in 'USING' mode by the join

Returns:

the result of joining the two given relations

Throws:

EvaluationException - If the evaluation fails for any reason

computeUsingJoin

public static RelationBuffer computeUsingJoin(RelationBuffer relationBuffer,
                                              RelationBuffer relationBuffer2,
                                              java.util.Set<NameIdentifier> partitioningKeys,
                                              MyReadOnlyLinkedHashMap<NameIdentifier,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations)

Parameters:

relationBuffer - A relation to be joined with the other one

relationBuffer2 - The other relation, to be joined with the former one

partitioningKeys - The set of all join attributes that are not to be treated in "range" mode for the computation.

intervalTypedAttributesIntervalOperatorImplementations - The mapping from interval-typed join attribute names to their Interval types, to gain accessibility to the interval operators. The entries are ordered in the packing order for the result.

Returns:

the result of joining the two given relations

validateExpressionDetails

public static JOINInvocationResultDetails validateExpressionDetails(Heading arg1Heading,
                                                                    Heading arg2Heading,
                                                                    java.util.LinkedHashSet<NameIdentifier> usingAttributes,
                                                                    java.lang.String predicate1,
                                                                    java.lang.String predicate2,
                                                                    java.util.Collection<? extends KeyDef> arg1KeySpecifications,
                                                                    java.util.Collection<? extends KeyDef> arg2KeySpecifications)
                                                             throws IncompatibleJoinHeadingsException,
                                                                    AttributeNotIntervalTypedException,
                                                                    JoinUsingAttributeNotCommonBetweenArgumentsException

Parameters:

arg1Heading - A relation to be joined with the other one

arg2Heading - The other relation, to be joined with the former one

usingAttributes - the interval-typed attributes, in-order, that are to be applied in 'USING' mode by the join

predicate1 - The predicate of which the first relation argument is the extension

predicate2 - The predicate of which the second relation argument is the extension

arg1KeySpecifications - The key specifications known to be satisfied by arg1

arg2KeySpecifications - The key specifications known to be satisfied by arg2

Returns:

The technical details about the join invocation

Throws:

IncompatibleJoinHeadingsException - If the two headings are not join-compatible.

AttributeNotIntervalTypedException - If an attribute mentioned in usingAttributes is not interval-typed

JoinUsingAttributeNotCommonBetweenArgumentsException - If an attribute mentioned in the usingAttributes is not an attribute in both arguments

getMaximumArgumentCount

public final int getMaximumArgumentCount()

Description copied from class: RelationalOperator

Gets the maximum argument count for this operator. Note that stuff like rename lists are regarded as an argument as far as this count is concerned

Specified by:

getMaximumArgumentCount in class RelationalOperator

Returns:

the maximum argument count for this operator.

getMinimumArgumentCount

public final int getMinimumArgumentCount()

Description copied from class: RelationalOperator

Gets the minimum argument count for this operator. Note that stuff like rename lists are regarded as an argument as far as this count is concerned

Specified by:

getMinimumArgumentCount in class RelationalOperator

Returns:

the minimum argument count for this operator

getName

public final java.lang.String getName()

Description copied from class: RelationalOperator

Gets the operator name

Specified by:

getName in class RelationalOperator

Returns:

the operator name

isMonoRelationOperator

public final boolean isMonoRelationOperator()

Description copied from class: RelationalOperator

Checks if the operator takes only one Relation as input

Specified by:

isMonoRelationOperator in class RelationalOperator

Returns:

true if the operator takes only one Relation as input