blob: 8995990e39867d2a88a12d9e9e2de45773d136bb (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
|
-- REGISTER vespa-hadoop.jar -- Not needed in tests
-- Define Vespa query for retrieving blog posts
DEFINE BlogPostRecommendations
com.yahoo.vespa.hadoop.pig.VespaQuery(
'query=$ENDPOINT/search?query=<userid>&hits=100',
'rootnode=root/children/children',
'schema=rank:int,id:chararray,relevance:double,fields/id:chararray,fields/content:chararray'
);
-- Load data from a local file
users = LOAD 'src/test/resources/user_ids.csv' AS (userid:chararray);
users = FILTER users BY userid IS NOT null;
-- Run a set of queries against Vespa
recommendations = FOREACH users GENERATE userid, FLATTEN(BlogPostRecommendations(*));
-- Output recommendations
DUMP recommendations;
|