Prototypical Stream Processing of vector data with Apache Flink
This repository contains a prototype for processing GeoJSON and supplementory data using Apache Kafka and Flink. It is build on top of the stack in https://github.com/DisyInformationssysteme/biggis-infrastructure.
The implemented jobs feature the import of GeoJSON coded sensor locations and corresponding time series. Sources are Kafka queues. Destination is a PostGIS/Postgres database. The source data is provided by the following projects:
- https://github.com/DisyInformationssysteme/biggis-download-kef-data
- https://github.com/DisyInformationssysteme/biggis-import-kef-data-to-kafka
This work was done for the BigGIS project funded by the German Federal Ministry of Education and Research (BMBF).