BatchEngine

constructor(environment: Environment<T, P>, scheduler: BatchedScheduler<T>, outputReplayStrategy: String = "aggregate")(source)
constructor(environment: Environment<T, P>, scheduler: String, batchSizeOrEpsilon: Number, outputReplayStrategy: String = "aggregate")(source)