Resultados da pesquisa a pedido "apache-zeppelin"
Remover tabelas temporárias do Apache SQL Spark
eu tenhoregistertemptable noApache Spark usandoZeppelin abaixo: val hvacText = sc.textFile("...") case class Hvac(date: String, time: String, targettemp: Integer, actualtemp: Integer, buildingID: String) val hvac = hvacText.map(s => ...
Como configurar o Zeppelin para trabalhar com o cluster remoto de fios EMR
Eu tenho o cluster do Amazon EMR Hadoop v2.6 com o Spark 1.4.1, com o gerenciador de recursos Yarn. Desejo implantar o Zeppelin em uma máquina separada para permitir desativar o cluster EMR quando não houver trabalhos em execução. Eu tentei ...
É possível personalizar a aparência do Zeppelin?
É possível personalizar a aparência do Zeppelin? Em outras palavras, substituir o logotipo do Zeppelin por outra coisa?
Lendo arquivos csv no zeppelin usando spark-csv
Eu quero ler arquivos csv no Zeppelin e gostaria de usar o pacote spark-csv do databricks:https://github.com/databricks/spark-csv [https://github.com/databricks/spark-csv] No spark-shell, posso usar o spark-csv com spark-shell --packages ...
Tutorial do Apache zeppelin, erro “interpretador sql não encontrado”
No "Tutorial do Zeppelin"notebook, não consigo usar o% intérprete sql. Isso irá gerar "sql interpreter not found". Mas os comandos do spark funcionam bem, assim como%md e%sh. Aqui está o log: ERRO [2015-10-20 10: 13: 35,045] ({qtp885851948-51} ...
Zeppelin: Scala Dataframe para python
Se eu tiver um parágrafo Scala com um DataFrame, posso compartilhá-lo e usá-lo com python. (Pelo que entendi, o pyspark usapy4j [https://www.py4j.org/advanced_topics.html#array]) Eu tentei isso: Parágrafo Scala: x.printSchema z.put("xtable", x ...
Registre UDF no SqlContext do Scala para usar no PySpark
É possível registrar um UDF (ou função) escrito em Scala para usar no PySpark? Por exemplo.: val mytable = sc.parallelize(1 to 2).toDF("spam") mytable.registerTempTable("mytable") def addOne(m: Integer): Integer = m + 1 // Spam: 1, 2No Scala, ...
Conversão entre spark.SQL DataFrame e pandas DataFrame [duplicado]
Esta pergunta já tem uma resposta aqui: Requisitos para converter o dataframe Spark em Pandas / R dataframe [/questions/30983197/requirements-for-converting-spark-dataframe-to-pandas-r-dataframe] 1 resposta Isso é possível para converter de ...
Zeppeling lançando NullPointerException ao configurar
Estou tentando configurar o zeppelin-0.8.0 no meu windos 8 r2 OS. Já executei o spark no meu console, ou seja, SPARK_HOME e JAVA_HOME, HADOOP_HOME foram configurados e estão funcionando bem. Mas enquanto estou tentando executar printl ("olá") no ...
Página 2 do 2