BatchCoordinator

constructor(name: String, options: BatchOptions, writer: BatchWriter<T>, metrics: WowMetrics = WowMetrics.NONE)