Resultados de la búsqueda a petición "apache-zeppelin"
¿Por qué el portátil Zeppelin no puede conectarse a S3?
He instaladozepelín [https://github.com/apache/incubator-zeppelin], en mi máquina aws EC2 para conectarme a mi grupo de chispas. Versión Spark: Independiente: spark-1.2.1-bin-hadoop1.tgz Puedo conectarme al grupo de chispas pero obtengo el ...
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 ...
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 => ...
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 ...
¿Es posible personalizar la máscara en Zeppelin?
¿Es posible personalizar la máscara en Zeppelin? En otras palabras, ¿reemplazar el logotipo de Zeppelin con algo más?
Lectura de archivos csv en zeppelin usando spark-csv
Quiero leer archivos csv en Zeppelin y me gustaría usar el paquete spark-csv de databricks:https://github.com/databricks/spark-csv [https://github.com/databricks/spark-csv] En el spark-shell, puedo usar spark-csv con spark-shell --packages ...
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} ...
Zeppelin: Scala Dataframe a Python
Si tengo un párrafo Scala con un DataFrame, ¿puedo compartirlo y usarlo con python? (Según tengo entendido, pyspark usapy4j [https://www.py4j.org/advanced_topics.html#array]) Intenté esto: Párrafo Scala: x.printSchema z.put("xtable", x ...
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 ...
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 ...
Página 1 de 2