I have the following code in a Spark Job.
// Get the baseline input file(s)
JavaPairRDDText,Text hsfBaselinePairRDDReadable =
sc.hadoopFile(baselineInputBucketFile, SequenceFileInputFormat.class,
Text.class, Text.class);
JavaPairRDDString, String hsfBaselinePairRDD =
I have the following code in a Spark Job.
// Get the baseline input file(s) JavaPairRDDText,Text
hsfBaselinePairRDDReadable = sc.hadoopFile(baselineInputBucketFile,
SequenceFileInputFormat.class, Text.class, Text.class); JavaPairRDDString,
String hsfBaselinePairRDD =