Package nz.org.riskscape.engine.pipeline

Class LopsidedFlatProjector<T>

java.lang.Object
nz.org.riskscape.engine.pipeline.LopsidedFlatProjector<T>
All Implemented Interfaces:
AutoCloseable, Function<nz.org.riskscape.engine.Tuple,nz.org.riskscape.engine.relation.TupleIterator>, nz.org.riskscape.engine.pipeline.Realized, nz.org.riskscape.engine.projection.FlatProjector
public class LopsidedFlatProjector<T> extends Object implements nz.org.riskscape.engine.projection.FlatProjector

Converts a LopsidedJoiner in to a FlatProjector so that a pipeline can parallelize the lhs

  • Constructor Summary

    Constructors
    Constructor
    Description
    LopsidedFlatProjector(nz.org.riskscape.engine.join.LopsidedJoiner<T> joiner, nz.org.riskscape.engine.relation.TupleIterator rhs)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    nz.org.riskscape.engine.relation.TupleIterator
    apply(nz.org.riskscape.engine.Tuple lhs)
     
    nz.org.riskscape.engine.types.Struct
    getProjectedType()
     
    nz.org.riskscape.engine.types.Struct
    getSourceType()
     

    Methods inherited from class java.lang.Object

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

    Methods inherited from interface java.util.function.Function

    andThen, compose

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

    close

  • Constructor Details

    • LopsidedFlatProjector

      public LopsidedFlatProjector(nz.org.riskscape.engine.join.LopsidedJoiner<T> joiner, nz.org.riskscape.engine.relation.TupleIterator rhs)

  • Method Details

    • getSourceType

      public nz.org.riskscape.engine.types.Struct getSourceType()
      Specified by:
      getSourceType in interface nz.org.riskscape.engine.projection.FlatProjector

    • getProjectedType

      public nz.org.riskscape.engine.types.Struct getProjectedType()
      Specified by:
      getProjectedType in interface nz.org.riskscape.engine.projection.FlatProjector

    • apply

      public nz.org.riskscape.engine.relation.TupleIterator apply(nz.org.riskscape.engine.Tuple lhs)
      Specified by:
      apply in interface nz.org.riskscape.engine.projection.FlatProjector
      Specified by:
      apply in interface Function<nz.org.riskscape.engine.Tuple,nz.org.riskscape.engine.relation.TupleIterator>