Untitled

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();