| 1 | ;
|
| 2 | var __importDefault = (this && this.__importDefault) || function (mod) {
|
| 3 | return (mod && mod.__esModule) ? mod : { "default": mod };
|
| 4 | };
|
| 5 | Object.defineProperty(exports, "__esModule", { value: true });
|
| 6 | const utils_1 = require("@terascope/utils");
|
| 7 | const processor_core_1 = __importDefault(require("./core/processor-core"));
|
| 8 | /**
|
| 9 | * A variation of Processor that can process a single DataEntity at a time.
|
| 10 | * This processor should return a modified DataEntity.
|
| 11 | */
|
| 12 | class MapProcessor extends processor_core_1.default {
|
| 13 | /**
|
| 14 | * A generic method called by the Teraslice framework, calls {@link #map}
|
| 15 | * @param input an array of DataEntities
|
| 16 | * @returns an array of DataEntities
|
| 17 | */
|
| 18 | async handle(input) {
|
| 19 | return input.map((data) => utils_1.DataEntity.make(this.map(data)));
|
| 20 | }
|
| 21 | }
|
| 22 | exports.default = MapProcessor;
|
| 23 | //# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoibWFwLXByb2Nlc3Nvci5qcyIsInNvdXJjZVJvb3QiOiIiLCJzb3VyY2VzIjpbIi4uLy4uL3NyYy9vcGVyYXRpb25zL21hcC1wcm9jZXNzb3IudHMiXSwibmFtZXMiOltdLCJtYXBwaW5ncyI6Ijs7Ozs7QUFDQSw0Q0FBOEM7QUFDOUMsMkVBQWtEO0FBRWxEOzs7R0FHRztBQUVILE1BQThCLFlBQTJCLFNBQVEsd0JBQWdCO0lBTzdFOzs7O01BSUU7SUFDRixLQUFLLENBQUMsTUFBTSxDQUFDLEtBQW1CO1FBQzVCLE9BQU8sS0FBSyxDQUFDLEdBQUcsQ0FBQyxDQUFDLElBQUksRUFBRSxFQUFFLENBQUMsa0JBQVUsQ0FBQyxJQUFJLENBQUMsSUFBSSxDQUFDLEdBQUcsQ0FBQyxJQUFJLENBQUMsQ0FBQyxDQUFDLENBQUM7SUFDaEUsQ0FBQztDQUNKO0FBZkQsK0JBZUMifQ== |
| \ | No newline at end of file |