Untitled

mail@pastecode.io avatar
unknown
plain_text
a year ago
205 B
3
Indexable
// Apply the transformation using map transformation on JavaRDD
JavaRDD<Row> transformedRowsJavaRDD = inputJavaRDD.map(
    new GenRecIdMapper(start_rid),
    Encoders.bean(Row.class)
).rdd().toJavaRDD();