Add benchmark implementations for Apache Flink