bullet-core
bullet-core copied to clipboard
Bullet is a streaming query engine that can be plugged into any singular data stream using a Stream Processing framework like Apache Storm, Spark or Flink.
[](https://docs.github.com/en/github/managing-security-vulnerabilities/about-dependabot-security-updates#about-compatibility-scores) Dependabot will resolve any conflicts with this PR as long as you don't alter it yourself. You can also trigger a rebase manually by commenting `@dependabot rebase`....
Bumps [gson](https://github.com/google/gson) from 2.7 to 2.8.9. Release notes Sourced from gson's releases. Gson 2.8.9 Make OSGi bundle's dependency on sun.misc optional (#1993). Deprecate Gson.excluder() exposing internal Excluder class (#1986). Prevent...
When we write out the PubSubMessage (created with a SerDe), the RestPubSub takes the payload (which is a byte[]), serializes it again to another byte[], Base64 encodes it as a...
Bumps httpclient from 4.5.9 to 4.5.13. [](https://docs.github.com/en/github/managing-security-vulnerabilities/about-dependabot-security-updates#about-compatibility-scores) Dependabot will resolve any conflicts with this PR as long as you don't alter it yourself. You can also trigger a...
This will let us represent pre-aggregation computations and more easily translate statements like: ```sql SELECT a + 5 FROM ... ``` rather than add it as a postAggregation. It will...
Any backend should be able be sent custom messages that it understands. Consider adding common ones such as status checking, flushing, kill all etc.
These are the non-critical errors that the user could still use for information and potentially correct. Examples: Threshold is bad for Top K, size is bad for Aggregations etc.
Overlapping (or not) windows. We can require the sizes to multiples of each other to essentially buffer N of the smaller in a turnstile like data structure in the Join...