JavaFX and commandline application to import events from the Ethereum blockchain into ElasticSearch, MongoDB, Hazelcast, CQEngine and SQLite.

Hive streaming ingest test application

This is an Elasticsearch Ingest Pipeline Processor that calls an HTTP(s) endpoint and adds the response back to the ingest document for further processing.

Apache NiFi 1.23 Custom Processor for WebCams

Riffl - generic streaming data ingestion framework