Resultados da pesquisa a pedido "apache-zeppelin"
Existe uma interface melhor para adicionar suporte a Highcharts no Zeppelin
Apache Zeppelin [https://zeppelin.apache.org/]tem um bom suporte paraAngularJS [https://angularjs.org/]. Embora exista uma lacuna entre Scala e Javascript. Estou tentando adicionarHighcharts [http://www.highcharts.com/]apoio ao Zeppelin para ...
Movendo o Spark DataFrame de Python para Scala com o Zeppelin
Eu criei um Spark DataFrame em um parágrafo Python no Zeppelin. sqlCtx = SQLContext(sc) spDf = sqlCtx.createDataFrame(df)edf é um dataframe de pandas print(type(df)) <class 'pandas.core.frame.DataFrame'>o que eu quero fazer é mudarspDf de um ...
Por que o notebook Zeppelin não consegue se conectar ao S3
Eu instaleizepelim [https://github.com/apache/incubator-zeppelin], na minha máquina aws EC2 para conectar-se ao meu cluster de faíscas. Versão Spark: Autônomo: spark-1.2.1-bin-hadoop1.tgz Consigo conectar-me ao cluster spark, mas obtendo o ...
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 ...
toPandas () erro usando pyspark: objeto 'int' não é iterável
Eu tenho um dataframe pyspark e estou tentando convertê-lo em pandas usando toPandas (), no entanto, estou executando o erro abaixo mencionado. Tentei opções diferentes, mas obtive o mesmo erro: 1) limitar os dados a apenas alguns registros 2) ...
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 ...
Obtendo NullPointerException ao executar o Spark Code no Zeppelin 0.7.1
Eu instaleiZeppelin 0.7.1. Quando tentei executar o programa spark Example (que estava disponível comZeppelin Tutorial notebook), estou recebendo o seguinte erro java.lang.NullPointerException ...
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, ...
É possível definir variáveis globais em um notebook Zeppelin?
Estou tentando criar um painel com vários parágrafos usando um notebook Zeppelin. Eu gostaria que as pessoas que usavam o painel precisassem digitar determinados parâmetros apenas uma vez. Por exemplo. se estou criando um painel com informações ...
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 => ...
Página 1 do 2