Database Reference
In-Depth Information
job
.
setReducerClass
(
JoinReducer
.
class
);
job
.
setOutputKeyClass
(
Text
.
class
);
return
job
.
waitForCompletion
(
true
) ?
0
:
1
;
}
public static
void
main
(
String
[]
args
)
throws
Exception
{
int
exitCode
=
ToolRunner
.
run
(
new
JoinRecordWithStationName
(),
args
);
System
.
exit
(
exitCode
);
}
}
Running the program on the sample data yields the following output:
011990-99999 SIHCCAJAVRI
0067011990999991950051507004...
011990-99999 SIHCCAJAVRI
0043011990999991950051512004...
011990-99999 SIHCCAJAVRI
0043011990999991950051518004...
012650-99999 TYNSET-HANSMOEN
0043012650999991949032412004...
012650-99999 TYNSET-HANSMOEN
0043012650999991949032418004...
