Package org.apache.nemo.compiler.frontend.beam.transform

Class LoopCompositeTransform<inputT extends org.apache.beam.sdk.values.PInput,​outputT extends org.apache.beam.sdk.values.POutput>

  • Type Parameters:
    inputT - input type of the composite transform.
    outputT - output type of the composite transform.
    All Implemented Interfaces:
    java.io.Serializable, org.apache.beam.sdk.transforms.display.HasDisplayData
    Direct Known Subclasses:
    AlternatingLeastSquare.UpdateUserAndItemMatrix, AlternatingLeastSquareInefficient.UpdateUserAndItemMatrix, MultinomialLogisticRegression.UpdateModel
    public abstract class LoopCompositeTransform<inputT extends org.apache.beam.sdk.values.PInput,​outputT extends org.apache.beam.sdk.values.POutput>
extends org.apache.beam.sdk.transforms.PTransform<inputT,​outputT>
implements java.io.Serializable
    A composite transform for wrapping transforms inside a loop to create loop operators in the IR. Each iterations are stateless, as the repeating iterations are zipped into a single copy. We assume a single LoopCompositeTransform inside a for/while loop.
    See Also:
    Serialized Form

    • Field Summary

      • Fields inherited from class org.apache.beam.sdk.transforms.PTransform

        name

    • Method Summary

      • Methods inherited from class org.apache.beam.sdk.transforms.PTransform

        compose, compose, expand, getAdditionalInputs, getDefaultOutputCoder, getDefaultOutputCoder, getDefaultOutputCoder, getKindString, getName, populateDisplayData, toString, validate

      • Methods inherited from class java.lang.Object

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

    • Constructor Detail

      • LoopCompositeTransform

        public LoopCompositeTransform()