class FileReadWordCount extends WordCount {

  @Override
  public StormTopology getTopology(Config config) {
    spout = new FileReadSpout(BenchmarkUtils.ifAckEnabled(config));
    return super.getTopology(config);
  }

}