flink批量写入HBASE

为什么我在使用了flink的apply算子后返回值是Any，不应该是DataStream类型的吗

后续想sink到hbase里面应该怎么写