Hi,
I was trying to fire a bunch of PIG queries from a Java client as follows
PigServer srvr = new PigServer(new PigContext());
srvr.registerQuery("raw = LOAD 'cassandra://testCounters/TOPX_TEST_COUNTERS' USING CassandraStorage() AS (name, columns: bag {T: tuple(counter, value)})");
srvr.registerQuery("rows = FOREACH raw.....");
srvr.registerQuery("calls = FILTER rows by ....");
srvr.registerQuery("ordered = ORDER calls by ...");
srvr.registerQuery("limited = LIMIT ordered 10 ...");
srvr.store("limited","output");
I am getting
INFO: Connecting to hadoop file system at: cfs:///
java.lang.RuntimeException: java.lang.ClassNotFoundException: org.apache.cassandra.hadoop.fs.CassandraFileSystem
I have added all the Brisk cassandra, pig, hadoop jars in the classpath.
I believe I have to go through Brisk framework which I'm not doing in my code.
Can someone please share how to do this?
