ForEachDStreams
ForEachDStream
is an internal DStream with dependency on the parent
stream with the exact same slideDuration
.
The compute
method returns no RDD.
When generateJob
is called, it returns a streaming job for a batch when parent
stream does. And if so, it uses the "foreach" function (given as foreachFunc
) to work on the RDDs generated.
Note
|
Although it may seem that You use stream operators that do the registration as part of their operation, like |