BatchEndOfStream

constructor(stream: DestinationStream.Descriptor, taskName: String, part: Int, totalInputCount: Long)