org.apache.sysml.runtime.instructions.spark.utils

Class RDDConverterUtils.DataFrameExtractIDFunction

  • java.lang.Object
    • org.apache.sysml.runtime.instructions.spark.utils.RDDConverterUtils.DataFrameExtractIDFunction
  • All Implemented Interfaces:
    Serializable, org.apache.spark.api.java.function.PairFunction<org.apache.spark.sql.Row,org.apache.spark.sql.Row,Long>
    Enclosing class:
    RDDConverterUtils


    public static class RDDConverterUtils.DataFrameExtractIDFunction
    extends Object
    implements org.apache.spark.api.java.function.PairFunction<org.apache.spark.sql.Row,org.apache.spark.sql.Row,Long>
    See Also:
    Serialized Form
    • Constructor Detail

      • DataFrameExtractIDFunction

        public DataFrameExtractIDFunction(int index)
    • Method Detail

      • call

        public scala.Tuple2<org.apache.spark.sql.Row,Long> call(org.apache.spark.sql.Row arg0)
                                                         throws Exception
        Specified by:
        call in interface org.apache.spark.api.java.function.PairFunction<org.apache.spark.sql.Row,org.apache.spark.sql.Row,Long>
        Throws:
        Exception

Copyright © 2017 The Apache Software Foundation. All rights reserved.