class BoundedEventSource extends BoundedSource<Event> {

  @Override
  public List<BoundedEventSource> split(long desiredBundleSizeBytes, PipelineOptions options) {
    NexmarkUtils.info("slitting bounded source %s into %d sub-sources", config, numEventGenerators);
    List<BoundedEventSource> results = new ArrayList<>();
    // Ignore desiredBundleSizeBytes and use numEventGenerators instead.
    for (GeneratorConfig subConfig : config.split(numEventGenerators)) {
      results.add(new BoundedEventSource(subConfig, 1));
    }
    return results;
  }

  public  BoundedEventSource(GeneratorConfig config, int numEventGenerators);

}