alien4u
08/25/2021, 7:27 PMbattk
08/25/2021, 7:29 PMalien4u
08/25/2021, 7:31 PMalien4u
08/25/2021, 7:32 PMconst getInputData = (inputContext) => {
return ['1', '2', '3'];
}
alien4u
08/25/2021, 7:33 PMalien4u
08/25/2021, 7:34 PMalien4u
08/25/2021, 7:34 PMconst summarize = (summaryContext) => {
/* Checking for Errors */
handleErrorIfAny(summaryContext);
}
alien4u
08/25/2021, 7:35 PM/**
* Handle error (if any) right now just log and email, but could be expanded.
*
* @param {Object} pSummary
*/
const handleErrorIfAny = (pSummary) => {
const oInputSummary = pSummary.inputSummary;
const oMapSummary = pSummary.mapSummary;
const oReduceSummary = pSummary.reduceSummary;
if (oInputSummary.error) {
var oError = error.create({
name: 'INPUT_STAGE_FAILED',
message: oInputSummary.error
});
handleErrorAndSendNotification(oError, 'getInputData');
}
handleErrorInStage('map', oMapSummary);
handleErrorInStage('reduce', oReduceSummary);
}
alien4u
08/25/2021, 7:35 PMbattk
08/25/2021, 7:43 PMalien4u
08/25/2021, 7:48 PMalien4u
08/25/2021, 7:49 PMalien4u
08/25/2021, 7:49 PM