Sign in
apache
/
datafu
/
refs/heads/0.0.8
/
.
/
test
/
pig
/
datafu
/
test
/
pig
/
bags
/
weightedSampleScoreTest.pig
blob: e231a8df3938ebcc135946caf6567977b5afb88a [
file
] [
log
] [
blame
]
register
$JAR_PATH
define
WeightedSample
datafu
.
pig
.
bags
.
WeightedSample
();
data
=
LOAD
'input'
AS
(
A
:
bag
{
T
:
tuple
(
v1
:
chararray
,
v2
:
INT
)});
data2
=
FOREACH data GENERATE
WeightedSample
(
A
,
1
);
describe data2
;
STORE data2 INTO
'output'
;