下面这个例子是从控制台中读取数据,然后根据","切割,把第一个赋值给name,然后写入到es的spark-structured-streaming索引中去,启动程序前需要在控制台执行下命令:nc -lk /location") .format("es").start("spark-structured-streaming"); es.awaitTermination();
color_FFFFFF,t_70) ### Ref 1. https://zhuanlan.zhihu.com/p/51883927 2. https://infoq.cn/article/2018/02/spark-structured-streaming