Package ca.uqac.lif.cep.tuples

Class JoinSet

java.lang.Object
ca.uqac.lif.cep.functions.Function
ca.uqac.lif.cep.functions.UnaryFunction<Set,Set>
ca.uqac.lif.cep.tuples.JoinSet
All Implemented Interfaces:
ca.uqac.lif.cep.Duplicable, ca.uqac.lif.cep.functions.DuplicableFunction
public class JoinSet extends ca.uqac.lif.cep.functions.UnaryFunction<Set,Set>
Merges all tuples in a set with the same value for a given attribute. This function accepts as its input a multiset of tuples, and outputs another multiset of tuples.
Author:
Sylvain Hallé

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    protected String
    m_joinAttribute
    The attribute over which to perform the join

    Fields inherited from class ca.uqac.lif.cep.functions.Function

    s_maxInputArity

  • Constructor Summary

    Constructors
    Constructor
    Description
    JoinSet(String join_attribute)
    Creates a new join set function

  • Method Summary

    Modifier and Type
    Method
    Description
    JoinSet
    duplicate(boolean with_state)
     
    Set<?>
    getValue(Set x)
     

    Methods inherited from class ca.uqac.lif.cep.functions.UnaryFunction

    evaluate, getInputArity, getInputTypesFor, getOutputArity, getOutputTypeFor, reset

    Methods inherited from class ca.uqac.lif.cep.functions.Function

    duplicate, evaluate, evaluate, evaluateLazy, evaluatePartial, printState, readState

    Methods inherited from class java.lang.Object

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

  • Field Details

    • m_joinAttribute

      protected String m_joinAttribute
      The attribute over which to perform the join

  • Constructor Details

    • JoinSet

      public JoinSet(String join_attribute)
      Creates a new join set function
      Parameters:
      join_attribute - The attribute over which to perform the join. All tuples in the input set with the same value for that attribute will be merged into a single tuple.

  • Method Details

    • getValue

      public Set<?> getValue(Set x)
      Specified by:
      getValue in class ca.uqac.lif.cep.functions.UnaryFunction<Set,Set>

    • duplicate

      public JoinSet duplicate(boolean with_state)
      Specified by:
      duplicate in interface ca.uqac.lif.cep.Duplicable
      Overrides:
      duplicate in class ca.uqac.lif.cep.functions.UnaryFunction<Set,Set>