confluo
confluo copied to clipboard
Real-time Monitoring and Analysis of Data Streams
Bumps [gson](https://github.com/google/gson) from 2.2.4 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...
Bumps [libthrift](https://github.com/apache/thrift) from 0.12.0 to 0.14.0. Release notes Sourced from libthrift's releases. Version 0.14.0 For release 0.14.0 head over to the official release download source: http://thrift.apache.org/download The assets below are...
## What changes were proposed in this pull request? 1. provide a producer and consumer implement for confluo as a pub/sub system in java 2. also include a simple produce/consume...
### Describe the bug Loading multilog after multiple restarts fails. ### How to reproduce the bug? The test case is: 1. start confluo using data path (e.g. --data-path=/var/db) 2. create...
Dear professor I have pasted the code I write for testing performace such as ops and throughput。I test the ops about 223566 packet per second。 The packet size is about...
GC data log buckets after archiving them for durable and durable relaxed modes so that we're not using 2x the disk space.
[An extra null pointer check is not needed in functions](https://isocpp.org/wiki/faq/freestore-mgmt#delete-handles-null "Do I need to check for null before delete p?") like the following. * [byte_string](https://github.com/ucbrise/confluo/blob/5d813245952b2fbd7b103a1ca70e5869d92d1498/libconfluo/src/types/byte_string.cc#L96 "Destructor for byte_string") * [delta_encoded_array](https://github.com/ucbrise/confluo/blob/7aa7ed5ccba3ecf6d07f160a5dce2880f314c830/libconfluo/confluo/container/bitmap/delta_encoded_array.h#L43...
* Implement count-min-sketch (supposedly more space-efficient than count-sketch) * Time-adaptive sketch: decay accuracy & storage for older values (using inflation) * Integrate with atomic multilog for offline/online approximate queries. -...
Initial sketch-related API additions to `atomic_multilog`: ```C++ void add_sketch(sketch_name : str, field_name : str, filter_name : Optional[str]); void remove_sketch(sketch_name : str); size_t estimate_frequency(sketch_name : str, value : str); map get_heavy_hitters(sketch_name...
We are interesting at the performance of Confluo especially the comparison with Kafka. Can confluo provide detailed test example to help user better understanding of that so we can make...