BatchCoordinator

constructor(name: String, options: BatchOptions, writer: BatchWriter<T>, keySelector: (T) -> Any = { Unit }, metrics: WowMetrics = WowMetrics.NONE)