Hi,
I have one more question regarding the exchange of data between
interpreters. I figured out how to exchange data between flink and
spark to use the result of Dynamic Form in later queries.
My actual quation is. Could I store a result into the Interpreter
Context from within Flink or Spark Interpreter and receive the value
by using the Cassandra Interpreter in its own paragraph?
Sample code:
{code}
%spark
import org.apache.zeppelin.interpreter.InterpreterContext
val resourcePool = InterpreterContext.get().getResourcePool()
resourcePool.put("countries", Seq(("one", "one"), ("two", "two)))
{/code}
And use the "countries" variable in Cassandra:
{code}
%cassandra
import org.apache.zeppelin.interpreter.InterpreterContext
val resourcePool = InterpreterContext.get().getResourcePool()
val c = resourcePool.get("countries").get.asInstanceOf[Seq
[(String,String)]]
{/code}
The code above works within the Flink interpreter because this
interpreter understands Scala.
Is there a way to adopt that and receive the variable "countries" in
a Cassandra Interpreter paragraph?
Thanks for any help.
Kind regards,
Andre
--
Andre Schütz
COO / Founder - Wegtam GmbH
[email protected] | P: +49 (0) 381-80 699 041 | M: +49 (0) 176-218 02 604
www.wegtam.com | www.tensei-data.com | www.wegtam.net
