erreur « projection scalaire non valide » après avoir fait un REJOIGNEZ puis filtre dans Pig

Question

J'utilise Pig 0.12.1. Pourquoi ai-je une erreur lorsque je FILTER après avoir fait un JOIN par LEFT OUTER?

Voici un exemple modifié:

A = LOAD '$file1' USING PigStorage('\t') AS (idA:int, manufacturer:chararray); 
B = LOAD '$file2' USING PigStorage('\t') AS (idB:int, price:float); 
C = JOIN A BY idA LEFT OUTER, B BY idB; 
D = FILTER C BY price > 2.0; 

Pourquoi puis-je obtenir cette "projection scalaire non valide" erreur sur D:

ERROR pig.PigServer: exception during parsing: Error during parsing. Pig script failed to parse: 
Invalid scalar projection: D 

Answer 1

Essayez ceci, Vous pouvez accéder à la colonne de prix par,

D = FILTER C BY $3 > 2.0; 
or 
D = FILTER C BY B::price > 2.0; 

Answer 2

Essayez représentant toute NULL s dans la relation.

D = FILTER C BY price > 2.0 AND price is not null;