spark-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Stephen Boesch <java...@gmail.com>
Subject Equivalent of collect() on DStream
Date Thu, 15 May 2014 04:25:34 GMT
Given that collect() does not exist on DStream apparently my mental model
of Streaming RDD (DStream) needs correction/refinement.  So what is the
means to convert DStream data into a JVM in-memory representation.  All of
the methods on DStream i.e. filter, map, transform, reduce, etc generate
other DStream's, and not an in memory data structure.

Mime
View raw message