/**
 * Copyright (c) 2012-2012 Malhar, Inc.
 * All rights reserved.
 */
package com.malhartech.demos.performance;

import com.malhartech.api.ApplicationFactory;
import com.malhartech.api.DAG;
import org.apache.hadoop.conf.Configuration;

/**
 * Example of application configuration in Java.<p>
 */
public class Application implements ApplicationFactory
{
  private static final boolean inline = false;

  @Override
  public DAG getApplication(Configuration conf)
  {
    DAG dag = new DAG(conf);
    dag.getAttributes().attr(DAG.STRAM_CHECKPOINT_INTERVAL_MILLIS).set(0); // disable operator state saving

    RandomWordInputModule wordGenerator = dag.addOperator("wordGenerator", RandomWordInputModule.class);
//    DoNothingModule<byte[]> noOpProcessor = dag.addOperator("noOpProcessor", new DoNothingModule<byte[]>());
    WordCountModule<byte[]> counter = dag.addOperator("counter", WordCountModule.class);

//    dag.addStream("Generator2Processor", wordGenerator.output, noOpProcessor.input).setInline(inline);
//    dag.addStream("Processor2Counter", noOpProcessor.output, counter.input).setInline(inline);

    dag.addStream("Generator2Counter", wordGenerator.output, counter.input).setInline(inline);
    return dag;
  }
}

@@ -878,16 +878,20 @@
 ounter%22,
+ new
  WordCou
@@ -898,22 +898,26 @@
 ntModule
-.class
+%3Cbyte%5B%5D%3E()
 );%0A%0A//  

Make more syntactically correct. No operational changes.