Tag: apache-zeppelin

Apache Zeppelin ist ein web-basiertes notebook ermöglicht interactive data analytics. Machen Sie schöne data-driven, interaktiven und kollaborativen Dokumenten mit SQL, Scala und vieles mehr.

Zeppelin Dynamische Form, Drop-Down-Wert in SQL

Anzahl der Antworten 2 Antworten
Ich habe ein dropdown-element in meinem Zeppelin notebook val instrument = z.select("Select Item", Seq(("A", "1"),("B", "2"),("C", "3"))) Möchte ich den Wert dieser variable instrument in meiner sql. Für z.B., meine nächsten Absatz das notebook enthält %sql select

Kann nicht ausgeführt werden, matplotlib mit Apache Zeppelin

Anzahl der Antworten 5 Antworten
Bin ich mit dem Zeppelin und matplotlib zu visualisieren einige Daten. Ich versuche Sie aber fehl mit dem folgenden Fehler. Könnten Sie mir einige Hinweise wie es zu lösen ist? %pyspark import matplotlib.pyplot as plt plt.plot([1,2,3,4]) plt.ylabel('some

Apache-Zeppelin - Disconnected status

Anzahl der Antworten 2 Antworten
Habe ich erfolgreich installiert und gestartet Zeppelin auf ec2-cluster mit spark 1.3 und hadoop 2.4.1 Garn.(wie in https://github.com/apache/incubator-zeppelin) Allerdings sehe ich zeppelin begann mit "disconnected" - status (auf der rechten Ecke). Als pro-log, finde ich, dass sowohl

Wie man eine variable in z ZeppelinContext in javascript in Zeppelin?

Anzahl der Antworten 2 Antworten
In Scala und Python ist es: z.put("varname", variable) Aber in javascript habe ich bekommen (in der Konsole) Uncaught ReferenceError: z is not defined Was ich wirklich tun wollen ist, den Zugriff auf eine javascript-variable von Scala-code mit

Mit d3.js mit Apache Zeppelin

Anzahl der Antworten 1 Antworten
Ich versuche, fügen Sie mehr Möglichkeiten zur Visualisierung zu Apache Zeppelin durch die Integration mit d3.js Fand ich ein Beispiel, wo jemand Tat es mit leaflet.js hier, und versuchte, etwas ähnliches zu tun-leider bin ich nicht allzu

apache zeppelin: java.lang.NullPointerException

Anzahl der Antworten 3 Antworten
Beim ausführen jeder Art von Befehl in zeppelin, ich bin immer eine "java.lang.NullPointerException" - Fehler - selbst einfache Sachen wie sc.appName. Hier ist der vollständige text: java.lang.NullPointerException at org.apache.zeppelin.spark.Utils.invokeMethod(Utils.java:38) at org.apache.zeppelin.spark.Utils.invokeMethod(Utils.java:33) at org.apache.zeppelin.spark.SparkInterpreter.createSparkContext_2(SparkInterpreter.java:391) at org.apache.zeppelin.spark.SparkInterpreter.createSparkContext(SparkInterpreter.java:380) at org.apache.zeppelin.spark.SparkInterpreter.getSparkContext(SparkInterpreter.java:146)

Feld "Eigenschaften" nicht vorhanden ist. SparkML

Anzahl der Antworten 1 Antworten
Ich versuche, ein Modell zu bauen in Spark ML, mit Zeppelin. Ich bin neu auf diesem Gebiet und möchte einige helfen. Ich denke, dass ich noch die richtigen Datentypen der Spalte an und bestimmen Sie die erste

com.fasterxml.jackson.databind-Methode.JsonMappingException: Jackson-version ist zu alt 2.5.3

Anzahl der Antworten 2 Antworten
Mein OS ist OS X 10.11.6. Ich bin mit Spark 2.0, Zeppelin 0.6, Scala 2.11 Wenn ich diesen code ausführen im Zeppelin bekomme ich eine Ausnahme von Jackson. Wenn ich diesen code ausführen spark-shell - keine Ausnahme.

Zeppelin change port bereits in Gebrauch ist von Spark Master

Anzahl der Antworten 4 Antworten
Wenn ich starten zeppelin auf der AWS-Plattform, startet Er auf port 8080, aber es ist Spark Master-so sagt es der port bereits in Verwendung ist... ich habe versucht, ändern den port in der zeppelin in config-Dateien, die

Scala und Spark-UDF-Funktion

Anzahl der Antworten 2 Antworten
Habe ich ein einfaches UDF zu konvertieren oder zu extrahieren einige Werte aus einem Feld in ein temptabl in spark. Melde ich die Funktion aber wenn ich den Aufruf der Funktion mit sql wirft es eine NullPointerException.

Wie kann ich pretty print ein Daten-frame in Zeppelin/Spark/Scala?

Anzahl der Antworten 1 Antworten
Bin ich mit Spark 2 und Scala 2.11 in einem Zeppelin 0.7 notebook. Ich habe einen dataframe, dass ich drucken kann, wie diese: dfLemma.select("text", "lemma").show(20,false) und die Ausgabe sieht so aus: +---------------------------------------------------------------------------------------------------------------------------+-----------------------------------------------------------------------------------------------------------------------------------------------------------------------+ |text |lemma | +---------------------------------------------------------------------------------------------------------------------------+-----------------------------------------------------------------------------------------------------------------------------------------------------------------------+ |RT

Wie Sie ein Glas in zeppelin?

Anzahl der Antworten 4 Antworten
Wie Sie ein Glas in Zeppelin für %hive-interpreter? Habe ich versucht %z.dep(''); add jar <jar path> Auch zeppelin-hive-interpreter wirft ClassNotFoundException Hinzufügen ./interpreter/hive/ Durchführungen Sparsamkeit Ausnahme, während add jar sagt Datei nicht gefunden. Wie es zu tun? Ich

Warum SparkContext zufällig in der Nähe, und wie wollen Sie starten es von der Zeppelin?

Anzahl der Antworten 4 Antworten
Arbeite ich in der Zeppelin-schreiben spark-sql-Abfragen und manchmal habe ich plötzlich immer diese Fehlermeldung (nach nicht code ändern): Cannot call methods on a stopped SparkContext. Dann die Ausgabe sagt weiter unten: The currently active SparkContext was created

Lesen Avro Datei in Spark

Anzahl der Antworten 2 Antworten
Habe ich gelesen, eine avro-Datei in spark RDD und müssen conver, die in einer sql-dataframe. wie mache ich das. Dies ist, was ich getan habe bisher. import org.apache.avro.generic.GenericRecord import org.apache.avro.mapred.{AvroInputFormat, AvroWrapper} import org.apache.hadoop.io.NullWritable val path = "hdfs://dds-nameservice/user/ghagh/"

JavaPackage-Objekt ist nicht aufrufbar-Fehler: Pyspark

Anzahl der Antworten 1 Antworten
Operationen wie dataframe.show () sQLContext.Lesen.json funktioniert gut , aber die meisten Funktionen gibt "JavaPackage-Objekt ist nicht aufrufbar-Fehler" . zB : wenn ich dataFrame.withColumn(field_name, monotonically_increasing_id()) Bekomme ich eine Fehlermeldung File "/tmp/spark-cd423f35-9572-45ee-b159-1b2732afa2a6/userFiles-3a6e1729-95f4-468b-914c-c706369bf2a6/Transformations.py", line 64, in add_id_column self.dataFrame = self.dataFrame.withColumn(field_name,

apache zeppelin gestartet ist, aber es gibt Fehler Verbindung in localhost:8080

Anzahl der Antworten 5 Antworten
nach erfolgreichem build apache zepellin auf Ubuntu 14, ich fange zeppelin, und es sagt erfolgreich gestartet, aber wenn ich auf localhost:8080 Firefox zeigt keine Verbindung Fehler wie es gar nicht gestartet, aber wenn ich überprüfen Zeppelin status

Entfernen Sie die Temporären Tabellen von Apache Spark SQL

Anzahl der Antworten 3 Antworten
Habe ich registertemptable im Apache Spark mit Zeppelin unten: val hvacText = sc.textFile("...") case class Hvac(date: String, time: String, targettemp: Integer, actualtemp: Integer, buildingID: String) val hvac = hvacText.map(s => s.split(",")).filter(s => s(0) != "Date").map( s =>

Einlesen der csv-Dateien im zeppelin mit Funken-csv

Anzahl der Antworten 6 Antworten
Ich will Lesen csv-Dateien in Zeppelin und verwenden möchten databricks' spark-csv-Paket: https://github.com/databricks/spark-csv In der Funke-shell, die ich verwenden kann, Funken -, csv mit spark-shell --packages com.databricks:spark-csv_2.11:1.2.0 Aber wie kann ich sagen Zeppelin zu verwenden, die im Paket?

Hallo Welt im zeppelin fehlgeschlagen

Anzahl der Antworten 10 Antworten
Ich gerade installierten apache-zeppelin (gebaut aus dem aktuellen Quellcode aus dem git-repo) und erfolgreich sah es bis und läuft in den Hafen 10008. Ich erstellte eine neue Notiz Buch mit einer einzigen Zeile code val a =

Immer NullPointerException beim laufen Spark-Code in Zeppelin 0.7.1

Anzahl der Antworten 9 Antworten
Habe ich installiert Zeppelin 0.7.1. Als ich versuchte, führen Sie die Beispiel-spark-Programm(das war mit Zeppelin Tutorial notebook), ich erhalte die folgende Fehlermeldung java.lang.NullPointerException at org.apache.zeppelin.spark.Utils.invokeMethod(Utils.java:38) at org.apache.zeppelin.spark.Utils.invokeMethod(Utils.java:33) at org.apache.zeppelin.spark.SparkInterpreter.createSparkContext_2(SparkInterpreter.java:391) at org.apache.zeppelin.spark.SparkInterpreter.createSparkContext(SparkInterpreter.java:380) at org.apache.zeppelin.spark.SparkInterpreter.getSparkContext(SparkInterpreter.java:146) at org.apache.zeppelin.spark.SparkInterpreter.open(SparkInterpreter.java:828) at org.apache.zeppelin.interpreter.LazyOpenInterpreter.open(LazyOpenInterpreter.java:70)

konvertieren pandas dataframes zu entfachen, dataframe im zeppelin

Anzahl der Antworten 3 Antworten
Ich bin der neue zeppelin. Ich habe einen Anwendungsfall, worin ich ein pandas dataframe.Ich brauche zu visualisieren, die Sammlungen mit in-built-Diagramm von zeppelin, die ich nicht haben eine klare Vorgehensweise hier. MEIN Verständnis ist, mit zeppelin können

Was muss `SPARK_HOME` eingestellt werden?

Anzahl der Antworten 1 Antworten
Installierten apache-maven-3.3.3, scala 2.11.6, dann ran: $ git clone git://github.com/apache/spark.git -b branch-1.4 $ cd spark $ build/mvn -DskipTests clean package Schließlich: $ git clone https://github.com/apache/incubator-zeppelin $ cd incubator-zeppelin/ $ mvn install -DskipTests Dann lief der server: $

In Zeppelin sind keine Dolmetscher verfügbar

Anzahl der Antworten 1 Antworten
Ich habe gerade installiert das folgende auf meinem Mac (Yosemite 10.10.3): oracle-java 1.8 update 45 scala 2.11.6 spark 1.4 (vorkompilierte Version: http://d3kbcqa49mib13.cloudfront.net/spark-1.4.0-bin-hadoop2.6.tgz) zeppelin von der Quelle (https://github.com/apache/incubator-zeppelin) keine zusätzliche Konfiguration, die nur kopiert erstellt zeppelin-env.sh und zeppelin-site.xml