You're getting confused about what code is running on the driver vs what
code is running on the executor. Read
http://spark.apache.org/docs/latest/programming-guide.html#understanding-closures-a-nameclosureslinka
On Mon, Feb 29, 2016 at 8:00 AM, franco barrientos <
franco.barrien...@exalitica.
Hi all,
I want to read some filtering rules from mysql (jdbc mysql driver) specifically
its a char type containing a field and value to process in a kafka streaming
input.
The main idea is to process this from a web UI (livy server).
Any suggestion or guidelines?
e.g., I have this:
object St
