Or should i try to use flink datastream?