Untitled

mail@pastecode.io avatar
unknown
plain_text
22 days ago
251 B
3
Indexable
Never
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));