I have also tried this stupid code snippet, only thinking that it may even
compile code
Function1<User, Object> FILTER_USER = new AbstractFunction1<User, Object >()
{
public Object apply(User user){
return user;
}
};
FILTER_USER is fine but cannot be applied to the following two options but
no results:
User[] filterUsr =
(User[])rdd.rdd().retag(User.class).filter(FILTER_USER);
User userFilter = (User) rdd.rdd().filter(FILTER_USER);
Giving issue: Inconertable types
I really need proper code related to this issue.
--
View this message in context:
http://apache-spark-user-list.1001560.n3.nabble.com/How-to-implement-top-and-filter-on-object-List-for-JavaRDD-tp23669p23677.html
Sent from the Apache Spark User List mailing list archive at Nabble.com.
---------------------------------------------------------------------
To unsubscribe, e-mail: user-unsubscr...@spark.apache.org
For additional commands, e-mail: user-h...@spark.apache.org
