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