Member since
06-27-2016
19
Posts
1
Kudos Received
0
Solutions
10-07-2022
08:42 PM
Hi, I have been following your instruction. If I want to do the same thing, but with pyspark, will the code similar to this?
... View more
07-21-2016
04:00 PM
1 Kudo
You don't really have a session store in NiFi. However, it would be perfectly possible to create a session store using Cookies and the DistributedMapCacheService and associated processors. You would need to do this by having a flow that creates a session id and adds the Set-Cookie header to the response using dynamic properties on the HandleResponse processor. Use the contents from this as a key to then change and lookup session contents.
... View more
07-08-2016
12:34 PM
I don't know why it was picked but Apache Storm is very production ready, mature and very well instrumented for metrics, debugging and running real production code. It is also real streaming not micro-batching. Hortonworks also has committers on that project. Spark and Flink are very new and maturing.
... View more
10-08-2017
10:34 PM
easy to integrate NiFi -> Kafka -> Spark or Storm or Flink or APEX Also NiFi -> S2s -> Spark / Flink / ...
... View more