Shuhao Zhang (Tony)

Hi Zongxiong, Currently, windowing function is implemented in the user application code itself (i.e., ad-hoc solution). The **window impl** is largely a mimic of Storm source code, but I haven't...

Hi mencagli, 1) fieldsgrouping is supported, as you can reference to WordCount.java to how to declare it. It is almost the same as Storm, but do take note the slight...

Technically yes, but I didn't write the corresponding code to allow Spout to connect next operator with FieldsGrouping (always assume shuffle grouping). As I just mentioned, I always assume Spout...

Dear Gabriele, I just checked the code, it is already supported. For illustration, I modified FaultDetection.java so that Spout is connected to Parser using FieldsGrouping. Of course, you can then...

Unfortunately, there is currently no such feature built in BriskStream. You may want to implement it in application itself, say, call ``system.exit()" when the Spout receive a special tuple.

Hi Gabriele, Currently, BriskStream relies on ``-bt" to tune the number of tuples being transmitted at once between executors. That is to say, the size of the message buffer is...

I see, so you are talking about the size of the communication queue. Yes, you can change it. It is located in the executorThread.java. Currently, it is hard-coded as 100000....

Hi Gabriele, I guess the system hangs at the "load()" function (see the following code). The reason is that it seeks to load statistics file that is required by the...

No problem. :) In fact, I should apologize for not having time to make it more user-friendly. For the NullPointerException, please ensure ` enable_shared_state @ Line 62 is false. `...

Ha, I guess that's related to the input data sets. I have assumed a delimiter of ",". The input data is like "eating, an, apple, is, good". You can change...