Suchergebnisse für Anfrage "hiveql"

4 die antwort

Hives unix_timestamp und from_unixtime Funktionen

Ich habe den Eindruck, dass unix_timestamp und from_unixtime Hive-Funktionen sind gegensätzlich. Wenn ich versuche, einen Zeitstempel in Sekunden umzuwandeln: SELECT unix_timestamp('10-Jun-15 10.00.00.000000 AM', 'dd-MMM-yy hh.mm.ss.MS a'); Ich ...

14 die antwort

So exportieren Sie Daten von Spark SQL nach CSV

Dieser Befehl funktioniert mit HiveQL: insert overwrite directory '/data/home.csv' select * from testtable;Aber mit Spark SQL erhalte ich einen Fehler mit einemorg.apache.spark.sql.hive.HiveQl Stack-Trace: java.lang.RuntimeException: ...

2 die antwort

Hive Join-Optimierung

Ich habe zwei Datensätze, die beide in einem S3-Bucket gespeichert sind, den ich in Hive verarbeiten und die Ausgabe in S3 zurückspeichern muss. Beispielzeilen aus den einzelnen Datasets lauten wie folgt: DataSet 1: ...

TOP-Veröffentlichungen

4 die antwort

Explodieren (transponieren?) Sie mehrere Spalten in der Spark-SQL-Tabelle

Ich verwende Spark SQL (ich erwähne, dass es in Spark ist, falls es die SQL-Syntax beeinflusst - ich bin noch nicht vertraut genug, um sicher zu sein) und ich habe eine Tabelle, die ich neu strukturieren möchte, aber ich ' Ich stecke fest und ...

2 die antwort

Verbindung mit HIVE2 über JAVA nicht möglich

[/imgs/FESNi.jpg]In Bezug auf Hive2 [https://cwiki.apache.org/confluence/display/Hive/HiveServer2+Clients#HiveServer2Clients-JDBC] hat ein einfaches Java-Programm erstellt, um eine Verbindung zum HIVE2-Server herzustellen (nicht lokal). Alle ...

2 die antwort

Looping mit Hiveql

Ich versuche, 2 Datensätze, z. B. A und B, zusammenzuführen. Der Datensatz A hat eine Variable "Flag", die 2 Werte annimmt. Anstatt beide Daten zusammenzuführen, habe ich versucht, zwei Datensätze basierend auf der Variablen "flag" ...

4 die antwort

So übergeben Sie mehrere Anweisungen an Spark SQL HiveContext

Zum Beispiel habe ich einige Hive HQL-Anweisungen, die ich an Spark SQL übergeben möchte: set parquet.compression=SNAPPY; create table MY_TABLE stored as parquet as select * from ANOTHER_TABLE; select * from MY_TABLE limit 5;Folgen ...

4 die antwort

Query Ein verschachteltes Array in Parkettaufzeichnungen

ch versuche verschiedene Möglichkeiten, einen Datensatz in einem Array von Datensätzen abzufragen und die vollständige Zeile als Ausgabe anzuzeige Ich weiß nicht, welches verschachtelte Objekt den String "pg" hat. Aber ich möchte nach einem ...

4 die antwort

Row Number-Funktionalität in Hive

Wie kann ich Zeilennummern für eine vorhandene Tabelle generieren, während eine Auswahlabfrage ausgeführt wird? Beispielsweise select row_number(), * from emp;Ich verwende Hive 0.13. Ich kann in meiner Umgebung nicht auf externe Jars oder Udfs ...

2 die antwort

So optimieren Sie den Scan von 1 großen Datei / Tabelle in Hive, um zu überprüfen, ob ein langer Punkt in einer Geometrieform enthalten ist

Ich versuche derzeit, jeden lat long Ping von einem Gerät mit seiner Postleitzahl zu verknüpfen. Ich habe Geräte-Ping-Daten für lange Zeiträume normalisiert und eine produktübergreifende / kartesische Produktverknüpfungstabelle erstellt, in ...