commit ad6c8a936bc5f33f7d2c604d56a92d5ed5686bb4
author Timothy Farkas <tim@datatorrent.com> Mon Aug 25 19:17:50 2014 -0700
committer Timothy Farkas <tim@datatorrent.com> Mon Aug 25 19:17:50 2014 -0700
tree b2e624b6ab190961fb09a70afb78fc08ddfb3454
parent 2e7d1012d7dd9b9a36534971f8265ed1c34397ca

Cleaned up code.

library/src/main/java/com/datatorrent/lib/io/fs/AbstractThroughputHashFSDirectoryInputOperator.java

diff --git a/library/src/main/java/com/datatorrent/lib/io/fs/AbstractThroughputHashFSDirectoryInputOperator.java b/library/src/main/java/com/datatorrent/lib/io/fs/AbstractThroughputHashFSDirectoryInputOperator.java
index 48a2551..7d301cf 100644
--- a/library/src/main/java/com/datatorrent/lib/io/fs/AbstractThroughputHashFSDirectoryInputOperator.java
+++ b/library/src/main/java/com/datatorrent/lib/io/fs/AbstractThroughputHashFSDirectoryInputOperator.java
@@ -119,7 +119,7 @@
       
       if (oper.currentFile != null) {
         totalFileCount++;
-      }  
+      }
     }
     
     if(!isInitialParitition) {
@@ -155,10 +155,8 @@
   {
     int fileCount = 0;
     
-    for(OperatorStats operatorStats: batchedOperatorStats.getLastWindowedStats())
-    {
-      if(operatorStats.counters != null)
-      {
+    for(OperatorStats operatorStats: batchedOperatorStats.getLastWindowedStats()) {
+      if(operatorStats.counters != null) {
         fileCount = (Integer) operatorStats.counters;
       }
     }