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

Class FrameRDDConverterUtils.LongWritableToSerFunction

  • java.lang.Object
    • org.apache.sysml.runtime.instructions.spark.utils.FrameRDDConverterUtils.LongWritableToSerFunction
  • All Implemented Interfaces:
    Serializable, org.apache.spark.api.java.function.PairFunction<scala.Tuple2<org.apache.hadoop.io.LongWritable,FrameBlock>,org.apache.hadoop.io.LongWritable,FrameBlock>
    Enclosing class:
    FrameRDDConverterUtils


    public static class FrameRDDConverterUtils.LongWritableToSerFunction
    extends Object
    implements org.apache.spark.api.java.function.PairFunction<scala.Tuple2<org.apache.hadoop.io.LongWritable,FrameBlock>,org.apache.hadoop.io.LongWritable,FrameBlock>
    See Also:
    Serialized Form
    • Constructor Detail

      • LongWritableToSerFunction

        public LongWritableToSerFunction()
    • Method Detail

      • call

        public scala.Tuple2<org.apache.hadoop.io.LongWritable,FrameBlock> call(scala.Tuple2<org.apache.hadoop.io.LongWritable,FrameBlock> arg0)
                                                                        throws Exception
        Specified by:
        call in interface org.apache.spark.api.java.function.PairFunction<scala.Tuple2<org.apache.hadoop.io.LongWritable,FrameBlock>,org.apache.hadoop.io.LongWritable,FrameBlock>
        Throws:
        Exception

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