Resultados de la búsqueda a petición "apache-zeppelin"
Zeppeling lanzando NullPointerException mientras configura
Estoy tratando de configurar zeppelin-0.8.0 en mi sistema operativo windos 8 r2. Ya he ejecutado spark en mi consola, es decir, SPARK_HOME y JAVA_HOME, HADOOP_HOME configurado y funcionando bien. Pero mientras intento ejecutar printl ("hola") en ...
¿Cómo obtener la salida del receptor de transmisión de consola en Zeppelin?
Estoy luchando por conseguir elconsole fregadero trabajando conTransmisión estructurada de PySpark [https://spark.apache.org/docs/2.2.0/structured-streaming-programming-guide.html] cuando se ejecuta desde Zeppelin. Básicamente, no veo ningún ...
Ejecutar zeppelin en modo de grupo de chispas
Estoy usando este tutorialgrupo de chispas en modo hilo en contenedor acoplable [https://zeppelin.apache.org/docs/0.7.0/install/spark_cluster_mode.html#spark-on-yarn-mode] para lanzar zeppelin en el grupo de chispas en modo hilo. Sin embargo, ...
Obteniendo NullPointerException cuando se ejecuta Spark Code en Zeppelin 0.7.1
He instaladoZeppelin 0.7.1. Cuando intenté ejecutar el programa Ejemplo de chispa (que estaba disponible conZeppelin Tutorial cuaderno), recibo el siguiente error java.lang.NullPointerException ...
Convertir entre spark.SQL DataFrame y pandas DataFrame [duplicado]
Esta pregunta ya tiene una respuesta aquí: Requisitos para convertir el marco de datos de Spark a Pandas / R marco de datos [/questions/30983197/requirements-for-converting-spark-dataframe-to-pandas-r-dataframe] 1 respuesta ¿Es posible ...
¿Es posible establecer variables globales en un cuaderno Zeppelin?
Estoy tratando de crear un panel de varios párrafos usando un cuaderno Zeppelin. Me gustaría que las personas que usan el tablero solo tengan que ingresar ciertos parámetros una vez. P.ej. Si estoy haciendo un tablero con información sobre ...
com.fasterxml.jackson.databind.JsonMappingException: la versión de Jackson es demasiado antigua 2.5.3
Mi sistema operativo es OS X 10.11.6. Estoy ejecutando Spark 2.0, Zeppelin 0.6, Scala 2.11 Cuando ejecuto este código en Zeppelin, recibo una excepción de Jackson. Cuando ejecuto este código en spark-shell, no hay excepción. val filestream = ...
¿Hay una mejor interfaz para agregar soporte de Highcharts a Zeppelin?
Apache Zeppelin [https://zeppelin.apache.org/]tiene buen apoyo paraAngularJS [https://angularjs.org/]. Si bien hay una brecha entre Scala y Javascript. Estoy tratando de agregarHighcharts [http://www.highcharts.com/]apoyo a Zeppelin para llenar ...
Mover Spark DataFrame de Python a Scala con Zeppelin
Creé un DataFrame de chispa en un párrafo de Python en Zeppelin. sqlCtx = SQLContext(sc) spDf = sqlCtx.createDataFrame(df)ydf es un marco de datos de pandas print(type(df)) <class 'pandas.core.frame.DataFrame'>lo que quiero hacer es mudarmespDf ...
Registre UDF en SqlContext desde Scala para usar en PySpark
¿Es posible registrar un UDF (o función) escrito en Scala para usar en PySpark? P.ej.: val mytable = sc.parallelize(1 to 2).toDF("spam") mytable.registerTempTable("mytable") def addOne(m: Integer): Integer = m + 1 // Spam: 1, 2En Scala, ahora es ...
Página 1 de 2