Class MapFunctionAdapter<InputType,​OutputType>

  • All Implemented Interfaces:
    java.io.Serializable, org.apache.spark.api.java.function.Function<InputType,​OutputType>

    public class MapFunctionAdapter<InputType,​OutputType>
    extends java.lang.Object
    implements org.apache.spark.api.java.function.Function<InputType,​OutputType>
    Wraps a Function as a Function.
    See Also:
    Serialized Form
    • Constructor Detail

      • MapFunctionAdapter

        public MapFunctionAdapter​(java.util.function.Function<InputType,​OutputType> function)
    • Method Detail

      • call

        public OutputType call​(InputType dataQuantum)
                        throws java.lang.Exception
        Specified by:
        call in interface org.apache.spark.api.java.function.Function<InputType,​OutputType>
        Throws:
        java.lang.Exception