if there’s no related DStream API (but have related RDD API). But
using map maybe more straightforward and easy to understand.
Thanks
Jerry
*From:* madhu phatak [mailto:phatak@gmail.com]
*Sent:* Monday, March 16, 2015 4:32 PM
*To:* user@spark.apache.org
*Subject:* MappedStream vs
DStream API (but have related RDD API). But
using map maybe more straightforward and easy to understand.
Thanks
Jerry
*From:* madhu phatak [mailto:phatak@gmail.com]
*Sent:* Monday, March 16, 2015 4:32 PM
*To:* user@spark.apache.org
*Subject:* MappedStream vs Transform API
Hi
and easy to understand.
Thanks
Jerry
*From:* madhu phatak [mailto:phatak@gmail.com]
*Sent:* Monday, March 16, 2015 4:32 PM
*To:* user@spark.apache.org
*Subject:* MappedStream vs Transform API
Hi,
Current implementation of map function in spark streaming looks as
below
if there’s no related DStream API (but have related RDD API). But
using map maybe more straightforward and easy to understand.
Thanks
Jerry
*From:* madhu phatak [mailto:phatak@gmail.com]
*Sent:* Monday, March 16, 2015 4:32 PM
*To:* user@spark.apache.org
*Subject:* MappedStream vs
straightforward and easy to understand.
Thanks
Jerry
*From:* madhu phatak [mailto:phatak@gmail.com]
*Sent:* Monday, March 16, 2015 4:32 PM
*To:* user@spark.apache.org
*Subject:* MappedStream vs Transform API
Hi,
Current implementation of map function in spark streaming looks as below
:* MappedStream vs Transform API
Hi,
Current implementation of map function in spark streaming looks as
below.
*def *map[U: ClassTag](mapFunc: T = U): DStream[U] = {
*new *MappedDStream(*this*, context.sparkContext.clean(mapFunc))
}
It creates an instance of MappedDStream which
Hi,
Current implementation of map function in spark streaming looks as below.
def map[U: ClassTag](mapFunc: T = U): DStream[U] = {
new MappedDStream(this, context.sparkContext.clean(mapFunc))
}
It creates an instance of MappedDStream which is a subclass of DStream.
The same function can
From: madhu phatak [mailto:phatak@gmail.com]
Sent: Monday, March 16, 2015 4:32 PM
To: user@spark.apache.org
Subject: MappedStream vs Transform API
Hi,
Current implementation of map function in spark streaming looks as below.
def map[U: ClassTag](mapFunc: T = U): DStream[U] = {
new