Package nz.org.riskscape.engine.join

Class DefaultJoiner

java.lang.Object
nz.org.riskscape.engine.join.DefaultJoiner
All Implemented Interfaces:
AutoCloseable, nz.org.riskscape.engine.join.LopsidedJoiner<JoinIndexer>, nz.org.riskscape.engine.pipeline.Realized
public class DefaultJoiner extends Object implements nz.org.riskscape.engine.join.LopsidedJoiner<JoinIndexer>

  • Field Summary

    Fields inherited from interface nz.org.riskscape.engine.join.LopsidedJoiner

    LHS_STEP_INDEX, RHS_STEP_INDEX

  • Constructor Summary

    Constructors
    Constructor
    Description
    DefaultJoiner(nz.org.riskscape.engine.join.Join join, List<JoinIndexer.Constructor> indexConstructors, nz.org.riskscape.engine.rl.ExpressionRealizer expressionRealizer, Optional<Integer> initalIndexSize)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    addToRhsIndex(nz.org.riskscape.engine.Tuple rhs, JoinIndexer index)
     
    JoinIndexer
    createRhsIndex()
     
    nz.org.riskscape.engine.types.Struct
    getLhs()
     
    nz.org.riskscape.engine.types.Struct
    getProducedType()
     
    nz.org.riskscape.engine.types.Struct
    getRhs()
     
    nz.org.riskscape.engine.relation.TupleIterator
    join(JoinIndexer index, nz.org.riskscape.engine.Tuple lhs)
     

    Methods inherited from class java.lang.Object

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

    Methods inherited from interface nz.org.riskscape.engine.join.LopsidedJoiner

    getJoinedType

    Methods inherited from interface nz.org.riskscape.engine.pipeline.Realized

    close

  • Constructor Details

    • DefaultJoiner

      public DefaultJoiner(nz.org.riskscape.engine.join.Join join, List<JoinIndexer.Constructor> indexConstructors, nz.org.riskscape.engine.rl.ExpressionRealizer expressionRealizer, Optional<Integer> initalIndexSize)

  • Method Details

    • getLhs

      public nz.org.riskscape.engine.types.Struct getLhs()
      Specified by:
      getLhs in interface nz.org.riskscape.engine.join.LopsidedJoiner<JoinIndexer>

    • getRhs

      public nz.org.riskscape.engine.types.Struct getRhs()
      Specified by:
      getRhs in interface nz.org.riskscape.engine.join.LopsidedJoiner<JoinIndexer>

    • getProducedType

      public nz.org.riskscape.engine.types.Struct getProducedType()
      Specified by:
      getProducedType in interface nz.org.riskscape.engine.join.LopsidedJoiner<JoinIndexer>
      Specified by:
      getProducedType in interface nz.org.riskscape.engine.pipeline.Realized

    • createRhsIndex

      public JoinIndexer createRhsIndex()
      Specified by:
      createRhsIndex in interface nz.org.riskscape.engine.join.LopsidedJoiner<JoinIndexer>

    • addToRhsIndex

      public void addToRhsIndex(nz.org.riskscape.engine.Tuple rhs, JoinIndexer index)
      Specified by:
      addToRhsIndex in interface nz.org.riskscape.engine.join.LopsidedJoiner<JoinIndexer>

    • join

      public nz.org.riskscape.engine.relation.TupleIterator join(JoinIndexer index, nz.org.riskscape.engine.Tuple lhs)
      Specified by:
      join in interface nz.org.riskscape.engine.join.LopsidedJoiner<JoinIndexer>