原文:用spark streaming实时读取hdfs数据并写入elasticsearch中