Untitled

mail@pastecode.io avatar
unknown
plain_text
7 months ago
376 B
2
Indexable
Never
RDD<Tuple2<Row, Object>> inputrows = rddhive.rdd().zipWithIndex();
JavaPairRDD<Row, Object> pairRDD = JavaPairRDD.fromRDD(inputrows, scala.reflect.ClassTag$.MODULE$.apply(Tuple2.class));

Function<Tuple2<Row, Object>, Row> genRecIdMapper = new GenRecIdMapper(start_rid);
JavaRDD<Row> transformedRows = pairRDD.map(genRecIdMapper);

RDD<Row> outputRDD = transformedRows.rdd();