Merge with master (Need to update Samza and multithreads code accordi…

…ng to the new API)
YahooArchive · Jul 8, 2014 · 51d9a47 · 51d9a47
1 parent a573d04
commit 51d9a47
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 4 deletions.
diff --git a/samoa-api/src/main/java/com/yahoo/labs/samoa/topology/Topology.java b/samoa-api/src/main/java/com/yahoo/labs/samoa/topology/Topology.java
@@ -20,9 +20,7 @@
  * #L%
  */
 
-
 public interface Topology {
-
 	/*
 	 * Name
 	 */
@@ -45,7 +43,7 @@ public interface Topology {
 	 * Entrance Processing Items
 	 */
 	/**
-	 * Add an EntranceProcessingItem to this topologyç
+	 * Add an EntranceProcessingItem to this topology
 	 * 
 	 * @param epi
 	 * 			the EntranceProcessingItem to be added

diff --git a/samoa-local/src/main/java/com/yahoo/labs/samoa/topology/impl/SimpleProcessingItem.java b/samoa-local/src/main/java/com/yahoo/labs/samoa/topology/impl/SimpleProcessingItem.java
@@ -76,7 +76,6 @@ public void processEvent(ContentEvent event, int counter) {
             for (int j = 0; j < parallelism; j++) {
                 arrayProcessingItem[j] = this.copy();
                 arrayProcessingItem[j].getProcessor().onCreate(j);
-                //System.out.println(j + " PROCESSOR create " + arrayProcessingItem[j].getProcessor());
             }
         }
         if (this.arrayProcessingItem != null) {