hi,all i am programming with Spark in Java, and now i have a question: when i made a method call on a JavaRDD such as:
textInput.mapPartitionsWithIndex(
new Function2<Object, Iterator<String>, Iterator<Integer>>()
{...},
false,
PARAM3
);
what value should i pass as the PARAM3 parameter?
it is required as a ClassTag value, then how can i define such a value in Java?
i really have no idea...
best regards,
bluejoe2008
