Untitled
unknown
plain_text
25 days ago
205 B
2
Indexable
Never
// Apply the transformation using map transformation on JavaRDD
JavaRDD<Row> transformedRowsJavaRDD = inputJavaRDD.map(
new GenRecIdMapper(start_rid),
Encoders.bean(Row.class)
).rdd().toJavaRDD();