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.
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
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
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
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
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
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)
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
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.
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
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.
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
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
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
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/"
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,
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
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 =>
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?
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 =
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)
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
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: $
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