class BoundedEventSource extends BoundedSource<Event> {

  @Override
  public EventReader createReader(PipelineOptions options) {
    NexmarkUtils.info("creating initial bounded reader for %s", config);
    return new EventReader(this, config);
  }

  public  BoundedEventSource(GeneratorConfig config, int numEventGenerators);

}