Active Functor Framework -

Questions

How system store all events (data input) ?

Sensors (data publishers / data collectors / data crawlers): Netty, PhantomJS, Chrome Ext

Message (Persistent Queue) : Kafka

Decode message into stimulus (aka event), fast persistent to Redis http://redis.io/:

Store stimulus (aka event) in Hadoop in date format yyyy/mm/dd/hh

Indexing with Elasticsearch (all fields in an event)

How system react to data ?

Reactive processing to every stimulus (stimuli as plural)

every event must belongs to category

https://github.com/Netflix/RxJava

http://doc.akka.io/docs/akka/2.2.3/java/untyped-actors.html

How system query data ?

FQL (functor query language)

https://github.com/FoundationDB/sql-parser

translate FQL to ES http://www.elasticsearch.org/guide/en/elasticsearch/reference/current/query-dsl-query-string-query.html

English to FQL converter

https://opennlp.apache.org/documentation.html

https://dl.dropboxusercontent.com/u/4074962/i2tree/139211173869-big-data-the-reactive-way.html