La ruche: Somme sur un groupe déterminé (HiveQL)

J'ai une table:

key    product_code    cost
1      UK              20
1      US              10
1      EU              5
2      UK              3
2      EU              6

Je voudrais trouver la somme de tous les produits pour chaque groupe de "clé" et d'ajouter à chaque ligne. Par exemple pour la clé = 1, trouver la somme des coûts de tous les produits (20+10+5=35) et ensuite ajouter le résultat à toutes les lignes qui correspondent à la clé = 1. Donc résultat final:

key    product_code    cost     total_costs
1      UK              20       35
1      US              10       35
1      EU              5        35
2      UK              3        9
2      EU              6        9

Je préfère le faire sans l'aide d'un sous-joignez-vous que ce serait inefficace. Ma meilleure idée serait d'utiliser le over de la fonction en collaboration avec le sum fonction, mais je ne peux pas le faire fonctionner. De mon mieux essayer:

SELECT key, product_code, sum(costs) over(PARTITION BY key)
FROM test
GROUP BY key, product_code;

Iv avait un look à la docs mais il y a tellement alambiquées, je n'ai aucune idée de la façon de travailler sur la façon de le faire. Im en utilisant la Ruche v0.12.0, HDP v2.0.6, hortonworks a distribution Hadoop.

Quel est le problème avec vos meilleurs essayer ?
Il donne juste une erreur de syntaxe. Je dois être en utilisant le plus de fonction dans le mauvais sens

OriginalL'auteur joshlk | 2014-08-01

8

Similaire à @VB_ réponse, utilisez le BETWEEN UNBOUNDED PRECEDING AND UNBOUNDED FOLLOWING déclaration.

La requête HiveQL est donc:
```
SELECT key, product_code,
SUM(costs) OVER (PARTITION BY key ORDER BY key ROWS BETWEEN UNBOUNDED PRECEDING AND UNBOUNDED FOLLOWING)
FROM test;
```
OriginalL'auteur joshlk
4

Vous pouvez utiliser BETWEEN UNBOUNDED PRECEDING AND CURRENT ROW de réaliser que sans une auto-jointure.

Code comme ci-dessous:
```
SELECT a, SUM(b) OVER (PARTITION BY c ORDER BY d ROWS BETWEEN UNBOUNDED PRECEDING AND CURRENT ROW)
FROM T;
```
On y est presque! cette somme jusqu'à la ligne actuelle. Iv réalisé maintenant que vous avez besoin de le la ENTRE UNBOUNDED preceding ET de la SURABONDANCE de la déclaration SUIVANTE

OriginalL'auteur VB_

La fonction analytique somme donne des sommes cumulées. Par exemple, si vous avez fait:

select key, product_code, cost, sum(cost) over (partition by key) as total_costs from test

ensuite, vous recevez:

key    product_code    cost     total_costs
1      UK              20       20
1      US              10       30
1      EU              5        35
2      UK              3        3
2      EU              6        9

qui, paraît-il, n'est pas ce que vous voulez.

Au lieu de cela, vous devez utiliser la fonction d'agrégation somme, combiné avec une jointure réflexive pour ce faire:

select test.key, test.product_code, test.cost, agg.total_cost
from (
  select key, sum(cost) as total_cost
  from test
  group by key
) agg
join test
on agg.key = test.key;

Est-il un moyen de le faire sans l'aide d'une jointure réflexive?

OriginalL'auteur Joe K

Le tableau ci-dessus ressemblait

key    product_code    cost
1      UK              20
1      US              10
1      EU              5
2      UK              3
2      EU              6

L'utilisateur voulait un tableau avec le total des coûts comme suit

key    product_code    cost     total_costs
1      UK              20       35
1      US              10       35
1      EU              5        35
2      UK              3        9
2      EU              6        9

À cet effet, nous avons utilisé la requête suivante

SELECT key, product_code,
SUM(costs) OVER (PARTITION BY key ORDER BY key ROWS BETWEEN UNBOUNDED PRECEDING AND UNBOUNDED FOLLOWING)
FROM test;

So far So good.
Je veux une colonne de plus, compter le nombre d'occurences de chaque pays

key    product_code    cost     total_costs     occurences
1      UK              20       35              2
1      US              10       35              1
1      EU              5        35              2
2      UK              3        9               2
2      EU              6        9               2

À cet effet, j'ai utilisé la requête suivante

SELECT key, product_code,
SUM(costs) OVER (PARTITION BY key ORDER BY key ROWS BETWEEN UNBOUNDED PRECEDING AND UNBOUNDED FOLLOWING) as total_costs
COUNT(product code) OVER (PARTITION BY key ORDER BY key ROWS BETWEEN UNBOUNDED PRECEDING AND UNBOUNDED FOLLOWING) as occurences
FROM test;

Malheureusement, ce n'est pas de travail. J'obtiens une erreur cryptique. Pour exclure une erreur dans ma requête je veux vous demander si j'ai fait quelque chose de mal.
Grâce

Bien que très ancienne, mais le COMTE(code de produit) devraient être COUNT(product_code) Aussi je suis en cours d'exécution de la Ruche-0,13 et j'ai pu obtenir le résultat souhaité en exécutant la requête suivante touche de sélection,product_code, le coût , la somme(coût) over( partition en clé de ), comte(product_code) over( partition by product_code) p_code_count DE prod_key;

OriginalL'auteur Peter

0

Cette requête me donne un résultat parfait

select key, product_code, cost, sum(cost) over (partition by key) as total_costs from zone;

OriginalL'auteur Ashish Mohan

Vous devez vous connecter pour publier un commentaire.