Hi,
computations are triggered by an output operation. No output operation, no
computation. Therefore in your code example,
On Thu, Aug 21, 2014 at 11:58 PM, Josh J joshjd...@gmail.com wrote:
JavaPairReceiverInputDStreamString, String messages =
Hi,
Can I build two sliding windows in parallel from the same Dstream ? Will
these two window streams run in parallel and process the same data? I wish
to do two different functions (aggregration on one window and storage for
the other window) across the same original dstream data though the same
