Simon Zelazny
Simon Zelazny
The goal: showcase Wallaroo's windowing functionality by using a Wallaroo app to ingest and aggregate metrics from a (different) Wallaroo app.
See: https://github.com/pzel/wallaroo/commit/117a7fd76696c760e2803b659eaf50e275550193 In networking-heavy applications, it makes sense to keep tcp source scheduled for longer than usual. Right now this is determined by the `max_received_count` parameter in `tcp_source`. For some...
This issue is to track a scenario we came across in February 2019. Ingredients: A realistic Wallaroo setup, consisting of one Wallaroo application reducing a large stream, and feeding it...
#### Is this a bug, feature request, or feedback? Bug / UI improvemnt. #### What is the current behavior? I have the following `Aggregation` class in an app that uses...
Our copyright headers currently say: ``` Copyright 2017 The Wallaroo Authors. ``` Let's update it to say: ``` Copyright 2017-2018 The Wallaroo Authors. ```
# Summary I propose to eliminate the overhead necessary to parse JSON and pretty-print custom responses to External Message queries by standardizing on always returning JSON from the queried Wallaroo...
### What are we doing to trigger the bug: `while (mix test test/fuzzy/partitions_test.exs:36); do sleep 1; done` ### What we expect: When running the `fuzzy/partitions_test` repeatedly, we expect it to...
By putting the separating space before the optional element(s), not after the obligatory ones, we ensure that in cases where there are no `tags` or `feed-title`, the `*elfeed-search*` buffer does...
Running the parallel trending hashtags app, I get the following after a while: ``` Traceback (most recent call last): File "twitter_client.py", line 50, in send_tweets_to_wallaroo(resp,sock) File "twitter_client.py", line 18, in...