import { DataEntity } from '@terascope/utils'; import { OpConfig } from '../interfaces'; import ProcessorCore from './core/processor-core'; /** * A variation of "Processor" that can handle a batch of data at a time. */ export default abstract class BatchProcessor extends ProcessorCore { /** * A method called by {@link BatchProcessor#handle} * @returns an array of DataEntities */ abstract onBatch(batch: DataEntity[]): Promise; handle(input: DataEntity[]): Promise; }