COUNT फ़ंक्शन

Question

का अनुमान नहीं लगा सका मैं एक डेटासेट की गिनती खींचने के लिए एक सुअर लैटिन स्क्रिप्ट लिखने की कोशिश कर रहा हूं जिसे मैंने फ़िल्टर किया है।

यहाँ स्क्रिप्ट अब तक बताया गया है:

Could not infer the matching function for org.apache.pig.builtin.COUNT as multiple or none of them fit. Please use an explicit cast.

क्या मैं गलत कर रहा हूँ यहाँ:

/* scans by title */ 

scans   = LOAD '/hive/scans/*' USING PigStorage(',') AS (thetime:long,product_id:long,lat:double,lon:double,user:chararray,category:chararray,title:chararray); 
productscans = FILTER scans BY (title MATCHES 'proactiv'); 
scancount  = FOREACH productscans GENERATE COUNT($0); 
DUMP scancount; 

किसी कारण के लिए, मैं त्रुटि मिलती है? मुझे लगता है कि इसमें उस क्षेत्र के प्रकार के साथ कुछ करना है जिसमें मैं गुजर रहा हूं, लेकिन मैं इसे हल नहीं कर सकता।

TIA, जेसन

Answer 1

क्या यह आप जो खोज रहे हैं (सभी द्वारा समूह एक बैग में सब कुछ लाने के लिए और फिर वे आइटम गिनती):

scans   = LOAD '/hive/scans/*' USING PigStorage(',') AS (thetime:long,product_id:long,lat:double,lon:double,user:chararray,category:chararray,title:chararray); 
productscans = FILTER scans BY (title MATCHES 'proactiv'); 
grouped   = GROUP productscans ALL; 
count   = FOREACH grouped GENERATE COUNT(productscans); 
dump count; 

Answer 2

शायद

/* scans by title */ 

scans   = LOAD '/hive/scans/*' USING PigStorage(',') AS (thetime:long,product_id:long,lat:double,lon:double,user:chararray,category:chararray,title:chararray); 
productscans = FILTER scans BY (title MATCHES 'proactiv'); 
scancount  = FOREACH productscans GENERATE COUNT(productscans); 
DUMP scancount; 

Answer 3

COUNT वैश्विक गणना के लिए पिछले समूह के सभी बयान और समूह गणनाओं के लिए ग्रुप बाय स्टेटमेंट की आवश्यकता है।

आप किसी भी नीचे की उपयोग कर सकते हैं:

scans   = LOAD '/hive/scans/*' USING PigStorage(',') AS (thetime:long,product_id:long,lat:double,lon:double,user:chararray,category:chararray,title:chararray); 
productscans = FILTER scans BY (title MATCHES 'proactiv'); 
grouped   = GROUP productscans ALL; 
count   = FOREACH grouped GENERATE COUNT(productscans); 
DUMP scancount; 

या

scans   = LOAD '/hive/scans/*' USING PigStorage(',') AS (thetime:long,product_id:long,lat:double,lon:double,user:chararray,category:chararray,title:chararray); 
productscans = FILTER scans BY (title MATCHES 'proactiv'); 
grouped   = GROUP productscans ALL; 
count   = FOREACH grouped GENERATE COUNT($1); 
DUMP scancount;