Member since
06-27-2016
19
Posts
1
Kudos Received
0
Solutions
07-01-2016
08:00 AM
Thanks for the reply @Jobin George, can you tell me how to send the results from Spark back to NiFi? There is a NiFiReceiver but no NiFiSender. Does the former have a method to send back the results? (I currently use the Java version)
Thanks.
... View more
06-27-2016
09:59 AM
Hi @Jobin George, Thanks for the tutorial! I am connecting to Spark from Nifi using the Output Port. I tried an example - sending a HTTP POST request using the HandleHttpRequest processor with random JSON message which is processed by Spark (code in Java) and is ultimately stored in a MongoDB collection. As a next step, I am going to send a real-world JSON request (let's say IoT data) and predict using a model (which I had already trained using MLLib). I want to predict the score and *return the result* back to Nifi's HandleHttpResponse processor as a response. I am not able to connect an output relationship from the Output Port to the Response processor. Is there another way to send the response (from Spark side) ? Thanks, Sai
... View more