Articles of hive

Sélection dynamic des colonnes d'une table hive / sql

Je suis un débutant en hive et également novice en sql aussi bien. Donc, au cas où j'applique ma solution d'une manière inappropriée, s'il vous plaît éclairer moi. Mon application prend ID en tant qu'input de l'user. Ensuite, j'ai besoin de vérifier les valeurs Pname qui lui correspondent dans le tableau 1, puis en fonction […]

SQOOP EXPORT: java.sql.BatchUpdateException: le paramètre # 1 n'a pas été défini

J'essaye de faire l'export de sqoop au server de sql et en utilisant la command ci-dessous: sqoop-export -D mapred.job.name=SQOOP:TEST:UPSERT -Dsqoop.export.records.per.statement=1 –connect $CONN –username $USER –password $PWD –table table_test_1 –hcatalog-database default –hcatalog-table test_1 –input-fields-terminated-by '\001' –input-null-ssortingng '\\N' –update-key ID –update-mode allowinsert –verbose –columns "name,id,age" Et je reçois l'erreur ci-dessous. Je ne sais pas pourquoi il est […]

Meilleur équivalent de la command SQL Server UPDATE dans Hive

Quel est le meilleur équivalent (less cher) de la command SQL Server UPDATE SET dans Hive ? Par exemple, considérez le cas dans lequel je veux convertir la requête suivante: UPDATE TABLE employee SET visaEligibility = 'YES' WHERE experienceMonths > 36 à la requête Hive équivalente.

Chaining se joint à SQL en se basant sur une table dynamic

Le titre n'est peut-être pas exact pour la question mais c'est parti! J'ai le tableau suivant: id1 id2 status 1 2 a 2 3 b 3 4 c 6 7 d 7 8 e 8 9 f 9 10 g Je voudrais get le premier id1 et le dernier status basé sur une string dynamic, […]

Convertir varchar en hexadécimal en server sql

Je veux une fonction pour convertir un varchar en hexadécimal en server sql. Aidez-moi, s'il vous plaît. PS Je vais utiliser unhex () dans Hive pour essayer de refind la valeur d'origine. En effet, mes données contiennent des caractères spéciaux et une barre oblique inverse et la table externe HIVE ne le reconnaît pas

Requête alternative pour joindre deux requêtes distinctes

Puis-je combiner q1 et q2 en une seule requête? J'ai besoin de la requête alternative dans Hive. SELECT q3.* FROM ( ( SELECT prod_id, prod_name, cust_id FROM sell_info GROUP BY prod_id, prod_name, cust_id )q1 JOIN ( SELECT cust_name, cust_address FROM cust_info WHERE cust_type LIKE 'Reg%' )q2 ON q1.cust_id = q2.cust_id ) q3;

Erreur d'import Sqoop avec le type de données BigInt

Lors de l'import d'une table de SQL Server vers Hive, je suis confronté à l'exception suivante /tmp/sqoop-hduser/comstack/a6db7754847c4d49c9164758fcc079d7/ReceivedData.java:513: error: incompatible types this.IDReceivedData = Long.valueOf(__dataIn.readLong()); required: Long found: Double /tmp/sqoop-hduser/comstack/a6db7754847c4d49c9164758fcc079d7/ReceivedData.java:1007: error: incompatible types this.IDReceivedData = Long.valueOf(__cur_str); ^ required: Long found: Double Note: /tmp/sqoop-hduser/comstack/a6db7754847c4d49c9164758fcc079d7/ReceivedData.java uses or overrides a deprecated API. Note: Recomstack with -Xlint:deprecation for details. 2 errors […]

Left Outer Join renvoie la valeur NULL dans l'instruction select

t.contractid=111111 valeurs nulles si j'utilise une jointure externe gauche même après avoir mentionné t.contractid=111111 dans l'instruction select . S'il vous plaît laissez-moi savoir comment résoudre ce problème. select t.contractid,r.contractid,t.batchno from tableA t left join tableB r on t.contractid=r.contractid and t.PayGrp=r.PayGrp and t.PriNo=r.PriNo where t.contractid=111111 and t.PayGrp=0 and t.batchno=201701 and t.prino=3 and r.contractid is null Exemple […]

comment countr des lignes consécutives sur une colonne en sql

J'ai une table avec 3 colonnes. Données de table Customer_id timestamp page_url 1234 10-11-2015 10:00:12 page1 1234 10-11-2015 10:00:16 page3 1234 10-11-2015 10:00:19 page2 1234 10-11-2015 10:01:12 page1 1234 10-11-2015 10:01:20 page2 — this should be counted as 1 1234 10-11-2015 10:01:50 page2 — this should be counted as 1 1234 10-11-2015 10:02:12 page4 5678 […]

Sqoop & Hadoop – Comment joindre / merge les anciennes données et les nouveldatatables imscopes par Sqoop en mode lastmodified?

Context: J'ai une table avec le schéma suivant sur un server SQL. Les mises à jour des lignes existantes sont possibles et de nouvelles lignes sont également ajoutées à cette table. unique_id | user_id | last_login_date | count 123-111 | 111 | 2016-06-18 19:07:00.0 | 180 124-100 | 100 | 2016-06-02 10:27:00.0 | 50 J'utilise […]