transform

lines.transform(
  rdd => {
      //周期性更新
      rdd.map{
        .....
      }
  }
)