Package org.apache.nemo.examples.beam

Class MultinomialLogisticRegression.CombineFunction

  • All Implemented Interfaces:
    java.io.Serializable, org.apache.beam.sdk.transforms.CombineFnBase.GlobalCombineFn<java.util.List<java.lang.Double>,​org.apache.beam.sdk.transforms.Combine.Holder<java.util.List<java.lang.Double>>,​java.util.List<java.lang.Double>>, org.apache.beam.sdk.transforms.display.HasDisplayData
    Enclosing class:
    MultinomialLogisticRegression
    public static final class MultinomialLogisticRegression.CombineFunction
extends org.apache.beam.sdk.transforms.Combine.BinaryCombineFn<java.util.List<java.lang.Double>>
    Combine Function for two Double arrays.
    See Also:
    Serialized Form

    • Constructor Summary

      Constructors 
      Constructor Description
      CombineFunction()  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      java.util.List<java.lang.Double> apply​(java.util.List<java.lang.Double> left, java.util.List<java.lang.Double> right)  
      java.lang.reflect.TypeVariable<?> getAccumTVariable()  
      java.lang.String getIncompatibleGlobalWindowErrorMessage()  
      java.lang.reflect.TypeVariable<?> getInputTVariable()  
      java.lang.reflect.TypeVariable<?> getOutputTVariable()  
      void populateDisplayData​(org.apache.beam.sdk.transforms.display.DisplayData.Builder arg0)  

      • Methods inherited from class org.apache.beam.sdk.transforms.Combine.BinaryCombineFn

        addInput, createAccumulator, extractOutput, getAccumulatorCoder, getDefaultOutputCoder, identity, mergeAccumulators, of

      • Methods inherited from class org.apache.beam.sdk.transforms.Combine.CombineFn

        apply, compact, defaultValue, getInputType, getOutputType

      • Methods inherited from class java.lang.Object

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

    • Constructor Detail

      • CombineFunction

        public CombineFunction()

    • Method Detail

      • apply

        public java.util.List<java.lang.Double> apply​(java.util.List<java.lang.Double> left,
                                              java.util.List<java.lang.Double> right)
        Specified by:
        apply in class org.apache.beam.sdk.transforms.Combine.BinaryCombineFn<java.util.List<java.lang.Double>>

      • getIncompatibleGlobalWindowErrorMessage

        public java.lang.String getIncompatibleGlobalWindowErrorMessage()
        Specified by:
        getIncompatibleGlobalWindowErrorMessage in interface org.apache.beam.sdk.transforms.CombineFnBase.GlobalCombineFn<InputT extends java.lang.Object,​AccumT extends java.lang.Object,​OutputT extends java.lang.Object>

      • getInputTVariable

        public java.lang.reflect.TypeVariable<?> getInputTVariable()

      • getAccumTVariable

        public java.lang.reflect.TypeVariable<?> getAccumTVariable()

      • getOutputTVariable

        public java.lang.reflect.TypeVariable<?> getOutputTVariable()

      • populateDisplayData

        public void populateDisplayData​(org.apache.beam.sdk.transforms.display.DisplayData.Builder arg0)
        Specified by:
        populateDisplayData in interface org.apache.beam.sdk.transforms.display.HasDisplayData