Sign in
apache
/
pig
/
44a13795084009c1ce2f171e9b7bc5e8452f8bd0
/
.
/
test
/
org
/
apache
/
pig
/
builtin
/
avro
/
code
/
pig
/
directory_test.pig
blob: 231603676d3b9955545c848062621b8fb94ac7a2 [
file
] [
log
] [
blame
]
in
=
LOAD
'$INFILE'
USING
AvroStorage
;
out
=
FOREACH
(
GROUP
in
ALL
)
GENERATE
(
int
)
SUM
(
in
.
item
)
as
itemSum
:
int
,
(
int
)
COUNT_STAR
(
in
)
as
n
:
int
;
RMF $OUTFILE
;
STORE
out
INTO
'$OUTFILE'
USING
AvroStorage
(
'$AVROSTORAGE_OUT_1'
,
'$AVROSTORAGE_OUT_2'
);