Hi , How can i pass an dynamic value inside below function to filter instead of hardcoded if have an existing RDD and i would like to use data in that for filter so instead of doing .where("name=?","Anna") i want to do .where("name=?",someobject.value)
Please help JavaRDD<String> rdd3 = javaFunctions(sc).cassandraTable("test", "people", mapRowTo(Person.class)) .where("name=?", "Anna").map(new Function<Person, String>() { @Override public String call(Person person) throws Exception { return person.toString(); } });