jjzjj

GetFilesProcessor

全部标签

apache-spark - 如何在 NiFi 中从 GetFilesProcessor 读取文件

下面是我的流程:GetFile>ExecuteSparkInteractive>PutFile我想从ExecuteSparkInteractive处理器中的GetFile处理器读取文件,应用一些转换并将其放在某个位置。下面是我的流程我在spark处理器的code部分写了sparkscala代码:valsc1=sc.textFile("local_path")sc1.foreach(println)流程中没有任何事情发生。那么如何使用GetFile处理器读取spark处理器中的文件。第二部分:我尝试了以下流程只是为了练习:ExecuteScript>PutFile>LogMessage我