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();
                    }
                });

Reply via email to