This project implements Bullet PubSub through Pulsar, allowing you to use Pulsar as your pubsub layer for transporting Bullet queries and results between the Bullet Web Service and Backend.
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. It lets you run queries on this data stream - including hard queries like Count Distincts, Top K etc. The main project is available here.
Bullet Pulsar is a Java implementation of the Bullet PubSub, published to Bintray and mirrored to JCenter. To see the various versions and set up your project for your package manager (Maven, Gradle etc), see here.
For usage, please refer to Pulsar PubSub.
All documentation is available at Github Pages here.
- PubSub Architecture to see PubSub architecture.
- Spark Quick Start to start with a Bullet instance running locally on Spark.
- Storm Quick Start to start with a Bullet instance running locally on Storm.
- Spark Architecture to see how Bullet is implemented on Storm.
- Storm Architecture to see how Bullet is implemented on Storm.
- Setup on Spark to see how to setup Bullet on Spark.
- Setup on Storm to see how to setup Bullet on Storm.
- API Examples to see what kind of queries you can run on Bullet.
- Setup Web Service to setup the Bullet Web Service.
- Setup UI to setup the Bullet UI.
All contributions are welcomed! Feel free to submit PRs for bug fixes, improvements or anything else you like! Submit issues, ask questions using Github issues as normal and we will classify it accordingly. See Contributing for a more in-depth policy. We just ask you to respect our Code of Conduct while you're here.
Code licensed under the Apache 2 license. See the LICENSE for terms.