关于flink读取json的问题

有一个json文件，内容如下：

{
    "name":"zhangsan",
    "age":15,
    "gender":"man"
}

现在使用flink读取：

package com.flinkscript

import org.apache.flink.streaming.api.scala._

object PutDataToNifi {
  def main(args: Array[String]): Unit = {
    val env: StreamExecutionEnvironment = StreamExecutionEnvironment.getExecutionEnvironment
    val dataStream = env.readTextFile("E:\\test\\testFile")
    dataStream.print()
    env.execute()
  }

输出结果它对文件内容分别进行了输出

6> {
1>     "age":15,
6>     "name":"zhangsan",
3>     "gender":"man"
5> }

请问该怎么把这些数据整合成一个完整的json呢？