Shuhao Zhang (Tony)

Processing Flows of Information: From Data Stream to Complex Event Processing https://dl.acm.org/doi/pdf/10.1145/2187671.2187677

Transactional Composition of Executions in StreamProcessing https://kopernio.com/viewer?doi=10.1109%2FDEXA.2016.037&token=WzExOTkwOTYsIjEwLjExMDkvREVYQS4yMDE2LjAzNyJd.3cB0jpgdE0aY5rfWUctrYv7HM_E

TSpoon: Transactions on a stream processor https://cugola.faculty.polimi.it/Papers/transp.pdf

FlowDB: Integrating Stream Processing and Consistent State Management https://dl.acm.org/doi/pdf/10.1145/3093742.3093929

Consistent Streaming Through Time: A Vision for Event Stream Processing https://www.microsoft.com/en-us/research/wp-content/uploads/2016/02/cidr07p42.pdf

Stateful Functions as a Service in Action https://dl.acm.org/doi/pdf/10.14778/3352063.3352092

Hi, Currently, no. You are very welcome to implement it on briskstream. You may want to checkout "BriskRunner.java" and implement one simple application by mimic the "WordCount" application. Please remember...

Hi, For wordcount, I used ./briskstream/common/src/main/java/applications/tools/zipf.java to **generate** the datasets. The input source is Linux dictionary, normally at /usr/share/dict/words. Besides, if you just need to run the program, you can...

Hi, Sure, please also remember to configure your machine specification accordingly as done in ./briskstream/common/src/main/java/applications/Platform.java ./briskstream/common/src/main/java/applications/HUAWEI_Machine.java Then, specify which machine you are using by passing "--machine" argument. Thanks! Tony

Hi Zongxiong, The report of throughput of each operator (executor specifically) is measured by the number of function invocation divided by the total duration. This is more for **debug** purpose....