apache-zeppelin

2зной

1ответ

zeppelin notebook "ошибка: не найден: значение%"

в соответствии с reading csv in zeppelin Я должен использовать %dep для загрузки csv jar, но я получаю error: not found: value % Кто-нибудь знает, чего я не хватает? %spark val a = 1 %dep z.reset

1зной

1ответ

Как использовать зависимости от S3 в Zeppelin?

Есть ли способ добавить банки, которые находятся в ведре на S3, как зависимость Zeppelin? попробовал z.load(s3n://...) и z.addRepo(some_name).url(s3n://...), но они, похоже, не выполняют эту работу.

1зной

1ответ

Преобразование списка в Scala в список Python или dataFrame

У меня есть список 2d в Scala под названием dataList, и я хочу преобразовать его в Pandas DataFrame. val dataList: List[List[Int]] = tempData.toList Если я хочу напечатать dataList, все работает отл

3зной

1ответ

org.apache.thrift.transport.TTransportException ошибка при чтении большого файла JSON в zeppelin scala

Я пытаюсь прочитать большой файл JSON (1,5 ГБ) с помощью Zeppelin и Scala. Zeppelin работает на SPARK в локальном режиме, установленном на ОС Ubuntu на виртуальной машине с ОЗУ 10 ГБ. Я выделила 8 Гб

0зной

1ответ

Спарк работает бесконечно, например Pi

Я просто настроить Спарк и выполнил команду spark-shell --master yarn-client --driver-memory 512m --executor-memory 512m Однако, он просто продолжает бесконечно распечатывать сообщения, как 16/04/25

1зной

1ответ

Как запустить искру на Цеппелин анализировать XML-файлы

Я могу запустить Спарк шелл bin/spark-shell --packages com.databricks:spark-xml_2.11:0.3.0 провести анализ файлов XML, например: import org.apache.spark.sql.SQLContext val sqlContext = new SQLContex

0зной

1ответ

AttributeError: объект 'DataFrame' не имеет атрибута 'get' on sparkle VectorAssembler ML

Я пытаюсь следовать рассмотренному примеру here, и я просто скопировал код в абзац Цеппелина. %pyspark import pandas as pd from pyspark.sql import SQLContext from pyspark.ml.feature import VectorAs