apache-zeppelin

6Hitze

1Antwort

Wenn ich einen Scala Absatz mit einem DataFrame habe, kann ich ihn mit python teilen und benutzen. (Wie ich es verstehe pyspark verwendet py4j) ich das versucht: Scala Absatz: x.printSchema z.put("xt

14Hitze

3Antwort

konvertieren pandas datenframes zu funken datenframe in zeppelin

Ich bin neu in Zeppelin. Ich habe einen Anwendungsfall, in dem ich einen Pandas-Dataframe habe. Ich muss die Sammlungen visualisieren, indem ich ein eingebautes Zeppelin-Diagramm verwende. Ich habe hi

11Hitze

5Antwort

Lese csv-Dateien in zeppelin mit Funken csv

ich CSV-Dateien in Zeppelin lesen wanna und möchte databricks' Funken csv-Paket verwenden: https://github.com/databricks/spark-csv In den Funken Schal, kann ich Funken csv mit spark-shell --packages c

7Hitze

1Antwort

Apache - Zeppelin mit Variablen in den Absätzen

Ich versuche, den folgenden Anwendungsfall auf Apache Zeppelin zu erreichen: Wenn ich eine SQL-Abfrage schreiben, zum Beispiel %sql SELECT * FROM table1 WHERE column1 = ${column1=1,1|2|3|4} ich ein

11Hitze

1Antwort

Wie verbindet man Zeppelin mit Spark 1.5 aus den Quellen?

Ich zog die neueste Quelle aus dem Spark-Repository und baute lokal. Es funktioniert gut von einer interaktiven Shell wie spark-shell oder spark-sql. Jetzt möchte ich Zeppelin an meinen Spark 1.5, nac

6Hitze

2Antwort

Apache zeppelin Tutorial Fehler "SQL-Interpreter nicht gefunden"

Im "Zeppelin Tutorial" Notebook, kann ich nicht % SQL-Interpreter verwenden. Es wird "sql interpreter not found" ausgeben. Aber die Funken Befehle funktionieren gut, sowie %md und %sh. Hier das Protok

5Hitze

3Antwort

entfernen temporäre Tabellen von Apache SQL Spark-

Ich habe registertemptable in Apache Spark mit Zeppelin unter: val hvacText = sc.textFile("...") case class Hvac(date: String, time: String, targettemp: Integer, actualtemp: Integer, buildingID: Str

5Hitze

4Antwort

Apache Zeppelin Installation Grunzen Buildfehler

Meine Konfiguration ist wie folgt: Ubuntu 15.04 Java 1.7 Spark 1.4.1 Hadoop 2.7 Maven 3.3.3 Ich versuche nach Apache Zeppelin zu installieren erfolgreich es von Github Klonen und mit dem folgend

9Hitze

3Antwort

Funken 1,6: Filterung Datenrahmen erzeugt, indem beschreiben()

Das Problem entsteht, wenn I describe Funktion auf einem Datenrahmen nennen: val statsDF = myDataFrame.describe() Funktion beschreibt Aufruf ergibt die folgende Ausgabe: statsDF: org.apache.spark.sq

5Hitze

1Antwort

Wie man Zeppelin benutzt, um auf aws spark-ec2 cluster und s3 buckets zuzugreifen

Ich habe eine aws ec2-Cluster-Setup von der Spark-ec2-Skript. Ich möchte Zeppelin konfigurieren, damit ich Scala-Code lokal auf Zeppelin schreiben und auf dem Cluster (über Master) ausführen kann. Auß