Re: Using Cassandra as an input stream from Java

2013-12-05 Thread Pulasthi Supun Wickramasinghe
it right now... > > Best Regards. > > Lucas. > On Dec 5, 2013 1:51 AM, "Pulasthi Supun Wickramasinghe" < > pulasthi...@gmail.com> wrote: > >> Hi Tal, >> >> Just checking if you have added your code to github :). if you have could >>

Re: Using Cassandra as an input stream from Java

2013-12-04 Thread Pulasthi Supun Wickramasinghe
t 1:00 AM, Pulasthi Supun Wickramasinghe > wrote: > > Hi Tal, > > > > Thanks for the info will try it out and see how it goes. > > > > > > On Thu, Nov 28, 2013 at 2:19 PM, Tal Sliwowicz > wrote: > >> > >> Hi Pulasthi, > >> > >&

Re: Error when running CassandraTest

2013-11-28 Thread Pulasthi Supun Wickramasinghe
Hi All, This was due to some missing jars. after adding the jars and bundles in the lib_managed folder in the distribution i was able to overcome this issue. Regards, Pulasthi On Mon, Nov 25, 2013 at 3:07 PM, Pulasthi Supun Wickramasinghe < pulasthi...@gmail.com> wrote: > Hi All,

Re: Using Cassandra as an input stream from Java

2013-11-28 Thread Pulasthi Supun Wickramasinghe
d will upload to github as an open > source (after the summit). > > That's great looking forward check it out after you publish on github :). Thanks, Pulasthi > I hope this helps for now, > > Tal > > > On Thu, Nov 28, 2013 at 10:21 AM, Pulasthi Supun Wickramasinghe <

Re: Using Cassandra as an input stream from Java

2013-11-28 Thread Pulasthi Supun Wickramasinghe
Hi Tal, I also tried doing this by converting the scala sample into Java but i am getting an compile time error below is the code JavaSparkContext sc = new JavaSparkContext("local[3]", "casDemo"); //Build the job configuration with ConfigHelper provided by Cassandra Job job = nu

Error when running CassandraTest

2013-11-25 Thread Pulasthi Supun Wickramasinghe
Hi All, I am trying to run the CassandraTest sample but i am running into an error When creating the spark context val sc = new SparkContext("spark://pulasthi-laptop:7077", "casDemo"); this line causes the following error i don't understand why "mesos/Scheduler" is needed. I have setup an local

Re: Using Spark with Cassandra

2013-11-12 Thread Pulasthi Supun Wickramasinghe
Hi Andre, Thanks :). Regards, Pulasthi On Tue, Nov 12, 2013 at 5:17 PM, Andre Kuhnen wrote: > there is an example here > https://github.com/apache/incubator-spark/tree/master/examples/src/main/scala/org/apache/spark/examples > > > have Fun :) > > > > 2013/11/12 Pu

Using Spark with Cassandra

2013-11-12 Thread Pulasthi Supun Wickramasinghe
Hi All, I am pretty new to Spark and still learning the basics. I want to create RDD's from data that is stored in a Cassandra database. in the org.apache.spark.rdd package there are several classes but didn't find any related to Cassandra. i did stumble across [1] so i assume that it is possible