Exception dans le type coulée de Chararry de double dans le de PORC

J'ai un exemple de saisie des onglets séparés clé, valeur paire comme suit

B_1001@2012-06-15   [email protected]
B_1001@2012-06-18   [email protected]
B_1002@2012-09-26   [email protected]
B_1002@2012-09-28   [email protected]

et je suis le chargement de ce fichier en porc et en procédant de la manière suivante

a = load '/home/HadoopUser/Desktop/a.txt' as (key:chararray, value:chararray);

describe a;
a: {key: chararray,value: chararray}

b = foreach a generate key, flatten(STRSPLIT(value,'@',2)) as (v1:double,v2:float);
describe b;
b: {key: chararray,v1: double,v2: float}

c = group b by key;
 describe c;
c: {group: chararray,b: {key: chararray,v1: double,v2: float}}

cela fonctionne jusqu'ici
mais
lorsque j'utilise Arthematical des calculs sur les b.v1, je suis ClassCastException comme java.lang.La chaîne ne peut pas être utilisé pour java.lang.Double

mais décrivent donne aucune erreur

d = foreach c generate group,SUM(b.v1);
describe d;
d: {group: chararray,double}

quand je dump d; id donnant à l'exception

J'ai même essayé de typecasting 'b' ainsi

b = foreach a generate key, (tuple (double,double))STRSPLIT(value,'@',2);

maintenant quand je décris b;
Sa donne une erreur comme
Ne peut pas lancer de tuple avec le schéma tuple à tuple avec schéma n-uplet({double,double})

Merci de m'aider à savoir pourquoi est-elle venue comme cela, même décrire montre schéma correct.

OriginalL'auteur sudheer | 2013-09-26

  1. 7

    J'ai rencontré ce problème avant. Je ne trouve pas le bug tracker de lien pour l'instant, mais lorsque vous définissez le type de/'cast' avec un énoncé comme B = FOREACH A GENERATE key AS key: chararray il ne sera pas réellement cast le type (mais cela va changer la sortie de DESCRIBE). Vous avez raison, vous aurez à faire un cast explicite, et les docs dire que vous pouvez lancer une chararray pour un double. Essayez quelque chose comme:

    b1 = FOREACH b GENERATE key, (double)v1, (float)v2 ;

    Mise à jour: Voici le lien vers le bug: https://issues.apache.org/jira/browse/PIG-2315

    Merci beaucoup au-dessus de la chose qui a fonctionné exactement. ce lien m'a expliqué pourquoi ainsi stackoverflow.com/questions/12213659/... PORC Schéma. pig.apache.org/docs/r0.9.1/basic.html#Schemas

    OriginalL'auteur mr2ert