Re: How to stream all data out of a Kafka topic once, then terminate job?

2015-04-30 Thread Akhil Das
am get processed, and then just be done and > terminate, rather than wait another period and try and process any more > data > from Kafka? > > > > -- > View this message in context: > http://apache-spark-user-list.1001560.n3.nabble.com/How-to-stream-all-data-out-of-a-Kafka-topic

Re: How to stream all data out of a Kafka topic once, then terminate job?

2015-04-29 Thread Dmitry Goldenberg
econds(...)); >>>> >>>> The batchDuration parameter is "The time interval at which streaming >>>> data >>>> will be divided into batches". Can this be worked somehow to cause Spark >>>> Streaming to just get all the available data

Re: How to stream all data out of a Kafka topic once, then terminate job?

2015-04-29 Thread Dmitry Goldenberg
gt;>>> JavaStreamingContext jssc = new JavaStreamingContext(sparkConf, >>>> Durations.milliseconds(...)); >>>> >>>> The batchDuration parameter is "The time interval at which streaming >>>> data >>>>

Re: How to stream all data out of a Kafka topic once, then terminate job?

2015-04-29 Thread Cody Koeninger
just get all the available data, then let all the RDD's >>> within >>> the Kafka discretized stream get processed, and then just be done and >>> terminate, rather than wait another period and try and process any more >>> data >>> from Kafka?

Re: How to stream all data out of a Kafka topic once, then terminate job?

2015-04-29 Thread Dmitry Goldenberg
>> will be divided into batches". Can this be worked somehow to cause Spark >> Streaming to just get all the available data, then let all the RDD's >> within >> the Kafka discretized stream get processed, and then just be done and >> terminate, rather than wait ano

Re: How to stream all data out of a Kafka topic once, then terminate job?

2015-04-29 Thread Dmitry Goldenberg
tches". Can this be worked somehow to cause Spark >> Streaming to just get all the available data, then let all the RDD's within >> the Kafka discretized stream get processed, and then just be done and >> terminate, rather than wait another period and try and process any

Re: How to stream all data out of a Kafka topic once, then terminate job?

2015-04-29 Thread ayan guha
View this message in context: > http://apache-spark-user-list.1001560.n3.nabble.com/How-to-stream-all-data-out-of-a-Kafka-topic-once-then-terminate-job-tp22698.html > Sent from the Apache Spark User List mailing list archive at Nabble.com. > > -

How to stream all data out of a Kafka topic once, then terminate job?

2015-04-28 Thread dgoldenberg
hin the Kafka discretized stream get processed, and then just be done and terminate, rather than wait another period and try and process any more data from Kafka? -- View this message in context: http://apache-spark-user-list.1001560.n3.nabble.com/How-to-stream-all-data-out-of-a-Kafka-topic-once-t