Resultados de la búsqueda a petición "apache-zeppelin"
Eliminar tablas temporales de Apache SQL Spark
yo tengoregistertemptable enApache Spark utilizandoZeppelin abajo: val hvacText = sc.textFile("...") case class Hvac(date: String, time: String, targettemp: Integer, actualtemp: Integer, buildingID: String) val hvac = hvacText.map(s => ...
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 ...
Tutorial de Apache zeppelin, error "intérprete sql no encontrado"
En el "Tutorial de zepelín"cuaderno, no puedo usar elintérprete% sql. Saldrá "sql interpreter not found". Pero los comandos de chispa funcionan bien, así como%md y%sh. Aquí está el registro: ERROR [2015-10-20 10: 13: 35,045] ({qtp885851948-51} ...
Cómo configurar Zeppelin para que funcione con el clúster remoto de hilos EMR
Tengo el clúster Amazon EMR Hadoop v2.6 con Spark 1.4.1, con el administrador de recursos Yarn. Quiero implementar Zeppelin en una máquina separada para permitir apagar el clúster EMR cuando no hay trabajos en ejecución. Traté de seguir las ...
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 ...
¿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 ...
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 = ...
¿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 ...
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, ...
No hay intérpretes disponibles en Zeppelin
Acabo de instalar lo siguiente en mi Mac (Yosemite 10.10.3): oracle java 1.8 actualización 45scala 2.11.6spark 1.4 (versión ...
Página 1 de 2