Skip to content
Project Rehydrate - Algebird HLL T-Digest REST API using Akka HTTP backed by Redis
Branch: master
Clone or download
Fetching latest commit…
Cannot retrieve the latest commit at this time.
Type Name Latest commit message Commit time
Failed to load latest commit information.

Project Rehydrate

Akka HTTP Algebird example

This project demonstrates the Akka HTTP library. Simple Scala REST service wrapping Twitter Algebird HLL library to make an analytics query engine to provide Distinct Counts for millions of items using HyperLogLog Algorithm.

You will need Redis. This Akka HTTP project persists data to Redis.

HLLs are stored as Base64 encoded strings using Twitter Chill (Kryo under the covers) for every minute.

Key: loginService-2015-08-21T04:29:00.000 HLLValue: encodedHLLString Value: 18394


Start services with sbt:

$ sbt run

The service provides 2 REST endpoints:

With the service up, you can start sending HTTP requests to the different endpoints:

Add UUID value to the loginService and return the distinct users seen for the interval:

$curl -i \
  -H "Accept: application/json" \
  -H "X-HTTP-Method-Override: PUT" \
  -X POST -d '{"servername": "loginService", "value": "4cd4f31f-3de2-4428-b457-04b75396214e"}' \
  "key": "loginService_2015-10-21T18:47:00.000",
  "estimatedSize": 99797.80031724533,

How many distinct users was seen for the loginService at 2015-08-21T04:29:00.000 ?

This endpoint demonstrates the rehydration of Algebird HLL Monoid from String fetched from Redis.

$ curl http://localhost:9000/distinct/loginService_2015-08-21T04:29:00.000
  "estimatedSize": 99810.66492371981


Execute tests using test command:

$ sbt
> test

Author & license

If you have any questions regarding this project contact:

@bigsnarfdude on Twitter

For licensing info see LICENSE file in project's root directory.

You can’t perform that action at this time.