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