On Jun 1, 2015, at 1:08 PM, Antonio Giambanco antogia...@gmail.com wrote:
Hi Helena,
thanks for answering me . . .
I didn't realize it could be the connector version, unfortunately i didn't
try yet.
I know scala is better but i'm using drools and i'm forced to use java
in my project i'm
/KafkaStreamingActor.scala#L45
https://github.com/killrweather/killrweather/blob/master/killrweather-app/src/main/scala/com/datastax/killrweather/KafkaStreamingActor.scala#L64
Helena
tw: @helenaedelson
On May 29, 2015, at 6:11 AM, Antonio Giambanco antogia...@gmail.com
wrote:
Hi all,
I
third-party software library from the Tasks (maps, filters etc) within your
DAG job
*From:* Antonio Giambanco [mailto:antogia...@gmail.com]
*Sent:* Friday, May 22, 2015 11:07 AM
*To:* Evo Eftimov
*Cc:* user@spark.apache.org
*Subject:* Re: Spark Streaming and Drools
Thanks a lot Evo,
do
This exception generally means that your cassandra instance is not
reachable/accessible
On Fri, May 29, 2015 at 6:11 AM, Antonio Giambanco antogia...@gmail.com
wrote:
Hi all,
I have in a single server installed spark 1.3.1 and cassandra 2.0.14
I'm coding a simple java class for Spark Streaming
Name: Objectway.com
URL: www.objectway.com
Description:
We're building a Big Data solution on Spark. We use Apache Flume for
parallel message queuing infrastructure and Apache Spark Streaming for near
real time datastream processing combined with a rule engine for complex
events catching.
Hi All,
I'm deploying and architecture that uses flume for sending log information
in a sink.
Spark streaming read from this sink (pull strategy) e process al this
information, during this process I would like to make some event
processing. . . for example:
Log appender writes information about
and use the result from the
Rule to make decision how to transform/filter an event/message
*From:* Antonio Giambanco [mailto:antogia...@gmail.com]
*Sent:* Friday, May 22, 2015 9:43 AM
*To:* user@spark.apache.org
*Subject:* Spark Streaming and Drools
Hi All,
I'm deploying
