Initial wrappers for Apache Flink added