Описание тега apache-zeppelin

Apache Zeppelin - это веб-блокнот, который обеспечивает интерактивную аналитику данных на основе данных. Вы можете создавать красивые, основанные на данных, интерактивные документы для совместной работы с помощью SQL, Python, Scala и других. Он также поддерживает синтаксис Markdown.
1 ответ

Отказ в соединении: подключиться во время работы Apache Zeppelin.

Я скачал Spark 2.1.0 и Apache Zeppelin 0.7.0. Я отредактировал свои переменные окружения для Spark, Java и Winutils (так как я использую Windows 10). Я отредактировал zeppelin-env.sh и zeppelin-site.xml, чтобы экспортировать мои JAVA_HOME и SPARK_HO…
02 мар '17 в 20:55
1 ответ

Отладка Zeppelin Dependency Management

Я пытаюсь заставить Zeppelin Dependency Management работать (Zeppelin версия 0.6.2). Например, я пытаюсь установить Spark-Cassandra Connector следующим образом: Добавление нового репозитория с URL: https://mvnrepository.com/artifact/ и никаких други…
07 ноя '16 в 15:52
2 ответа

Apache Zeppelin - Highcharts

Я пытаюсь Apache Zeppelin. Я хотел иметь высокие чарты. Поэтому я подумал об использовании%html интерпретатора. Я сделал это print("%html <h3> Hello World!! </h3>") Это прекрасно работает. Знай, у меня есть код для старших <!DOCTYPE h…
13 май '16 в 11:46
1 ответ

Как Zeppelin интегрирован, чтобы зажечь?

Я очень плохо знаком с распределенной обработкой данных и хотел бы понять, как Zeppelin взаимодействует с искровым кластером? Хотите знать, как zeppelin может извлекать фреймы данных, сгенерированные в предыдущих абзацах, а затем использовать их в т…
0 ответов

Пользовательские учетные данные в Apache Zeppelin

Мне нужно хранить свои пользовательские учетные данные, которые относятся к моей библиотеке, которая работает на Spark Interpreter. Эти учетные данные доступны в токене JWT, и я могу расширить ActiveDirectoryGroupRealm из Shiro для извлечения этих д…
10 июл '17 в 10:34
3 ответа

Как запустить Apache Zepelin в режиме отладки?

Мне нужно запустить Zeppelin в режиме отладки, чтобы добавить точки прерывания в Intellij для удаленной отладки кода. Как мне это сделать? Нет документации по этому вопросу.
28 сен '15 в 09:37
1 ответ

Повторно использовать настройки интерпретатора Zeppelin

Есть ли шанс, что я смогу перенести настройки интерпретатора Zeppelin из другого кластера Zeppelin? Я сделал некоторые изменения в Zeppelin spark переводчик. Я хотел бы сохранить эти изменения и использовать на другом кластере. Это файл interter.jso…
05 сен '17 в 14:12
1 ответ

Читайте локальные файлы в фрейме данных spark в zeppelin, работающем в докере

Я пытаюсь написать код Spark в Zeppelin, используя изображение докера apache zeppelin на моем ноутбуке. Все работает, как и ожидалось, за исключением чтения файлов с локального диска, например, когда я пытаюсь прочитать файл CSV в кадре данных Spark…
16 ноя '18 в 00:21
0 ответов

apache zeppelin hive jdbc mapreduce java.sql.SQLException

Интерпретатор JDBC для улья в Zeppelin отлично работает с не MR запросами. В случае MR, получение ошибки ниже %Hive выбрать * из таблицы, где месяц = ​​2; получить следующее исключение: java.sql.SQLException: ошибка при обработке оператора: FAILED: …
08 мар '17 в 04:57
1 ответ

ClassNotFoundException: org.apache.zeppelin.spark.ZeppelinContext при использовании входного значения Zeppelin внутри метода фильтра DataFrame в spark

У меня проблемы уже два дня, и я не могу найти решения. я собираюсь ClassNotFoundException: org.apache.zeppelin.spark.ZeppelinContext при использовании входного значения внутри метода фильтра spark DataFrame. val city = z.select("City",cities).toStr…
0 ответов

Apache Zeppelin 0.7.2 и spark-2.1.1-bin-hadoop2.7 на компьютере с Windows 10

Я новичок в zeppelin и пытаюсь настроить apache zeppelin для соединения с автономной искрой на моей локальной машине, я установил следующие настройки в файле zeppelin-env.cmd. И измените номер порта на 8082 в файле zeppelin-site.xml. set JAVA_HOME=C…
09 июл '17 в 20:28
2 ответа

Как игнорировать первый элемент в Groupby в Scala /Spark?

Я использую Spark2, Zeppelin и Scala, чтобы показать 10 лучших вхождений слов в наборе данных. Мой код: z.show(dfFlat.groupBy("value").count().sort(desc("count")), 10) дает: Как мне проигнорировать "кошку" и сделать так, чтобы сюжет начинался с "шля…
05 сен '17 в 10:51
0 ответов

Настройка StreamingContext в Apache Zeppelin

Моя цель - прочитать потоковые данные из потока (в моем случае aws kinesis) и затем запросить данные. Проблема в том, что я хочу запрашивать данные за последние 5 минут на каждом интервале. И я обнаружил, что возможно хранить данные в потоке в течен…
0 ответов

Spark Scala API (Блокнот Zeppelin): игнорировать сериализацию преобразования foreachRDD

Вызов преобразования foreachRDD вызывает исключение NotSerializableException в моем проекте Spark Scala в блокноте Zeppelin. Это потоковое приложение, которое собирает данные через окна, поэтому мне пришлось включить контрольные точки: val hadoopCon…
0 ответов

Pyspark с Zeppelin: распределение файлов по узлам кластера в сравнении с SparkContext.addFile()

У меня есть библиотека, которую я создал, и которую я хочу сделать доступной для всех узлов кластера pyspark (1.6.3). Я запускаю тестовые программы на этом искровом кластере через Zeppelin (0.7.3). Файлы, которые я хочу, находятся в репозитории gith…
1 ответ

Zeppelin spark innterpreters выдает java.lang.StackruError через некоторое время

Я использую Zeppelin, чтобы запустить какую-то работу с помощью crontab. jdk8,spark1.6.2,scala2.10 Но в последние дни я обнаружил, что искровой интерпретатор Цеппелина отключался почти каждый день один или несколько раз. А вот и журнал java.lang.Sta…
03 авг '16 в 03:20
1 ответ

Не удалось запустить демонстрацию ноутбука Zeppelin Spark Streaming - песочница Hortonworks

Я попытался запустить демонстрационную тетрадь, доступную на Zeppelin, в песочнице Hortonworks 2.4 (Notebook с именем twitter), чтобы изучить SparkStreaming. Согласно инструкции на верхней части ноутбука (/* ПЕРЕД НАЧАТЬ....), я вошел в систему Amba…
0 ответов

Можно ли запускать абзацы Zeppelin без браузера?

У меня есть параграф, который выполняется по расписанию, чтобы проверить ценность данных за последнюю минуту, и он отправляет предупреждение на другой сервер, если не в рамках спецификации. Может ли этот или любой другой абзац, выполняемый по распис…
01 сен '16 в 21:45
0 ответов

Фильтр ComboBox источника данных в Apache Zeppelin

У меня есть проект Apache Zepellin. В моем проекте у меня есть два ComboBox, настроенные следующим образом: DropDownA Источником данных является 1, 2, 3, 4, 5. DropDownB Источником данных является A, B, C, D, E. Мне нужно отфильтровать DropDownB ист…
15 июн '17 в 13:02
1 ответ

Как связать стандартный токен с краудсейлом в Zeppelin Solidity

Здравствуйте! Я пытаюсь создать краудсейл с помощью цеппелина, но не смог найти способ связать стандартный токен с заранее выделенным запасом с краудсейлом. Другими словами, мне нужно иметь баланс токенов для определенных VIP-адресов без необходимос…
03 ноя '17 в 10:05