public class RecordSavePrepPairFunction extends Object implements org.apache.spark.api.java.function.PairFunction<scala.Tuple2<List<Writable>,Long>,org.apache.hadoop.io.LongWritable,RecordWritable>
SparkStorageUtils
Constructor and Description |
---|
RecordSavePrepPairFunction() |
Modifier and Type | Method and Description |
---|---|
scala.Tuple2<org.apache.hadoop.io.LongWritable,RecordWritable> |
call(scala.Tuple2<List<Writable>,Long> t2) |
public scala.Tuple2<org.apache.hadoop.io.LongWritable,RecordWritable> call(scala.Tuple2<List<Writable>,Long> t2) throws Exception
call
in interface org.apache.spark.api.java.function.PairFunction<scala.Tuple2<List<Writable>,Long>,org.apache.hadoop.io.LongWritable,RecordWritable>
Exception
Copyright © 2020. All rights reserved.