Untitled

RDD<Tuple2<Row, Object>> inputrows = rddhive.rdd().zipWithIndex();
RDD<Row> transformedRows = inputrows.map(new GenRecIdMapper(start_rid),
        scala.reflect.ClassTag$.MODULE$.apply(Row.class), scala.reflect.ClassTag$.MODULE$.apply(Object.class));