Flink data operator #