| Package | Description |
|---|---|
| be.SIRAPRISE.client |
This package contains all the classes and interfaces that can be useful on the client side of an application involving SIRA_PRISE.
|
| be.SIRAPRISE.client.jsba |
This package contains all the classes and interfaces for the
Java
SIRA_PRISE
Bridging
Architecture, as well as classes that can be used to manipulate catalog objects using the JSBA.
|
| be.SIRAPRISE.typeimplementations |
This package contains the SIRA_PRISE type and operator implementations.
|
| Modifier and Type | Method and Description |
|---|---|
int |
ByAttributesTupleBufferOrderer.compare(TupleBuffer o1,
TupleBuffer o2) |
| Modifier and Type | Method and Description |
|---|---|
static RelationBuffer |
Relations.orderedRelation(MyReadOnlyCollection<TupleBuffer> tupleBufferCollection,
ByAttributesTupleBufferOrderer orderer)
Gets a relationBuffer in which iteration over the tuples will be in-order, according to the ordering operators associated with the types of the given ordering attributes
|
| Constructor and Description |
|---|
Tuple(Heading heading,
TupleBuffer tupleBuffer)
Deprecated.
Creates the Tuple object
|
| Modifier and Type | Method and Description |
|---|---|
static TupleBuffer |
RANGEJOIN_TUPLE_TUPLE_STRING.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.
|
static TupleBuffer |
RANGEINTERSECT_TUPLE_TUPLE_STRING.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 computeRangeIntersectionForSamePartitionTuples. The catch(IntersectionWithEmptyIntervalException e) is to be replaced with a check on the returned collection being empty.
|
static TupleBuffer |
TupleBuffer.fromStream1_0(Heading heading,
java.io.DataInputStream in)
Reads an encoded TupleBuffer from the given Stream
|
TupleBuffer |
Tuple.getTupleBuffer()
Gets tupleBuffer
|
TupleBuffer |
IntersectionWithEmptyIntervalException.getTupleBuffer()
Gets The tupleBuffer that has the empty interval intersection
|
| Modifier and Type | Method and Description |
|---|---|
static java.util.Collection<TupleBuffer> |
RANGEMINUS_TUPLE_TUPLE_STRING.computeDifferenceForSamePartitionTuples(TupleBuffer minuendTuple,
TupleBuffer subtrahendTuple,
MyReadOnlyLinkedHashMap<NameIdentifier,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations,
java.util.Map<NameIdentifier,IntervalTypeImplementation> attributeIntervalTypeImplementations)
Computes the USING difference between two given tuples
|
static java.util.Collection<TupleBuffer> |
RANGEMINUS_TUPLE_TUPLE_STRING.computeDifferenceForSamePartitionTuples(TupleBuffer minuendTuple,
TupleBuffer subtrahendTuple,
MyReadOnlyLinkedHashMap<NameIdentifier,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations,
java.util.Map<NameIdentifier,IntervalTypeImplementation> attributeIntervalTypeImplementations,
java.util.LinkedList<ValueBuffer> wrkArgList)
Computes the USING difference between two given tuples
|
static java.util.Set<TupleBuffer> |
MINUS_RELATION_RELATION.computePlainDifference(java.util.Collection<? extends TupleBuffer> minuend,
java.util.Collection<? extends TupleBuffer> subtrahend)
Method for computing "plain" relational difference between two given collections of tuple buffers
|
static java.util.Set<TupleBuffer> |
INTERSECT_RELATION_RELATION.computePlainIntersection(java.util.Collection<? extends TupleBuffer> r1,
java.util.Collection<? extends TupleBuffer> r2)
Computes the "plain" intersection between two relation values (passed in the form of Collections of TupleBuffers).
|
static java.util.Set<TupleBuffer> |
JOIN_RELATION_RELATION.computePlainJoin(MyReadOnlySet<TupleBuffer> r1,
MyReadOnlySet<TupleBuffer> r2)
Computes the "plain" JOIN between the given relation arguments.
|
static java.util.Set<TupleBuffer> |
JOIN_RELATION_RELATION.computePlainJoin(MyReadOnlySet<TupleBuffer> r1,
MyReadOnlySet<TupleBuffer> r2,
java.util.Set<NameIdentifier> partitioningKeys)
Computes the "plain" JOIN between the given relation arguments.
|
static java.util.Set<TupleBuffer> |
XMINUS_RELATION_RELATION.computePlainSymmetricDifference(java.util.Set<TupleBuffer> r1,
java.util.Set<TupleBuffer> r2)
Computes the "plain" symmetric difference between the given two tuple sets.
|
static java.util.Set<TupleBuffer> |
UNION_RELATION_RELATION.computePlainUnion(java.util.Collection<TupleBuffer> r1,
java.util.Collection<TupleBuffer> r2)
The most stupid way conceivable to compute a relation union of relations that have no interval-typed attributes
|
static java.util.Set<TupleBuffer> |
MINUSUSING_RELATION_RELATION.computeRangeDifferenceAndPack(java.util.Collection<? extends TupleBuffer> minuend,
java.util.Collection<? extends TupleBuffer> subtrahend,
java.util.Set<NameIdentifier> partitioningKeys,
MyReadOnlyLinkedHashMap<NameIdentifier,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations,
java.util.LinkedList<ValueBuffer> wrkArgList,
java.util.Map<NameIdentifier,IntervalTypeImplementation> attributeIntervalTypeImplementations)
Computes the temporal difference on given tuplelists
|
static java.util.Set<TupleBuffer> |
MINUSUSING_RELATION_RELATION.computeRangeDifferenceAndPack(java.util.Collection<? extends TupleBuffer> minuend,
java.util.Collection<? extends TupleBuffer> subtrahend,
java.util.Set<NameIdentifier> partitioningKeys,
MyReadOnlyLinkedHashMap<NameIdentifier,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations,
java.util.Map<NameIdentifier,IntervalTypeImplementation> attributeIntervalTypeImplementations)
Computes the temporal difference on given tuplelists
|
static java.util.Set<TupleBuffer> |
MINUSUSING_RELATION_RELATION.computeRangeDifferenceOnSamePartitionRelations(java.util.Collection<? extends TupleBuffer> minuend,
java.util.Collection<? extends TupleBuffer> subtrahend,
MyReadOnlyLinkedHashMap<NameIdentifier,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations,
java.util.Map<NameIdentifier,IntervalTypeImplementation> attributeIntervalTypeImplementations)
Computes the difference between tuplelists.
|
static java.util.Set<TupleBuffer> |
MINUSUSING_RELATION_RELATION.computeRangeDifferenceOnSamePartitionRelations(java.util.Collection<? extends TupleBuffer> minuend,
java.util.Collection<? extends TupleBuffer> subtrahend,
MyReadOnlyLinkedHashMap<NameIdentifier,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations,
java.util.Map<NameIdentifier,IntervalTypeImplementation> attributeIntervalTypeImplementations,
java.util.LinkedList<ValueBuffer> wrkArgList)
Computes the difference between tuplelists.
|
static java.util.Set<TupleBuffer> |
MINUSUSING_RELATION_RELATION.computeRangeDifferenceOnSamePartitionRelationsAndPack(java.util.Collection<? extends TupleBuffer> minuend,
java.util.Collection<? extends TupleBuffer> subtrahend,
MyReadOnlyLinkedHashMap<NameIdentifier,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations,
java.util.Map<NameIdentifier,IntervalTypeImplementation> attributeIntervalTypeImplementations)
Computes the difference between relations.
|
static java.util.Set<TupleBuffer> |
MINUSUSING_RELATION_RELATION.computeRangeDifferenceOnSamePartitionRelationsAndPack(java.util.Collection<? extends TupleBuffer> minuend,
java.util.Collection<? extends TupleBuffer> subtrahend,
MyReadOnlyLinkedHashMap<NameIdentifier,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations,
java.util.Map<NameIdentifier,IntervalTypeImplementation> attributeIntervalTypeImplementations,
java.util.LinkedList<ValueBuffer> wrkArgList)
Computes the difference between relations.
|
static java.util.Collection<TupleBuffer> |
RANGEINTERSECT_TUPLE_TUPLE_STRING.computeRangeIntersection(TupleBuffer t1,
TupleBuffer t2,
MyReadOnlyLinkedHashMap<NameIdentifier,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations)
Gets the USING...
|
static java.util.Collection<TupleBuffer> |
RANGEINTERSECT_TUPLE_TUPLE_STRING.computeRangeIntersection(TupleBuffer t1,
TupleBuffer t2,
MyReadOnlyLinkedHashMap<NameIdentifier,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations,
java.util.LinkedList<ValueBuffer> wrkArgList)
Gets the USING...
|
static java.util.Set<TupleBuffer> |
INTERSECTUSING_RELATION_RELATION.computeRangeIntersectionAndPack(java.util.Collection<? extends TupleBuffer> r1,
java.util.Collection<? extends TupleBuffer> r2,
java.util.Set<NameIdentifier> partitioningKeys,
MyReadOnlyLinkedHashMap<NameIdentifier,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations,
java.util.LinkedList<ValueBuffer> wrkArgList,
java.util.Map<NameIdentifier,IntervalTypeImplementation> intervalTypedAttributesIntervalTypeImplementations)
Computes the intersection, given the two tuple collections.
|
static java.util.Set<TupleBuffer> |
INTERSECTUSING_RELATION_RELATION.computeRangeIntersectionAndPack(java.util.Collection<? extends TupleBuffer> r1,
java.util.Collection<? extends TupleBuffer> r2,
java.util.Set<NameIdentifier> partitioningKeys,
MyReadOnlyLinkedHashMap<NameIdentifier,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations,
java.util.Map<NameIdentifier,IntervalTypeImplementation> intervalTypedAttributesIntervalTypeImplementations)
Computes the intersection, given the two tuple collections.
|
static java.util.Set<TupleBuffer> |
INTERSECTUSING_RELATION_RELATION.computeRangeIntersectionForSamePartitionRelationsAndPack(java.util.Collection<? extends TupleBuffer> r1,
java.util.Collection<? extends TupleBuffer> r2,
MyReadOnlyLinkedHashMap<NameIdentifier,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations,
java.util.LinkedList<ValueBuffer> wrkArgList,
java.util.Map<NameIdentifier,IntervalTypeImplementation> intervalTypedAttributesIntervalTypeImplementations)
Computes the range intersection of tuple lists whose non-interval-typed attributes are required to have the same value
|
static java.util.Set<TupleBuffer> |
INTERSECTUSING_RELATION_RELATION.computeRangeIntersectionForSamePartitionRelationsAndPack(java.util.Collection<? extends TupleBuffer> r1,
java.util.Collection<? extends TupleBuffer> r2,
MyReadOnlyLinkedHashMap<NameIdentifier,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations,
java.util.Map<NameIdentifier,IntervalTypeImplementation> intervalTypedAttributesIntervalTypeImplementations)
Computes the range intersection of tuple lists whose non-interval-typed attributes are required to have the same value
|
static java.util.Collection<TupleBuffer> |
RANGEINTERSECT_TUPLE_TUPLE_STRING.computeRangeIntersectionForSamePartitionTuples(TupleBuffer t1,
TupleBuffer t2,
MyReadOnlyLinkedHashMap<NameIdentifier,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations)
Gets the USING...
|
static java.util.Collection<TupleBuffer> |
RANGEINTERSECT_TUPLE_TUPLE_STRING.computeRangeIntersectionForSamePartitionTuples(TupleBuffer t1,
TupleBuffer t2,
MyReadOnlyLinkedHashMap<NameIdentifier,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations,
java.util.LinkedList<ValueBuffer> wrkArgList)
Gets the USING...
|
static java.util.Collection<TupleBuffer> |
RANGEJOIN_TUPLE_TUPLE_STRING.computeRangeJoin(TupleBuffer t1,
TupleBuffer t2,
MyReadOnlyLinkedHashMap<NameIdentifier,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations)
Gets the USING...
|
static java.util.Collection<TupleBuffer> |
RANGEJOIN_TUPLE_TUPLE_STRING.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.Set<TupleBuffer> |
JOINUSING_RELATION_RELATION.computeRangeJoinAndPack(java.util.Collection<TupleBuffer> r1,
java.util.Collection<TupleBuffer> r2,
java.util.Set<NameIdentifier> partitioningKeys,
MyReadOnlyLinkedHashMap<NameIdentifier,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations,
java.util.Map<NameIdentifier,IntervalTypeImplementation> intervalTypedAttributesIntervalTypeImplementations)
Computes the "range" JOIN between the given relations.
|
static java.util.Set<TupleBuffer> |
JOINUSING_RELATION_RELATION.computeRangeJoinAndPack(java.util.Collection<TupleBuffer> r1,
java.util.Collection<TupleBuffer> r2,
java.util.Set<NameIdentifier> partitioningKeys,
MyReadOnlyLinkedHashMap<NameIdentifier,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations,
java.util.Map<NameIdentifier,ValueBuffer> wrkAttributeValueMap,
java.util.LinkedList<ValueBuffer> wrkArgList,
java.util.Map<NameIdentifier,IntervalTypeImplementation> intervalTypedAttributesIntervalTypeImplementations)
Computes the "range" JOIN between the given relations.
|
static java.util.Collection<TupleBuffer> |
JOINUSING_RELATION_RELATION.computeRangeJoinForSamePartitionRelationsAndPack(java.util.Collection<TupleBuffer> r1,
java.util.Collection<TupleBuffer> r2,
MyReadOnlyLinkedHashMap<NameIdentifier,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations,
java.util.Map<NameIdentifier,IntervalTypeImplementation> intervalTypedAttributesIntervalTypeImplementations)
Computes the range join of tuple lists whose non-interval-typed attributes are required to have the same value
|
static java.util.Collection<TupleBuffer> |
JOINUSING_RELATION_RELATION.computeRangeJoinForSamePartitionRelationsAndPack(java.util.Collection<TupleBuffer> r1,
java.util.Collection<TupleBuffer> r2,
MyReadOnlyLinkedHashMap<NameIdentifier,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations,
java.util.Map<NameIdentifier,ValueBuffer> wrkAttributeValueMap,
java.util.LinkedList<ValueBuffer> wrkArglist,
java.util.Map<NameIdentifier,IntervalTypeImplementation> intervalTypedAttributesIntervalTypeImplementations)
Computes the range join of tuple lists whose non-interval-typed attributes are required to have the same value
|
static java.util.Collection<TupleBuffer> |
RANGEJOIN_TUPLE_TUPLE_STRING.computeRangeJoinForSamePartitionTuples(TupleBuffer t1,
TupleBuffer t2,
MyReadOnlyLinkedHashMap<NameIdentifier,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations)
Gets the USING...
|
static java.util.Collection<TupleBuffer> |
RANGEJOIN_TUPLE_TUPLE_STRING.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 java.util.Collection<TupleBuffer> |
UNIONUSING_RELATION_RELATION.computeRangeUnionAndPack(java.util.Collection<TupleBuffer> r1,
java.util.Collection<TupleBuffer> r2,
MyReadOnlyLinkedHashMap<NameIdentifier,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations,
java.util.Map<NameIdentifier,IntervalTypeImplementation> intervalTypedAttributesIntervalTypeImplementations,
java.util.Set<NameIdentifier> partitioningKeys)
Computes the interval union of the given tuple sets.
|
static java.util.Collection<TupleBuffer> |
UNIONUSING_RELATION_RELATION.computeRangeUnionAndPack(java.util.Collection<TupleBuffer> r1,
java.util.Collection<TupleBuffer> r2,
MyReadOnlyLinkedHashMap<NameIdentifier,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations,
java.util.Map<NameIdentifier,IntervalTypeImplementation> intervalTypedAttributesIntervalTypeImplementations,
java.util.Set<NameIdentifier> partitioningKeys,
java.util.LinkedList<ValueBuffer> wrkArgList)
Computes the interval union of the given tuple sets.
|
static java.util.Set<TupleBuffer> |
UNIONUSING_RELATION_RELATION.computeRangeUnionForSamePartitionRelationsAndPack(java.util.Collection<? extends TupleBuffer> r1,
java.util.Collection<? extends TupleBuffer> r2,
MyReadOnlyLinkedHashMap<NameIdentifier,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations,
java.util.Map<NameIdentifier,IntervalTypeImplementation> intervalTypedAttributesIntervalTypeImplementations)
Computes the interval union of the given tuple sets.
|
static java.util.Set<TupleBuffer> |
UNIONUSING_RELATION_RELATION.computeRangeUnionForSamePartitionRelationsAndPack(java.util.Collection<? extends TupleBuffer> r1,
java.util.Collection<? extends TupleBuffer> r2,
MyReadOnlyLinkedHashMap<NameIdentifier,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations,
java.util.Map<NameIdentifier,IntervalTypeImplementation> attributeIntervalTypeImplementations,
java.util.LinkedList<ValueBuffer> wrkArgList)
Computes the interval union of the given tuple sets.
|
static java.util.Set<TupleBuffer> |
TCLOSE_RELATION.computeTclose(MyReadOnlyCollection<TupleBuffer> r,
java.util.Map<NameIdentifier,NameIdentifier> closureLeftAttributes,
java.util.Map<NameIdentifier,NameIdentifier> closureRightAttributes)
Computes the closure in a straightforward way.
|
static java.util.Set<TupleBuffer> |
UNPACK_RELATION.computeUnpack(java.util.Collection<TupleBuffer> r1,
MyReadOnlyLinkedHashMap<NameIdentifier,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations,
MyReadOnlyMap<NameIdentifier,IntervalTypeImplementation> intervalTypeImplementations)
The most stupid way conceivable to compute a relation union of relations that have no interval-typed attributes
|
static java.util.Set<TupleBuffer> |
RelationBuffer.fromStream1_0(Heading heading,
java.io.DataInputStream in) |
abstract MyReadOnlyCollection<TupleBuffer> |
TupleCollectionBuffer.getTupleBufferCollection()
Gets the collection of tuple buffers
|
MyReadOnlyCollection<TupleBuffer> |
TupleBagBuffer.getTupleBufferCollection()
Gets the relation value
|
MyReadOnlyCollection<TupleBuffer> |
RelationBuffer.getTupleBufferCollection() |
MyReadOnlySet<TupleBuffer> |
RelationBuffer.getTupleBufferSet()
Gets the relation value
|
static java.util.Set<TupleBuffer> |
PACK_RELATION_STRING.packPartition(java.util.Collection<TupleBuffer> in,
MyReadOnlyLinkedHashMap<NameIdentifier,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations,
java.util.Map<NameIdentifier,IntervalTypeImplementation> attributeIntervalTypeImplementations)
Packs the given collection of tuplebuffers by merging the mergeable tuples.
|
static java.util.Set<TupleBuffer> |
PACK_RELATION_STRING.packPartitionOld(java.util.Collection<TupleBuffer> in,
MyReadOnlyLinkedHashMap<NameIdentifier,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations,
java.util.Map<NameIdentifier,IntervalTypeImplementation> intervalTypedAttributesIntervalTypeImplementations)
Packs the given collection of tuplebuffers by merging the mergeable tuples.
|
static java.util.Map<java.util.Map<java.lang.String,ValueBuffer>,java.util.Collection<TupleBuffer>> |
DbmsRelationImplementation.partition(java.util.Collection<? extends TupleBuffer> r,
java.util.Set<java.lang.String> partitioningKeys)
Deprecated.
|
static java.util.Map<java.util.Map<NameIdentifier,ValueBuffer>,java.util.Collection<TupleBuffer>> |
DbmsRelationImplementation.partitionByIdentifier(java.util.Collection<? extends TupleBuffer> r,
java.util.Set<NameIdentifier> partitioningKeys)
Partitions the given tuplelist into map entries (K,L), where : K = a Map of attribute name/value pairs L = A tupleList K has an entry for each attribute name in the set of join attributes
|
| Modifier and Type | Method and Description |
|---|---|
static boolean |
RANGEMINUS_TUPLE_TUPLE_STRING.computeDifference(TupleBuffer minuendTuple,
TupleBuffer subtrahendTuple,
java.util.Map<java.lang.String,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations,
java.util.Map<java.lang.String,IntervalTypeImplementation> attributeIntervalTypeImplementations,
java.util.LinkedList<ValueBuffer> wrkArgList,
java.util.Set<TupleBuffer> wrkSet1,
java.util.Set<TupleBuffer> wrkSet2)
Deprecated.
- replace with computeDifferenceForSamePartitionTuples
|
static java.util.Collection<TupleBuffer> |
RANGEMINUS_TUPLE_TUPLE_STRING.computeDifferenceForSamePartitionTuples(TupleBuffer minuendTuple,
TupleBuffer subtrahendTuple,
MyReadOnlyLinkedHashMap<NameIdentifier,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations,
java.util.Map<NameIdentifier,IntervalTypeImplementation> attributeIntervalTypeImplementations)
Computes the USING difference between two given tuples
|
static java.util.Collection<TupleBuffer> |
RANGEMINUS_TUPLE_TUPLE_STRING.computeDifferenceForSamePartitionTuples(TupleBuffer minuendTuple,
TupleBuffer subtrahendTuple,
MyReadOnlyLinkedHashMap<NameIdentifier,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations,
java.util.Map<NameIdentifier,IntervalTypeImplementation> attributeIntervalTypeImplementations,
java.util.LinkedList<ValueBuffer> wrkArgList)
Computes the USING difference between two given tuples
|
static java.util.Collection<TupleBuffer> |
RANGEINTERSECT_TUPLE_TUPLE_STRING.computeRangeIntersection(TupleBuffer t1,
TupleBuffer t2,
MyReadOnlyLinkedHashMap<NameIdentifier,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations)
Gets the USING...
|
static java.util.Collection<TupleBuffer> |
RANGEINTERSECT_TUPLE_TUPLE_STRING.computeRangeIntersection(TupleBuffer t1,
TupleBuffer t2,
MyReadOnlyLinkedHashMap<NameIdentifier,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations,
java.util.LinkedList<ValueBuffer> wrkArgList)
Gets the USING...
|
static java.util.Collection<TupleBuffer> |
RANGEINTERSECT_TUPLE_TUPLE_STRING.computeRangeIntersectionForSamePartitionTuples(TupleBuffer t1,
TupleBuffer t2,
MyReadOnlyLinkedHashMap<NameIdentifier,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations)
Gets the USING...
|
static java.util.Collection<TupleBuffer> |
RANGEINTERSECT_TUPLE_TUPLE_STRING.computeRangeIntersectionForSamePartitionTuples(TupleBuffer t1,
TupleBuffer t2,
MyReadOnlyLinkedHashMap<NameIdentifier,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations,
java.util.LinkedList<ValueBuffer> wrkArgList)
Gets the USING...
|
static java.util.Collection<TupleBuffer> |
RANGEJOIN_TUPLE_TUPLE_STRING.computeRangeJoin(TupleBuffer t1,
TupleBuffer t2,
MyReadOnlyLinkedHashMap<NameIdentifier,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations)
Gets the USING...
|
static java.util.Collection<TupleBuffer> |
RANGEJOIN_TUPLE_TUPLE_STRING.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> |
RANGEJOIN_TUPLE_TUPLE_STRING.computeRangeJoinForSamePartitionTuples(TupleBuffer t1,
TupleBuffer t2,
MyReadOnlyLinkedHashMap<NameIdentifier,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations)
Gets the USING...
|
static java.util.Collection<TupleBuffer> |
RANGEJOIN_TUPLE_TUPLE_STRING.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 |
RANGEJOIN_TUPLE_TUPLE_STRING.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.
|
static TupleBuffer |
RANGEINTERSECT_TUPLE_TUPLE_STRING.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 computeRangeIntersectionForSamePartitionTuples. The catch(IntersectionWithEmptyIntervalException e) is to be replaced with a check on the returned collection being empty.
|
boolean |
TupleBuffer.equalsTupleBuffer(TupleBuffer obj)
Tells whether or not this TupleBuffer is equal to another TupleBuffer.
|
static java.lang.String |
Tuple.getPropositionText(java.lang.String predicateText,
TupleBuffer tupleBuffer,
Heading heading)
Creates a textual proposition from a given predicate, given the attribute values held in the TupleBuffer.
|
static void |
TupleBuffer.toStream1_0(TupleBuffer tupleBuffer,
Heading heading,
java.io.DataOutputStream outputStream)
Streams the given tupleBuffer to the given outputStream
|
static java.util.Set<MyReadOnlyMap<NameIdentifier,ValueBuffer>> |
UNPACK_RELATION.unpackTuple(TupleBuffer t,
MyReadOnlyMap<NameIdentifier,IntervalTypeImplementation> intervalTypeImplementations,
MyReadOnlyLinkedHashMap<NameIdentifier,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations) |
| Modifier and Type | Method and Description |
|---|---|
static boolean |
RANGEMINUS_TUPLE_TUPLE_STRING.computeDifference(TupleBuffer minuendTuple,
TupleBuffer subtrahendTuple,
java.util.Map<java.lang.String,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations,
java.util.Map<java.lang.String,IntervalTypeImplementation> attributeIntervalTypeImplementations,
java.util.LinkedList<ValueBuffer> wrkArgList,
java.util.Set<TupleBuffer> wrkSet1,
java.util.Set<TupleBuffer> wrkSet2)
Deprecated.
- replace with computeDifferenceForSamePartitionTuples
|
static boolean |
RANGEMINUS_TUPLE_TUPLE_STRING.computeDifference(TupleBuffer minuendTuple,
TupleBuffer subtrahendTuple,
java.util.Map<java.lang.String,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations,
java.util.Map<java.lang.String,IntervalTypeImplementation> attributeIntervalTypeImplementations,
java.util.LinkedList<ValueBuffer> wrkArgList,
java.util.Set<TupleBuffer> wrkSet1,
java.util.Set<TupleBuffer> wrkSet2)
Deprecated.
- replace with computeDifferenceForSamePartitionTuples
|
static java.util.Set<TupleBuffer> |
MINUS_RELATION_RELATION.computePlainDifference(java.util.Collection<? extends TupleBuffer> minuend,
java.util.Collection<? extends TupleBuffer> subtrahend)
Method for computing "plain" relational difference between two given collections of tuple buffers
|
static java.util.Set<TupleBuffer> |
MINUS_RELATION_RELATION.computePlainDifference(java.util.Collection<? extends TupleBuffer> minuend,
java.util.Collection<? extends TupleBuffer> subtrahend)
Method for computing "plain" relational difference between two given collections of tuple buffers
|
static java.util.Set<TupleBuffer> |
INTERSECT_RELATION_RELATION.computePlainIntersection(java.util.Collection<? extends TupleBuffer> r1,
java.util.Collection<? extends TupleBuffer> r2)
Computes the "plain" intersection between two relation values (passed in the form of Collections of TupleBuffers).
|
static java.util.Set<TupleBuffer> |
INTERSECT_RELATION_RELATION.computePlainIntersection(java.util.Collection<? extends TupleBuffer> r1,
java.util.Collection<? extends TupleBuffer> r2)
Computes the "plain" intersection between two relation values (passed in the form of Collections of TupleBuffers).
|
static java.util.Set<TupleBuffer> |
JOIN_RELATION_RELATION.computePlainJoin(MyReadOnlySet<TupleBuffer> r1,
MyReadOnlySet<TupleBuffer> r2)
Computes the "plain" JOIN between the given relation arguments.
|
static java.util.Set<TupleBuffer> |
JOIN_RELATION_RELATION.computePlainJoin(MyReadOnlySet<TupleBuffer> r1,
MyReadOnlySet<TupleBuffer> r2)
Computes the "plain" JOIN between the given relation arguments.
|
static java.util.Set<TupleBuffer> |
JOIN_RELATION_RELATION.computePlainJoin(MyReadOnlySet<TupleBuffer> r1,
MyReadOnlySet<TupleBuffer> r2,
java.util.Set<NameIdentifier> partitioningKeys)
Computes the "plain" JOIN between the given relation arguments.
|
static java.util.Set<TupleBuffer> |
JOIN_RELATION_RELATION.computePlainJoin(MyReadOnlySet<TupleBuffer> r1,
MyReadOnlySet<TupleBuffer> r2,
java.util.Set<NameIdentifier> partitioningKeys)
Computes the "plain" JOIN between the given relation arguments.
|
static java.util.Set<TupleBuffer> |
XMINUS_RELATION_RELATION.computePlainSymmetricDifference(java.util.Set<TupleBuffer> r1,
java.util.Set<TupleBuffer> r2)
Computes the "plain" symmetric difference between the given two tuple sets.
|
static java.util.Set<TupleBuffer> |
XMINUS_RELATION_RELATION.computePlainSymmetricDifference(java.util.Set<TupleBuffer> r1,
java.util.Set<TupleBuffer> r2)
Computes the "plain" symmetric difference between the given two tuple sets.
|
static java.util.Set<TupleBuffer> |
UNION_RELATION_RELATION.computePlainUnion(java.util.Collection<TupleBuffer> r1,
java.util.Collection<TupleBuffer> r2)
The most stupid way conceivable to compute a relation union of relations that have no interval-typed attributes
|
static java.util.Set<TupleBuffer> |
UNION_RELATION_RELATION.computePlainUnion(java.util.Collection<TupleBuffer> r1,
java.util.Collection<TupleBuffer> r2)
The most stupid way conceivable to compute a relation union of relations that have no interval-typed attributes
|
static java.util.Set<TupleBuffer> |
MINUSUSING_RELATION_RELATION.computeRangeDifferenceAndPack(java.util.Collection<? extends TupleBuffer> minuend,
java.util.Collection<? extends TupleBuffer> subtrahend,
java.util.Set<NameIdentifier> partitioningKeys,
MyReadOnlyLinkedHashMap<NameIdentifier,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations,
java.util.LinkedList<ValueBuffer> wrkArgList,
java.util.Map<NameIdentifier,IntervalTypeImplementation> attributeIntervalTypeImplementations)
Computes the temporal difference on given tuplelists
|
static java.util.Set<TupleBuffer> |
MINUSUSING_RELATION_RELATION.computeRangeDifferenceAndPack(java.util.Collection<? extends TupleBuffer> minuend,
java.util.Collection<? extends TupleBuffer> subtrahend,
java.util.Set<NameIdentifier> partitioningKeys,
MyReadOnlyLinkedHashMap<NameIdentifier,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations,
java.util.LinkedList<ValueBuffer> wrkArgList,
java.util.Map<NameIdentifier,IntervalTypeImplementation> attributeIntervalTypeImplementations)
Computes the temporal difference on given tuplelists
|
static java.util.Set<TupleBuffer> |
MINUSUSING_RELATION_RELATION.computeRangeDifferenceAndPack(java.util.Collection<? extends TupleBuffer> minuend,
java.util.Collection<? extends TupleBuffer> subtrahend,
java.util.Set<NameIdentifier> partitioningKeys,
MyReadOnlyLinkedHashMap<NameIdentifier,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations,
java.util.Map<NameIdentifier,IntervalTypeImplementation> attributeIntervalTypeImplementations)
Computes the temporal difference on given tuplelists
|
static java.util.Set<TupleBuffer> |
MINUSUSING_RELATION_RELATION.computeRangeDifferenceAndPack(java.util.Collection<? extends TupleBuffer> minuend,
java.util.Collection<? extends TupleBuffer> subtrahend,
java.util.Set<NameIdentifier> partitioningKeys,
MyReadOnlyLinkedHashMap<NameIdentifier,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations,
java.util.Map<NameIdentifier,IntervalTypeImplementation> attributeIntervalTypeImplementations)
Computes the temporal difference on given tuplelists
|
static java.util.Set<TupleBuffer> |
MINUSUSING_RELATION_RELATION.computeRangeDifferenceOnSamePartitionRelations(java.util.Collection<? extends TupleBuffer> minuend,
java.util.Collection<? extends TupleBuffer> subtrahend,
MyReadOnlyLinkedHashMap<NameIdentifier,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations,
java.util.Map<NameIdentifier,IntervalTypeImplementation> attributeIntervalTypeImplementations)
Computes the difference between tuplelists.
|
static java.util.Set<TupleBuffer> |
MINUSUSING_RELATION_RELATION.computeRangeDifferenceOnSamePartitionRelations(java.util.Collection<? extends TupleBuffer> minuend,
java.util.Collection<? extends TupleBuffer> subtrahend,
MyReadOnlyLinkedHashMap<NameIdentifier,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations,
java.util.Map<NameIdentifier,IntervalTypeImplementation> attributeIntervalTypeImplementations)
Computes the difference between tuplelists.
|
static java.util.Set<TupleBuffer> |
MINUSUSING_RELATION_RELATION.computeRangeDifferenceOnSamePartitionRelations(java.util.Collection<? extends TupleBuffer> minuend,
java.util.Collection<? extends TupleBuffer> subtrahend,
MyReadOnlyLinkedHashMap<NameIdentifier,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations,
java.util.Map<NameIdentifier,IntervalTypeImplementation> attributeIntervalTypeImplementations,
java.util.LinkedList<ValueBuffer> wrkArgList)
Computes the difference between tuplelists.
|
static java.util.Set<TupleBuffer> |
MINUSUSING_RELATION_RELATION.computeRangeDifferenceOnSamePartitionRelations(java.util.Collection<? extends TupleBuffer> minuend,
java.util.Collection<? extends TupleBuffer> subtrahend,
MyReadOnlyLinkedHashMap<NameIdentifier,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations,
java.util.Map<NameIdentifier,IntervalTypeImplementation> attributeIntervalTypeImplementations,
java.util.LinkedList<ValueBuffer> wrkArgList)
Computes the difference between tuplelists.
|
static java.util.Set<TupleBuffer> |
MINUSUSING_RELATION_RELATION.computeRangeDifferenceOnSamePartitionRelationsAndPack(java.util.Collection<? extends TupleBuffer> minuend,
java.util.Collection<? extends TupleBuffer> subtrahend,
MyReadOnlyLinkedHashMap<NameIdentifier,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations,
java.util.Map<NameIdentifier,IntervalTypeImplementation> attributeIntervalTypeImplementations)
Computes the difference between relations.
|
static java.util.Set<TupleBuffer> |
MINUSUSING_RELATION_RELATION.computeRangeDifferenceOnSamePartitionRelationsAndPack(java.util.Collection<? extends TupleBuffer> minuend,
java.util.Collection<? extends TupleBuffer> subtrahend,
MyReadOnlyLinkedHashMap<NameIdentifier,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations,
java.util.Map<NameIdentifier,IntervalTypeImplementation> attributeIntervalTypeImplementations)
Computes the difference between relations.
|
static java.util.Set<TupleBuffer> |
MINUSUSING_RELATION_RELATION.computeRangeDifferenceOnSamePartitionRelationsAndPack(java.util.Collection<? extends TupleBuffer> minuend,
java.util.Collection<? extends TupleBuffer> subtrahend,
MyReadOnlyLinkedHashMap<NameIdentifier,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations,
java.util.Map<NameIdentifier,IntervalTypeImplementation> attributeIntervalTypeImplementations,
java.util.LinkedList<ValueBuffer> wrkArgList)
Computes the difference between relations.
|
static java.util.Set<TupleBuffer> |
MINUSUSING_RELATION_RELATION.computeRangeDifferenceOnSamePartitionRelationsAndPack(java.util.Collection<? extends TupleBuffer> minuend,
java.util.Collection<? extends TupleBuffer> subtrahend,
MyReadOnlyLinkedHashMap<NameIdentifier,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations,
java.util.Map<NameIdentifier,IntervalTypeImplementation> attributeIntervalTypeImplementations,
java.util.LinkedList<ValueBuffer> wrkArgList)
Computes the difference between relations.
|
static java.util.Set<TupleBuffer> |
INTERSECTUSING_RELATION_RELATION.computeRangeIntersectionAndPack(java.util.Collection<? extends TupleBuffer> r1,
java.util.Collection<? extends TupleBuffer> r2,
java.util.Set<NameIdentifier> partitioningKeys,
MyReadOnlyLinkedHashMap<NameIdentifier,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations,
java.util.LinkedList<ValueBuffer> wrkArgList,
java.util.Map<NameIdentifier,IntervalTypeImplementation> intervalTypedAttributesIntervalTypeImplementations)
Computes the intersection, given the two tuple collections.
|
static java.util.Set<TupleBuffer> |
INTERSECTUSING_RELATION_RELATION.computeRangeIntersectionAndPack(java.util.Collection<? extends TupleBuffer> r1,
java.util.Collection<? extends TupleBuffer> r2,
java.util.Set<NameIdentifier> partitioningKeys,
MyReadOnlyLinkedHashMap<NameIdentifier,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations,
java.util.LinkedList<ValueBuffer> wrkArgList,
java.util.Map<NameIdentifier,IntervalTypeImplementation> intervalTypedAttributesIntervalTypeImplementations)
Computes the intersection, given the two tuple collections.
|
static java.util.Set<TupleBuffer> |
INTERSECTUSING_RELATION_RELATION.computeRangeIntersectionAndPack(java.util.Collection<? extends TupleBuffer> r1,
java.util.Collection<? extends TupleBuffer> r2,
java.util.Set<NameIdentifier> partitioningKeys,
MyReadOnlyLinkedHashMap<NameIdentifier,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations,
java.util.Map<NameIdentifier,IntervalTypeImplementation> intervalTypedAttributesIntervalTypeImplementations)
Computes the intersection, given the two tuple collections.
|
static java.util.Set<TupleBuffer> |
INTERSECTUSING_RELATION_RELATION.computeRangeIntersectionAndPack(java.util.Collection<? extends TupleBuffer> r1,
java.util.Collection<? extends TupleBuffer> r2,
java.util.Set<NameIdentifier> partitioningKeys,
MyReadOnlyLinkedHashMap<NameIdentifier,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations,
java.util.Map<NameIdentifier,IntervalTypeImplementation> intervalTypedAttributesIntervalTypeImplementations)
Computes the intersection, given the two tuple collections.
|
static java.util.Set<TupleBuffer> |
INTERSECTUSING_RELATION_RELATION.computeRangeIntersectionForSamePartitionRelationsAndPack(java.util.Collection<? extends TupleBuffer> r1,
java.util.Collection<? extends TupleBuffer> r2,
MyReadOnlyLinkedHashMap<NameIdentifier,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations,
java.util.LinkedList<ValueBuffer> wrkArgList,
java.util.Map<NameIdentifier,IntervalTypeImplementation> intervalTypedAttributesIntervalTypeImplementations)
Computes the range intersection of tuple lists whose non-interval-typed attributes are required to have the same value
|
static java.util.Set<TupleBuffer> |
INTERSECTUSING_RELATION_RELATION.computeRangeIntersectionForSamePartitionRelationsAndPack(java.util.Collection<? extends TupleBuffer> r1,
java.util.Collection<? extends TupleBuffer> r2,
MyReadOnlyLinkedHashMap<NameIdentifier,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations,
java.util.LinkedList<ValueBuffer> wrkArgList,
java.util.Map<NameIdentifier,IntervalTypeImplementation> intervalTypedAttributesIntervalTypeImplementations)
Computes the range intersection of tuple lists whose non-interval-typed attributes are required to have the same value
|
static java.util.Set<TupleBuffer> |
INTERSECTUSING_RELATION_RELATION.computeRangeIntersectionForSamePartitionRelationsAndPack(java.util.Collection<? extends TupleBuffer> r1,
java.util.Collection<? extends TupleBuffer> r2,
MyReadOnlyLinkedHashMap<NameIdentifier,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations,
java.util.Map<NameIdentifier,IntervalTypeImplementation> intervalTypedAttributesIntervalTypeImplementations)
Computes the range intersection of tuple lists whose non-interval-typed attributes are required to have the same value
|
static java.util.Set<TupleBuffer> |
INTERSECTUSING_RELATION_RELATION.computeRangeIntersectionForSamePartitionRelationsAndPack(java.util.Collection<? extends TupleBuffer> r1,
java.util.Collection<? extends TupleBuffer> r2,
MyReadOnlyLinkedHashMap<NameIdentifier,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations,
java.util.Map<NameIdentifier,IntervalTypeImplementation> intervalTypedAttributesIntervalTypeImplementations)
Computes the range intersection of tuple lists whose non-interval-typed attributes are required to have the same value
|
static java.util.Set<TupleBuffer> |
JOINUSING_RELATION_RELATION.computeRangeJoinAndPack(java.util.Collection<TupleBuffer> r1,
java.util.Collection<TupleBuffer> r2,
java.util.Set<NameIdentifier> partitioningKeys,
MyReadOnlyLinkedHashMap<NameIdentifier,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations,
java.util.Map<NameIdentifier,IntervalTypeImplementation> intervalTypedAttributesIntervalTypeImplementations)
Computes the "range" JOIN between the given relations.
|
static java.util.Set<TupleBuffer> |
JOINUSING_RELATION_RELATION.computeRangeJoinAndPack(java.util.Collection<TupleBuffer> r1,
java.util.Collection<TupleBuffer> r2,
java.util.Set<NameIdentifier> partitioningKeys,
MyReadOnlyLinkedHashMap<NameIdentifier,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations,
java.util.Map<NameIdentifier,IntervalTypeImplementation> intervalTypedAttributesIntervalTypeImplementations)
Computes the "range" JOIN between the given relations.
|
static java.util.Set<TupleBuffer> |
JOINUSING_RELATION_RELATION.computeRangeJoinAndPack(java.util.Collection<TupleBuffer> r1,
java.util.Collection<TupleBuffer> r2,
java.util.Set<NameIdentifier> partitioningKeys,
MyReadOnlyLinkedHashMap<NameIdentifier,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations,
java.util.Map<NameIdentifier,ValueBuffer> wrkAttributeValueMap,
java.util.LinkedList<ValueBuffer> wrkArgList,
java.util.Map<NameIdentifier,IntervalTypeImplementation> intervalTypedAttributesIntervalTypeImplementations)
Computes the "range" JOIN between the given relations.
|
static java.util.Set<TupleBuffer> |
JOINUSING_RELATION_RELATION.computeRangeJoinAndPack(java.util.Collection<TupleBuffer> r1,
java.util.Collection<TupleBuffer> r2,
java.util.Set<NameIdentifier> partitioningKeys,
MyReadOnlyLinkedHashMap<NameIdentifier,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations,
java.util.Map<NameIdentifier,ValueBuffer> wrkAttributeValueMap,
java.util.LinkedList<ValueBuffer> wrkArgList,
java.util.Map<NameIdentifier,IntervalTypeImplementation> intervalTypedAttributesIntervalTypeImplementations)
Computes the "range" JOIN between the given relations.
|
static java.util.Collection<TupleBuffer> |
JOINUSING_RELATION_RELATION.computeRangeJoinForSamePartitionRelationsAndPack(java.util.Collection<TupleBuffer> r1,
java.util.Collection<TupleBuffer> r2,
MyReadOnlyLinkedHashMap<NameIdentifier,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations,
java.util.Map<NameIdentifier,IntervalTypeImplementation> intervalTypedAttributesIntervalTypeImplementations)
Computes the range join of tuple lists whose non-interval-typed attributes are required to have the same value
|
static java.util.Collection<TupleBuffer> |
JOINUSING_RELATION_RELATION.computeRangeJoinForSamePartitionRelationsAndPack(java.util.Collection<TupleBuffer> r1,
java.util.Collection<TupleBuffer> r2,
MyReadOnlyLinkedHashMap<NameIdentifier,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations,
java.util.Map<NameIdentifier,IntervalTypeImplementation> intervalTypedAttributesIntervalTypeImplementations)
Computes the range join of tuple lists whose non-interval-typed attributes are required to have the same value
|
static java.util.Collection<TupleBuffer> |
JOINUSING_RELATION_RELATION.computeRangeJoinForSamePartitionRelationsAndPack(java.util.Collection<TupleBuffer> r1,
java.util.Collection<TupleBuffer> r2,
MyReadOnlyLinkedHashMap<NameIdentifier,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations,
java.util.Map<NameIdentifier,ValueBuffer> wrkAttributeValueMap,
java.util.LinkedList<ValueBuffer> wrkArglist,
java.util.Map<NameIdentifier,IntervalTypeImplementation> intervalTypedAttributesIntervalTypeImplementations)
Computes the range join of tuple lists whose non-interval-typed attributes are required to have the same value
|
static java.util.Collection<TupleBuffer> |
JOINUSING_RELATION_RELATION.computeRangeJoinForSamePartitionRelationsAndPack(java.util.Collection<TupleBuffer> r1,
java.util.Collection<TupleBuffer> r2,
MyReadOnlyLinkedHashMap<NameIdentifier,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations,
java.util.Map<NameIdentifier,ValueBuffer> wrkAttributeValueMap,
java.util.LinkedList<ValueBuffer> wrkArglist,
java.util.Map<NameIdentifier,IntervalTypeImplementation> intervalTypedAttributesIntervalTypeImplementations)
Computes the range join of tuple lists whose non-interval-typed attributes are required to have the same value
|
static java.util.Collection<TupleBuffer> |
UNIONUSING_RELATION_RELATION.computeRangeUnionAndPack(java.util.Collection<TupleBuffer> r1,
java.util.Collection<TupleBuffer> r2,
MyReadOnlyLinkedHashMap<NameIdentifier,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations,
java.util.Map<NameIdentifier,IntervalTypeImplementation> intervalTypedAttributesIntervalTypeImplementations,
java.util.Set<NameIdentifier> partitioningKeys)
Computes the interval union of the given tuple sets.
|
static java.util.Collection<TupleBuffer> |
UNIONUSING_RELATION_RELATION.computeRangeUnionAndPack(java.util.Collection<TupleBuffer> r1,
java.util.Collection<TupleBuffer> r2,
MyReadOnlyLinkedHashMap<NameIdentifier,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations,
java.util.Map<NameIdentifier,IntervalTypeImplementation> intervalTypedAttributesIntervalTypeImplementations,
java.util.Set<NameIdentifier> partitioningKeys)
Computes the interval union of the given tuple sets.
|
static java.util.Collection<TupleBuffer> |
UNIONUSING_RELATION_RELATION.computeRangeUnionAndPack(java.util.Collection<TupleBuffer> r1,
java.util.Collection<TupleBuffer> r2,
MyReadOnlyLinkedHashMap<NameIdentifier,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations,
java.util.Map<NameIdentifier,IntervalTypeImplementation> intervalTypedAttributesIntervalTypeImplementations,
java.util.Set<NameIdentifier> partitioningKeys,
java.util.LinkedList<ValueBuffer> wrkArgList)
Computes the interval union of the given tuple sets.
|
static java.util.Collection<TupleBuffer> |
UNIONUSING_RELATION_RELATION.computeRangeUnionAndPack(java.util.Collection<TupleBuffer> r1,
java.util.Collection<TupleBuffer> r2,
MyReadOnlyLinkedHashMap<NameIdentifier,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations,
java.util.Map<NameIdentifier,IntervalTypeImplementation> intervalTypedAttributesIntervalTypeImplementations,
java.util.Set<NameIdentifier> partitioningKeys,
java.util.LinkedList<ValueBuffer> wrkArgList)
Computes the interval union of the given tuple sets.
|
static java.util.Set<TupleBuffer> |
UNIONUSING_RELATION_RELATION.computeRangeUnionForSamePartitionRelationsAndPack(java.util.Collection<? extends TupleBuffer> r1,
java.util.Collection<? extends TupleBuffer> r2,
MyReadOnlyLinkedHashMap<NameIdentifier,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations,
java.util.Map<NameIdentifier,IntervalTypeImplementation> intervalTypedAttributesIntervalTypeImplementations)
Computes the interval union of the given tuple sets.
|
static java.util.Set<TupleBuffer> |
UNIONUSING_RELATION_RELATION.computeRangeUnionForSamePartitionRelationsAndPack(java.util.Collection<? extends TupleBuffer> r1,
java.util.Collection<? extends TupleBuffer> r2,
MyReadOnlyLinkedHashMap<NameIdentifier,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations,
java.util.Map<NameIdentifier,IntervalTypeImplementation> intervalTypedAttributesIntervalTypeImplementations)
Computes the interval union of the given tuple sets.
|
static java.util.Set<TupleBuffer> |
UNIONUSING_RELATION_RELATION.computeRangeUnionForSamePartitionRelationsAndPack(java.util.Collection<? extends TupleBuffer> r1,
java.util.Collection<? extends TupleBuffer> r2,
MyReadOnlyLinkedHashMap<NameIdentifier,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations,
java.util.Map<NameIdentifier,IntervalTypeImplementation> attributeIntervalTypeImplementations,
java.util.LinkedList<ValueBuffer> wrkArgList)
Computes the interval union of the given tuple sets.
|
static java.util.Set<TupleBuffer> |
UNIONUSING_RELATION_RELATION.computeRangeUnionForSamePartitionRelationsAndPack(java.util.Collection<? extends TupleBuffer> r1,
java.util.Collection<? extends TupleBuffer> r2,
MyReadOnlyLinkedHashMap<NameIdentifier,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations,
java.util.Map<NameIdentifier,IntervalTypeImplementation> attributeIntervalTypeImplementations,
java.util.LinkedList<ValueBuffer> wrkArgList)
Computes the interval union of the given tuple sets.
|
static java.util.Set<TupleBuffer> |
TCLOSE_RELATION.computeTclose(MyReadOnlyCollection<TupleBuffer> r,
java.util.Map<NameIdentifier,NameIdentifier> closureLeftAttributes,
java.util.Map<NameIdentifier,NameIdentifier> closureRightAttributes)
Computes the closure in a straightforward way.
|
static java.util.Set<TupleBuffer> |
UNPACK_RELATION.computeUnpack(java.util.Collection<TupleBuffer> r1,
MyReadOnlyLinkedHashMap<NameIdentifier,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations,
MyReadOnlyMap<NameIdentifier,IntervalTypeImplementation> intervalTypeImplementations)
The most stupid way conceivable to compute a relation union of relations that have no interval-typed attributes
|
static java.util.Set<TupleBuffer> |
PACK_RELATION_STRING.packPartition(java.util.Collection<TupleBuffer> in,
MyReadOnlyLinkedHashMap<NameIdentifier,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations,
java.util.Map<NameIdentifier,IntervalTypeImplementation> attributeIntervalTypeImplementations)
Packs the given collection of tuplebuffers by merging the mergeable tuples.
|
static java.util.Set<TupleBuffer> |
PACK_RELATION_STRING.packPartitionOld(java.util.Collection<TupleBuffer> in,
MyReadOnlyLinkedHashMap<NameIdentifier,java.util.Map<java.lang.String,OperatorImplementation_V0104>> intervalTypedAttributesIntervalOperatorImplementations,
java.util.Map<NameIdentifier,IntervalTypeImplementation> intervalTypedAttributesIntervalTypeImplementations)
Packs the given collection of tuplebuffers by merging the mergeable tuples.
|
static java.util.Map<java.util.Map<java.lang.String,ValueBuffer>,java.util.Collection<TupleBuffer>> |
DbmsRelationImplementation.partition(java.util.Collection<? extends TupleBuffer> r,
java.util.Set<java.lang.String> partitioningKeys)
Deprecated.
|
static java.util.Map<java.util.Map<NameIdentifier,ValueBuffer>,java.util.Collection<TupleBuffer>> |
DbmsRelationImplementation.partitionByIdentifier(java.util.Collection<? extends TupleBuffer> r,
java.util.Set<NameIdentifier> partitioningKeys)
Partitions the given tuplelist into map entries (K,L), where : K = a Map of attribute name/value pairs L = A tupleList K has an entry for each attribute name in the set of join attributes
|
static void |
RelationBuffer.toStream1_0(java.util.Collection<TupleBuffer> tupleBufferCollection,
Heading heading,
java.io.DataOutputStream outputStream)
Writes the given tuple buffer collection to the given Stream
|
| Constructor and Description |
|---|
Tuple(Heading heading,
TupleBuffer tupleBuffer)
Creates the Tuple object
|
| Constructor and Description |
|---|
RelationBuffer(java.util.Collection<TupleBuffer> tupleBuffers)
Creates the RelationBuffer
|
RelationBuffer(java.util.Collection<TupleBuffer> tupleBuffers,
boolean setReferenceLocal)
Creates the RelationBuffer
|
RelationBuffer(java.util.Set<TupleBuffer> tupleBuffers)
Creates the buffer and sets its value
|
RelationBuffer(java.util.Set<TupleBuffer> tupleBuffers,
boolean setReferenceLocal)
Creates the buffer and sets its value
|
TupleBagBuffer(java.util.Collection<TupleBuffer> tupleBuffers)
Creates the buffer and sets its value
|
TupleBagBuffer(java.util.Collection<TupleBuffer> tupleBuffers,
boolean setReferenceLocal)
Creates the buffer and sets its value
|