Untitled

 avatar
unknown
plain_text
a year ago
251 B
4
Indexable
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));