From 35e5a9f42048297ce06d4a882cccfccfc1b4a7f7 Mon Sep 17 00:00:00 2001
From: Apex Dev <dev@apex.apache.org>
Date: Wed, 19 Apr 2017 19:41:54 -0700
Subject: [PATCH] APEXMALHAR-2468 Fixed Checkstyle and Log4j

---
 examples/fileIO/pom.xml                       | 20 ++++
 examples/fileIO/src/assemble/appPackage.xml   | 20 ++++
 .../apex/examples/fileIO/Application.java     | 26 ++++-
 .../apex/examples/fileIO/BytesFileWriter.java | 23 ++++-
 .../apex/examples/fileIO/FileReader.java      | 32 +++++--
 .../apex/examples/fileIO/FileWriter.java      | 30 +++++-
 .../fileIO/ThroughputBasedApplication.java    | 23 ++++-
 .../fileIO/ThroughputBasedReader.java         | 26 ++++-
 .../examples/fileIOMultiDir/Application.java  | 28 ++++--
 .../examples/fileIOMultiDir/FileReader.java   | 28 +++++-
 .../fileIOMultiDir/FileReaderMultiDir.java    | 96 ++++++++++++++-----
 .../examples/fileIOMultiDir/FileWriter.java   | 30 +++++-
 .../examples/fileIOSimple/Application.java    | 29 +++++-
 .../fileIOSimple/FileOutputOperator.java      | 32 ++++++-
 .../apex/examples/fileOutput/Application.java | 21 +++-
 .../apex/examples/fileOutput/FileWriter.java  | 32 ++++++-
 .../fileOutput/SequenceGenerator.java         | 44 ++++++++-
 .../resources/META-INF/properties-FileIO.xml  | 20 ++++
 .../properties-ThroughputBasedFileIO.xml      | 20 ++++
 .../META-INF/properties-fileIO-multiDir.xml   | 20 ++++
 .../META-INF/properties-fileIOSimple.xml      | 20 ++++
 .../META-INF/properties-fileOutput.xml        | 20 ++++
 .../main/resources/unused-log4j.properties    | 19 ++++
 .../apex/examples/fileIO/ApplicationTest.java | 37 +++++--
 .../ThroughputBasedApplicationTest.java       | 27 +++++-
 .../fileIOMultiDir/ApplicationTest.java       | 54 ++++++++---
 .../fileIOSimple/ApplicationTest.java         | 41 ++++++--
 .../examples/fileOutput/ApplicationTest.java  | 36 +++++--
 .../src/test/resources/log4j.properties       | 21 ++++
 29 files changed, 753 insertions(+), 122 deletions(-)

diff --git a/examples/fileIO/pom.xml b/examples/fileIO/pom.xml
index 812af59be2..e069acc6f3 100644
--- a/examples/fileIO/pom.xml
+++ b/examples/fileIO/pom.xml
@@ -1,4 +1,24 @@
 <?xml version="1.0" encoding="UTF-8"?>
+<!--
+
+    Licensed to the Apache Software Foundation (ASF) under one
+    or more contributor license agreements.  See the NOTICE file
+    distributed with this work for additional information
+    regarding copyright ownership.  The ASF licenses this file
+    to you under the Apache License, Version 2.0 (the
+    "License"); you may not use this file except in compliance
+    with the License.  You may obtain a copy of the License at
+
+      http://www.apache.org/licenses/LICENSE-2.0
+
+    Unless required by applicable law or agreed to in writing,
+    software distributed under the License is distributed on an
+    "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+    KIND, either express or implied.  See the License for the
+    specific language governing permissions and limitations
+    under the License.
+
+-->
 <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
   <modelVersion>4.0.0</modelVersion>
   
diff --git a/examples/fileIO/src/assemble/appPackage.xml b/examples/fileIO/src/assemble/appPackage.xml
index 7ad071c69f..a8708074a2 100644
--- a/examples/fileIO/src/assemble/appPackage.xml
+++ b/examples/fileIO/src/assemble/appPackage.xml
@@ -1,3 +1,23 @@
+<!--
+
+    Licensed to the Apache Software Foundation (ASF) under one
+    or more contributor license agreements.  See the NOTICE file
+    distributed with this work for additional information
+    regarding copyright ownership.  The ASF licenses this file
+    to you under the Apache License, Version 2.0 (the
+    "License"); you may not use this file except in compliance
+    with the License.  You may obtain a copy of the License at
+
+      http://www.apache.org/licenses/LICENSE-2.0
+
+    Unless required by applicable law or agreed to in writing,
+    software distributed under the License is distributed on an
+    "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+    KIND, either express or implied.  See the License for the
+    specific language governing permissions and limitations
+    under the License.
+
+-->
 <assembly xmlns="http://maven.apache.org/plugins/maven-assembly-plugin/assembly/1.1.2"
     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
     xsi:schemaLocation="http://maven.apache.org/plugins/maven-assembly-plugin/assembly/1.1.2 http://maven.apache.org/xsd/assembly-1.1.2.xsd">
diff --git a/examples/fileIO/src/main/java/org/apache/apex/examples/fileIO/Application.java b/examples/fileIO/src/main/java/org/apache/apex/examples/fileIO/Application.java
index 2edac4bfb4..1831767f5d 100644
--- a/examples/fileIO/src/main/java/org/apache/apex/examples/fileIO/Application.java
+++ b/examples/fileIO/src/main/java/org/apache/apex/examples/fileIO/Application.java
@@ -1,17 +1,33 @@
 /**
- * Put your copyright and license info here.
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
  */
+
 package org.apache.apex.examples.fileIO;
 
 import org.apache.hadoop.conf.Configuration;
 
-import com.datatorrent.api.annotation.ApplicationAnnotation;
-import com.datatorrent.api.StreamingApplication;
 import com.datatorrent.api.DAG;
+import com.datatorrent.api.StreamingApplication;
+import com.datatorrent.api.annotation.ApplicationAnnotation;
 
-import static com.datatorrent.api.Context.PortContext.*;
+import static com.datatorrent.api.Context.PortContext.PARTITION_PARALLEL;
 
-@ApplicationAnnotation(name="FileIO")
+@ApplicationAnnotation(name = "FileIO")
 public class Application implements StreamingApplication
 {
 
diff --git a/examples/fileIO/src/main/java/org/apache/apex/examples/fileIO/BytesFileWriter.java b/examples/fileIO/src/main/java/org/apache/apex/examples/fileIO/BytesFileWriter.java
index fa9ea6512a..6484c1e80a 100644
--- a/examples/fileIO/src/main/java/org/apache/apex/examples/fileIO/BytesFileWriter.java
+++ b/examples/fileIO/src/main/java/org/apache/apex/examples/fileIO/BytesFileWriter.java
@@ -1,3 +1,22 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
 package org.apache.apex.examples.fileIO;
 
 import java.util.ArrayList;
@@ -11,8 +30,8 @@
 public class BytesFileWriter extends AbstractFileOutputOperator<byte[]>
 {
   private static final transient Logger LOG = LoggerFactory.getLogger(BytesFileWriter.class);
-  private static final char START_FILE = ThroughputBasedReader.START_FILE,
-      FINISH_FILE = ThroughputBasedReader.FINISH_FILE;
+  private static final char START_FILE = ThroughputBasedReader.START_FILE;
+  private static final char FINISH_FILE = ThroughputBasedReader.FINISH_FILE;
   private String fileName; // current file name
   private boolean eof;
   private transient ArrayList<byte[]> savedLines = new ArrayList<>();
diff --git a/examples/fileIO/src/main/java/org/apache/apex/examples/fileIO/FileReader.java b/examples/fileIO/src/main/java/org/apache/apex/examples/fileIO/FileReader.java
index e83ba21caf..f38bacf5e7 100644
--- a/examples/fileIO/src/main/java/org/apache/apex/examples/fileIO/FileReader.java
+++ b/examples/fileIO/src/main/java/org/apache/apex/examples/fileIO/FileReader.java
@@ -1,3 +1,22 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
 package org.apache.apex.examples.fileIO;
 
 import java.io.BufferedReader;
@@ -5,14 +24,14 @@
 import java.io.InputStream;
 import java.io.InputStreamReader;
 
-import com.datatorrent.api.Context;
-import org.apache.hadoop.fs.Path;
-
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-import com.datatorrent.api.annotation.OutputPortFieldAnnotation;
+import org.apache.hadoop.fs.Path;
+
+import com.datatorrent.api.Context;
 import com.datatorrent.api.DefaultOutputPort;
+import com.datatorrent.api.annotation.OutputPortFieldAnnotation;
 import com.datatorrent.lib.io.fs.AbstractFileInputOperator;
 
 /**
@@ -26,7 +45,8 @@ public class FileReader extends AbstractFileInputOperator<String>
   /**
    * prefix for file start and finish control tuples
    */
-  public static final char START_FILE = '(', FINISH_FILE = ')';
+  public static final char START_FILE = '(';
+  public static final char FINISH_FILE = ')';
 
   /**
    * output port for file data
@@ -74,7 +94,7 @@ public void endWindow()
   @Override
   public void emitTuples()
   {
-    if ( ! stop ) {        // normal processing
+    if (!stop) {        // normal processing
       super.emitTuples();
       return;
     }
diff --git a/examples/fileIO/src/main/java/org/apache/apex/examples/fileIO/FileWriter.java b/examples/fileIO/src/main/java/org/apache/apex/examples/fileIO/FileWriter.java
index 16da820e87..0e0c1d18cc 100644
--- a/examples/fileIO/src/main/java/org/apache/apex/examples/fileIO/FileWriter.java
+++ b/examples/fileIO/src/main/java/org/apache/apex/examples/fileIO/FileWriter.java
@@ -1,3 +1,22 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
 package org.apache.apex.examples.fileIO;
 
 import java.util.ArrayList;
@@ -16,7 +35,8 @@ public class FileWriter extends AbstractFileOutputOperator<String>
   private static final Logger LOG = LoggerFactory.getLogger(FileWriter.class);
   private static final String CHARSET_NAME = "UTF-8";
   private static final String NL = System.lineSeparator();
-  private static final char START_FILE = FileReader.START_FILE, FINISH_FILE = FileReader.FINISH_FILE;
+  private static final char START_FILE = FileReader.START_FILE;
+  private static final char FINISH_FILE = FileReader.FINISH_FILE;
 
   private String fileName;    // current file name
 
@@ -50,7 +70,7 @@ private void processControlTuple(final String tuple)
       fileName = tuple.substring(1);
 
       // if we have saved lines, process them
-      if ( ! savedLines.isEmpty() ) {
+      if (!savedLines.isEmpty()) {
         LOG.debug("Processing {} saved lines", savedLines.size());
         for (String line : savedLines) {
           processTuple(line);
@@ -67,7 +87,7 @@ private void processControlTuple(final String tuple)
       String name = tuple.substring(0, last);
 
       // sanity check : should match what we got with start control tuple
-      if (null == fileName || ! fileName.equals(name)) {
+      if (null == fileName || !fileName.equals(name)) {
         throw new RuntimeException(String.format("Error: fileName = %s != %s = tuple", fileName, tuple));
       }
 
@@ -93,7 +113,7 @@ public void processTuple(String tuple)
   @Override
   public void endWindow()
   {
-    if ( ! eof ) {
+    if (!eof) {
       return;
     }
 
@@ -121,7 +141,7 @@ protected byte[] getBytesForTuple(String line)
   {
     LOG.debug("getBytesForTuple: line.length = {}", line.length());
 
-    byte result[] = null;
+    byte[] result = null;
     try {
       result = (line + NL).getBytes(CHARSET_NAME);
     } catch (Exception e) {
diff --git a/examples/fileIO/src/main/java/org/apache/apex/examples/fileIO/ThroughputBasedApplication.java b/examples/fileIO/src/main/java/org/apache/apex/examples/fileIO/ThroughputBasedApplication.java
index 15e3081870..001e9c939b 100644
--- a/examples/fileIO/src/main/java/org/apache/apex/examples/fileIO/ThroughputBasedApplication.java
+++ b/examples/fileIO/src/main/java/org/apache/apex/examples/fileIO/ThroughputBasedApplication.java
@@ -1,6 +1,23 @@
-package org.apache.apex.examples.fileIO;
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
 
-import static com.datatorrent.api.Context.PortContext.PARTITION_PARALLEL;
+package org.apache.apex.examples.fileIO;
 
 import org.apache.hadoop.conf.Configuration;
 
@@ -8,6 +25,8 @@
 import com.datatorrent.api.StreamingApplication;
 import com.datatorrent.api.annotation.ApplicationAnnotation;
 
+import static com.datatorrent.api.Context.PortContext.PARTITION_PARALLEL;
+
 @ApplicationAnnotation(name = "ThroughputBasedFileIO")
 public class ThroughputBasedApplication implements StreamingApplication
 {
diff --git a/examples/fileIO/src/main/java/org/apache/apex/examples/fileIO/ThroughputBasedReader.java b/examples/fileIO/src/main/java/org/apache/apex/examples/fileIO/ThroughputBasedReader.java
index ad1e257879..c8fb9c4aa2 100644
--- a/examples/fileIO/src/main/java/org/apache/apex/examples/fileIO/ThroughputBasedReader.java
+++ b/examples/fileIO/src/main/java/org/apache/apex/examples/fileIO/ThroughputBasedReader.java
@@ -1,3 +1,22 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
 package org.apache.apex.examples.fileIO;
 
 import java.io.File;
@@ -17,7 +36,8 @@ public class ThroughputBasedReader extends AbstractThroughputFileInputOperator<b
   /**
    * prefix for file start and finish control tuples
    */
-  public static final char START_FILE = '(', FINISH_FILE = ')';
+  public static final char START_FILE = '(';
+  public static final char FINISH_FILE = ')';
   private static final int DEFAULT_BLOCK_SIZE = 1024 * 64;
 
   @OutputPortFieldAnnotation(optional = false)
@@ -120,7 +140,7 @@ public void setBlockSize(int blockSize)
 
   /**
    * Gets number of blocks to emit per window
-   * 
+   *
    * @return
    */
   public int getBlockThreshold()
@@ -130,7 +150,7 @@ public int getBlockThreshold()
 
   /**
    * Sets number of blocks to emit per window
-   * 
+   *
    * @param blockThreshold
    */
   public void setBlockThreshold(int blockThreshold)
diff --git a/examples/fileIO/src/main/java/org/apache/apex/examples/fileIOMultiDir/Application.java b/examples/fileIO/src/main/java/org/apache/apex/examples/fileIOMultiDir/Application.java
index 40542827e6..8da1c95d60 100644
--- a/examples/fileIO/src/main/java/org/apache/apex/examples/fileIOMultiDir/Application.java
+++ b/examples/fileIO/src/main/java/org/apache/apex/examples/fileIOMultiDir/Application.java
@@ -1,18 +1,32 @@
 /**
- * Put your copyright and license info here.
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
  */
+
 package org.apache.apex.examples.fileIOMultiDir;
 
 import org.apache.hadoop.conf.Configuration;
-
-import com.datatorrent.api.annotation.ApplicationAnnotation;
-import com.datatorrent.api.StreamingApplication;
 import com.datatorrent.api.DAG;
+import com.datatorrent.api.StreamingApplication;
+import com.datatorrent.api.annotation.ApplicationAnnotation;
 
-//import com.datatorrent.lib.io.fs.FileReaderMultiDir;
-import static com.datatorrent.api.Context.PortContext.*;
+import static com.datatorrent.api.Context.PortContext.PARTITION_PARALLEL;
 
-@ApplicationAnnotation(name="FileIO")
+@ApplicationAnnotation(name = "FileIO")
 public class Application implements StreamingApplication
 {
 
diff --git a/examples/fileIO/src/main/java/org/apache/apex/examples/fileIOMultiDir/FileReader.java b/examples/fileIO/src/main/java/org/apache/apex/examples/fileIOMultiDir/FileReader.java
index a346ddb69a..2f790b81da 100644
--- a/examples/fileIO/src/main/java/org/apache/apex/examples/fileIOMultiDir/FileReader.java
+++ b/examples/fileIO/src/main/java/org/apache/apex/examples/fileIOMultiDir/FileReader.java
@@ -1,3 +1,22 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
 package org.apache.apex.examples.fileIOMultiDir;
 
 import java.io.BufferedReader;
@@ -26,7 +45,8 @@ public class FileReader extends FileReaderMultiDir
   /**
    * prefix for file start and finish control tuples
    */
-  public static final char START_FILE = '(', FINISH_FILE = ')';
+  public static final char START_FILE = '(';
+  public static final char FINISH_FILE = ')';
 
   /**
    * output port for file data
@@ -58,8 +78,8 @@ public void setup(Context.OperatorContext context)
     super.setup(context);
     SlicedDirectoryScanner sds = (SlicedDirectoryScanner)getScanner();
     LOG.info("setup: directory = {}; scanner: " +
-             "(startIndex = {}, endIndex = {}, pIndex = {})", getDirectory(),
-             sds.getStartIndex(), sds.getEndIndex(), sds.getpIndex());
+        "(startIndex = {}, endIndex = {}, pIndex = {})", getDirectory(),
+        sds.getStartIndex(), sds.getEndIndex(), sds.getpIndex());
 
     pauseTime = context.getValue(Context.OperatorContext.SPIN_MILLIS);
 
@@ -78,7 +98,7 @@ public void endWindow()
   @Override
   public void emitTuples()
   {
-    if ( ! stop ) {        // normal processing
+    if (!stop) {        // normal processing
       super.emitTuples();
       return;
     }
diff --git a/examples/fileIO/src/main/java/org/apache/apex/examples/fileIOMultiDir/FileReaderMultiDir.java b/examples/fileIO/src/main/java/org/apache/apex/examples/fileIOMultiDir/FileReaderMultiDir.java
index 7ddf489814..bea75351a6 100644
--- a/examples/fileIO/src/main/java/org/apache/apex/examples/fileIOMultiDir/FileReaderMultiDir.java
+++ b/examples/fileIO/src/main/java/org/apache/apex/examples/fileIOMultiDir/FileReaderMultiDir.java
@@ -1,8 +1,22 @@
 /**
- * Copyright (c) 2016 DataTorrent, Inc.
- * All rights reserved.
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
  */
-//package com.datatorrent.lib.io.fs;
+
 package org.apache.apex.examples.fileIOMultiDir;
 
 import java.io.ByteArrayOutputStream;
@@ -103,11 +117,12 @@ public Collection<Partition<AbstractFileInputOperator<String>>> definePartitions
     }
 
     // compute first and last indices of partitions for each directory
-    final int numDirs = directories.length, numParCounts = partitionCounts.length;
+    final int numDirs = directories.length;
+    final int numParCounts = partitionCounts.length;
     final int[] sliceFirstIndex = new int[numDirs];
 
     LOG.info("definePartitions: prevCount = {}, directories.length = {}, " +
-             "partitionCounts.length = {}", prevCount, numDirs, numParCounts);
+        "partitionCounts.length = {}", prevCount, numDirs, numParCounts);
 
     int nPartitions = 0;        // desired number of partitions
 
@@ -143,21 +158,21 @@ public Collection<Partition<AbstractFileInputOperator<String>>> definePartitions
 
     SlicedDirectoryScanner sds = (SlicedDirectoryScanner)scanner;
     List<SlicedDirectoryScanner> scanners = sds.partition(nPartitions, directories,
-                                                          partitionCounts);
+        partitionCounts);
 
     // return value: new list of partitions (includes old list)
     List<Partition<AbstractFileInputOperator<String>>> newPartitions
       // = Lists.newArrayListWithExpectedSize(totalCount);
-      = new ArrayList(nPartitions);
+        = new ArrayList(nPartitions);
 
     // parallel list of storage managers
     Collection<WindowDataManager> newManagers
       //  = Lists.newArrayListWithExpectedSize(totalCount);
-      = new ArrayList(nPartitions);
+        = new ArrayList(nPartitions);
 
     // setup new partitions
     LOG.info("definePartitions: setting up {} new partitoins with {} monitored directories",
-             nPartitions, numDirs);
+        nPartitions, numDirs);
 
     final WindowDataManager ism = getWindowDataManager();
 
@@ -171,8 +186,7 @@ public Collection<Partition<AbstractFileInputOperator<String>>> definePartitions
       for (int i = first; i < last; ++i) {
         AbstractFileInputOperator<String> oper = cloneObject(kryo, this);
         oper.setDirectory(dir);
-        //oper.setpIndex(i);
-        SlicedDirectoryScanner scn = (SlicedDirectoryScanner) scanners.get(i);
+        SlicedDirectoryScanner scn = (SlicedDirectoryScanner)scanners.get(i);
         scn.setStartIndex(first);
         scn.setEndIndex(last);
         scn.setDirectory(dir);
@@ -200,7 +214,9 @@ public static class SlicedDirectoryScanner extends AbstractFileInputOperator.Dir
     //   DirectoryScanner since it is private and has no accessors defined; we also use
     //   it differently here.
     //
-    int startIndex, endIndex, pIndex;
+    int startIndex;
+    int endIndex;
+    int pIndex;
 
     // the monitored directory
     String directory;
@@ -210,9 +226,8 @@ public static class SlicedDirectoryScanner extends AbstractFileInputOperator.Dir
     // dirs -- list of monitored directories, one per slice
     // pCounts -- number of partitions in each slice
     //
-    private List<SlicedDirectoryScanner> partition(int total,
-                                                   String[] dirs,
-                                                   int[] pCounts) {
+    private List<SlicedDirectoryScanner> partition(int total, String[] dirs, int[] pCounts)
+    {
       ArrayList<SlicedDirectoryScanner> partitions = new ArrayList(total);
       for (int i = 0; i < total; i++) {
         final SlicedDirectoryScanner that = new SlicedDirectoryScanner();
@@ -240,8 +255,8 @@ protected boolean acceptFile(String filePathStr)
           mod += sliceSize;
         }
         LOG.debug("partitionIndex = {}, startIndex = {}, endIndex = {}, sliceSize = {}, " +
-                  "filePathStr = {}, hashcode = {}, mod = {}",
-                  pIndex, startIndex, endIndex, sliceSize, filePathStr, i, mod);
+            "filePathStr = {}, hashcode = {}, mod = {}",
+            pIndex, startIndex, endIndex, sliceSize, filePathStr, i, mod);
 
         if ((startIndex + mod) != pIndex) {
           return false;
@@ -260,14 +275,45 @@ protected boolean acceptFile(String filePathStr)
     }  // acceptFile
 
     // getters and setters
-    public String getDirectory() { return directory; }
-    public void setDirectory(String v) { directory = v; }
-    public int getStartIndex() { return startIndex; }
-    public void setStartIndex(int v) { startIndex = v; }
-    public int getEndIndex() { return endIndex; }
-    public void setEndIndex(int v) { endIndex = v; }
-    public int getpIndex() { return pIndex; }
-    public void setpIndex(int v) { pIndex = v; }
+    public String getDirectory()
+    {
+      return directory;
+    }
+
+    public void setDirectory(String v)
+    {
+      directory = v;
+    }
+
+    public int getStartIndex()
+    {
+      return startIndex;
+    }
+
+    public void setStartIndex(int v)
+    {
+      startIndex = v;
+    }
+
+    public int getEndIndex()
+    {
+      return endIndex;
+    }
+
+    public void setEndIndex(int v)
+    {
+      endIndex = v;
+    }
+
+    public int getpIndex()
+    {
+      return pIndex;
+    }
+
+    public void setpIndex(int v)
+    {
+      pIndex = v;
+    }
 
   }    // SlicedDirectoryScanner
 
diff --git a/examples/fileIO/src/main/java/org/apache/apex/examples/fileIOMultiDir/FileWriter.java b/examples/fileIO/src/main/java/org/apache/apex/examples/fileIOMultiDir/FileWriter.java
index 971fc3d8d7..0e79cbc095 100644
--- a/examples/fileIO/src/main/java/org/apache/apex/examples/fileIOMultiDir/FileWriter.java
+++ b/examples/fileIO/src/main/java/org/apache/apex/examples/fileIOMultiDir/FileWriter.java
@@ -1,3 +1,22 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
 package org.apache.apex.examples.fileIOMultiDir;
 
 import java.util.ArrayList;
@@ -16,7 +35,8 @@ public class FileWriter extends AbstractFileOutputOperator<String>
   private static final Logger LOG = LoggerFactory.getLogger(FileWriter.class);
   private static final String CHARSET_NAME = "UTF-8";
   private static final String NL = System.lineSeparator();
-  private static final char START_FILE = FileReader.START_FILE, FINISH_FILE = FileReader.FINISH_FILE;
+  private static final char START_FILE = FileReader.START_FILE;
+  private static final char FINISH_FILE = FileReader.FINISH_FILE;
 
   private String fileName;    // current file name
 
@@ -50,7 +70,7 @@ private void processControlTuple(final String tuple)
       fileName = tuple.substring(1);
 
       // if we have saved lines, process them
-      if ( ! savedLines.isEmpty() ) {
+      if (!savedLines.isEmpty()) {
         LOG.debug("Processing {} saved lines", savedLines.size());
         for (String line : savedLines) {
           processTuple(line);
@@ -67,7 +87,7 @@ private void processControlTuple(final String tuple)
       String name = tuple.substring(0, last);
 
       // sanity check : should match what we got with start control tuple
-      if (null == fileName || ! fileName.equals(name)) {
+      if (null == fileName || !fileName.equals(name)) {
         throw new RuntimeException(String.format("Error: fileName = %s != %s = tuple", fileName, tuple));
       }
 
@@ -93,7 +113,7 @@ public void processTuple(String tuple)
   @Override
   public void endWindow()
   {
-    if ( ! eof ) {
+    if (!eof) {
       return;
     }
 
@@ -121,7 +141,7 @@ protected byte[] getBytesForTuple(String line)
   {
     LOG.debug("getBytesForTuple: line.length = {}", line.length());
 
-    byte result[] = null;
+    byte[] result = null;
     try {
       result = (line + NL).getBytes(CHARSET_NAME);
     } catch (Exception e) {
diff --git a/examples/fileIO/src/main/java/org/apache/apex/examples/fileIOSimple/Application.java b/examples/fileIO/src/main/java/org/apache/apex/examples/fileIOSimple/Application.java
index 65b84381dd..550186e665 100644
--- a/examples/fileIO/src/main/java/org/apache/apex/examples/fileIOSimple/Application.java
+++ b/examples/fileIO/src/main/java/org/apache/apex/examples/fileIOSimple/Application.java
@@ -1,16 +1,35 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
 package org.apache.apex.examples.fileIOSimple;
 
 import org.apache.apex.malhar.lib.fs.LineByLineFileInputOperator;
 import org.apache.hadoop.conf.Configuration;
 
-import com.datatorrent.api.annotation.ApplicationAnnotation;
-import com.datatorrent.api.StreamingApplication;
 import com.datatorrent.api.DAG;
+import com.datatorrent.api.StreamingApplication;
+import com.datatorrent.api.annotation.ApplicationAnnotation;
 
 /**
  * Simple application illustrating file input-output
  */
-@ApplicationAnnotation(name="SimpleFileIO")
+@ApplicationAnnotation(name = "SimpleFileIO")
 public class Application implements StreamingApplication
 {
 
@@ -19,9 +38,9 @@ public void populateDAG(DAG dag, Configuration conf)
   {
     // create operators
     LineByLineFileInputOperator in = dag.addOperator("input",
-                                               new LineByLineFileInputOperator());
+        new LineByLineFileInputOperator());
     FileOutputOperator out = dag.addOperator("output",
-                                             new FileOutputOperator());
+        new FileOutputOperator());
     // configure operators
     in.setDirectory("/tmp/SimpleFileIO/input-dir");
     out.setFilePath("/tmp/SimpleFileIO/output-dir");
diff --git a/examples/fileIO/src/main/java/org/apache/apex/examples/fileIOSimple/FileOutputOperator.java b/examples/fileIO/src/main/java/org/apache/apex/examples/fileIOSimple/FileOutputOperator.java
index 4c02ea5b3b..e11921239c 100644
--- a/examples/fileIO/src/main/java/org/apache/apex/examples/fileIOSimple/FileOutputOperator.java
+++ b/examples/fileIO/src/main/java/org/apache/apex/examples/fileIOSimple/FileOutputOperator.java
@@ -1,3 +1,22 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
 package org.apache.apex.examples.fileIOSimple;
 
 import javax.validation.constraints.NotNull;
@@ -38,7 +57,7 @@ protected String getFileName(String tuple)
   @Override
   protected byte[] getBytesForTuple(String line)
   {
-    byte result[] = null;
+    byte[] result = null;
     try {
       result = (line + NL).getBytes(CHARSET_NAME);
     } catch (Exception e) {
@@ -48,6 +67,13 @@ protected byte[] getBytesForTuple(String line)
   }
 
   // getters and setters
-  public String getFileName() { return fileName; }
-  public void setFileName(String v) { fileName = v; }
+  public String getFileName()
+  {
+    return fileName;
+  }
+
+  public void setFileName(String v)
+  {
+    fileName = v;
+  }
 }
diff --git a/examples/fileIO/src/main/java/org/apache/apex/examples/fileOutput/Application.java b/examples/fileIO/src/main/java/org/apache/apex/examples/fileOutput/Application.java
index 904e3abb62..4cdba22a66 100644
--- a/examples/fileIO/src/main/java/org/apache/apex/examples/fileOutput/Application.java
+++ b/examples/fileIO/src/main/java/org/apache/apex/examples/fileOutput/Application.java
@@ -1,3 +1,22 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
 package org.apache.apex.examples.fileOutput;
 
 import org.apache.hadoop.conf.Configuration;
@@ -6,7 +25,7 @@
 import com.datatorrent.api.StreamingApplication;
 import com.datatorrent.api.annotation.ApplicationAnnotation;
 
-@ApplicationAnnotation(name="fileOutput")
+@ApplicationAnnotation(name = "fileOutput")
 public class Application implements StreamingApplication
 {
 
diff --git a/examples/fileIO/src/main/java/org/apache/apex/examples/fileOutput/FileWriter.java b/examples/fileIO/src/main/java/org/apache/apex/examples/fileOutput/FileWriter.java
index b8d00a01c7..1ec6cfb44a 100644
--- a/examples/fileIO/src/main/java/org/apache/apex/examples/fileOutput/FileWriter.java
+++ b/examples/fileIO/src/main/java/org/apache/apex/examples/fileOutput/FileWriter.java
@@ -1,3 +1,22 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
 package org.apache.apex.examples.fileOutput;
 
 import java.util.Arrays;
@@ -46,7 +65,7 @@ protected String getFileName(Long[] tuple)
   @Override
   protected byte[] getBytesForTuple(Long[] pair)
   {
-    byte result[] = null;
+    byte[] result = null;
     try {
       result = (Arrays.toString(pair) + NL).getBytes(CHARSET_NAME);
     } catch (Exception e) {
@@ -57,6 +76,13 @@ protected byte[] getBytesForTuple(Long[] pair)
   }
 
   // getters and setters
-  public String getFileName() { return fileName; }
-  public void setFileName(String v) { fileName = v; }
+  public String getFileName()
+  {
+    return fileName;
+  }
+
+  public void setFileName(String v)
+  {
+    fileName = v;
+  }
 }
diff --git a/examples/fileIO/src/main/java/org/apache/apex/examples/fileOutput/SequenceGenerator.java b/examples/fileIO/src/main/java/org/apache/apex/examples/fileOutput/SequenceGenerator.java
index 759b6fa3f4..34fcd3f80b 100644
--- a/examples/fileIO/src/main/java/org/apache/apex/examples/fileOutput/SequenceGenerator.java
+++ b/examples/fileIO/src/main/java/org/apache/apex/examples/fileOutput/SequenceGenerator.java
@@ -1,3 +1,22 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
 package org.apache.apex.examples.fileOutput;
 
 import javax.validation.constraints.Min;
@@ -45,7 +64,7 @@ public void setup(OperatorContext context)
     id = context.getId();
     sleepTime = context.getValue(OperatorContext.SPIN_MILLIS);
     LOG.debug("Leaving setup, id = {}, sleepTime = {}, divisor = {}",
-              id, sleepTime, divisor);
+        id, sleepTime, divisor);
   }
 
   @Override
@@ -83,8 +102,23 @@ public void emitTuples()
 
   // getters and setters
 
-  public long getDivisor() { return divisor; }
-  public void setDivisor(long v) { divisor = v; }
-  public int getMaxTuples() { return maxTuples; }
-  public void setMaxTuples(int v) { maxTuples = v; }
+  public long getDivisor()
+  {
+    return divisor;
+  }
+
+  public void setDivisor(long v)
+  {
+    divisor = v;
+  }
+
+  public int getMaxTuples()
+  {
+    return maxTuples;
+  }
+
+  public void setMaxTuples(int v)
+  {
+    maxTuples = v;
+  }
 }
diff --git a/examples/fileIO/src/main/resources/META-INF/properties-FileIO.xml b/examples/fileIO/src/main/resources/META-INF/properties-FileIO.xml
index e99bae5872..3df70043b0 100644
--- a/examples/fileIO/src/main/resources/META-INF/properties-FileIO.xml
+++ b/examples/fileIO/src/main/resources/META-INF/properties-FileIO.xml
@@ -1,4 +1,24 @@
 <?xml version="1.0"?>
+<!--
+
+    Licensed to the Apache Software Foundation (ASF) under one
+    or more contributor license agreements.  See the NOTICE file
+    distributed with this work for additional information
+    regarding copyright ownership.  The ASF licenses this file
+    to you under the Apache License, Version 2.0 (the
+    "License"); you may not use this file except in compliance
+    with the License.  You may obtain a copy of the License at
+
+      http://www.apache.org/licenses/LICENSE-2.0
+
+    Unless required by applicable law or agreed to in writing,
+    software distributed under the License is distributed on an
+    "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+    KIND, either express or implied.  See the License for the
+    specific language governing permissions and limitations
+    under the License.
+
+-->
 <configuration>
   <!-- 
   <property>
diff --git a/examples/fileIO/src/main/resources/META-INF/properties-ThroughputBasedFileIO.xml b/examples/fileIO/src/main/resources/META-INF/properties-ThroughputBasedFileIO.xml
index 8fc5014c38..da98a34d4e 100644
--- a/examples/fileIO/src/main/resources/META-INF/properties-ThroughputBasedFileIO.xml
+++ b/examples/fileIO/src/main/resources/META-INF/properties-ThroughputBasedFileIO.xml
@@ -1,4 +1,24 @@
 <?xml version="1.0"?>
+<!--
+
+    Licensed to the Apache Software Foundation (ASF) under one
+    or more contributor license agreements.  See the NOTICE file
+    distributed with this work for additional information
+    regarding copyright ownership.  The ASF licenses this file
+    to you under the Apache License, Version 2.0 (the
+    "License"); you may not use this file except in compliance
+    with the License.  You may obtain a copy of the License at
+
+      http://www.apache.org/licenses/LICENSE-2.0
+
+    Unless required by applicable law or agreed to in writing,
+    software distributed under the License is distributed on an
+    "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+    KIND, either express or implied.  See the License for the
+    specific language governing permissions and limitations
+    under the License.
+
+-->
 <configuration>
   <!-- 
   <property>
diff --git a/examples/fileIO/src/main/resources/META-INF/properties-fileIO-multiDir.xml b/examples/fileIO/src/main/resources/META-INF/properties-fileIO-multiDir.xml
index e3775f4817..4dfb8d655a 100644
--- a/examples/fileIO/src/main/resources/META-INF/properties-fileIO-multiDir.xml
+++ b/examples/fileIO/src/main/resources/META-INF/properties-fileIO-multiDir.xml
@@ -1,4 +1,24 @@
 <?xml version="1.0"?>
+<!--
+
+    Licensed to the Apache Software Foundation (ASF) under one
+    or more contributor license agreements.  See the NOTICE file
+    distributed with this work for additional information
+    regarding copyright ownership.  The ASF licenses this file
+    to you under the Apache License, Version 2.0 (the
+    "License"); you may not use this file except in compliance
+    with the License.  You may obtain a copy of the License at
+
+      http://www.apache.org/licenses/LICENSE-2.0
+
+    Unless required by applicable law or agreed to in writing,
+    software distributed under the License is distributed on an
+    "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+    KIND, either express or implied.  See the License for the
+    specific language governing permissions and limitations
+    under the License.
+
+-->
 <configuration>
   <!-- 
   <property>
diff --git a/examples/fileIO/src/main/resources/META-INF/properties-fileIOSimple.xml b/examples/fileIO/src/main/resources/META-INF/properties-fileIOSimple.xml
index 8c584cfe9c..caead28950 100644
--- a/examples/fileIO/src/main/resources/META-INF/properties-fileIOSimple.xml
+++ b/examples/fileIO/src/main/resources/META-INF/properties-fileIOSimple.xml
@@ -1,4 +1,24 @@
 <?xml version="1.0"?>
+<!--
+
+    Licensed to the Apache Software Foundation (ASF) under one
+    or more contributor license agreements.  See the NOTICE file
+    distributed with this work for additional information
+    regarding copyright ownership.  The ASF licenses this file
+    to you under the Apache License, Version 2.0 (the
+    "License"); you may not use this file except in compliance
+    with the License.  You may obtain a copy of the License at
+
+      http://www.apache.org/licenses/LICENSE-2.0
+
+    Unless required by applicable law or agreed to in writing,
+    software distributed under the License is distributed on an
+    "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+    KIND, either express or implied.  See the License for the
+    specific language governing permissions and limitations
+    under the License.
+
+-->
 <configuration>
   <!-- 
   <property>
diff --git a/examples/fileIO/src/main/resources/META-INF/properties-fileOutput.xml b/examples/fileIO/src/main/resources/META-INF/properties-fileOutput.xml
index 03901db93a..c81c5ee831 100644
--- a/examples/fileIO/src/main/resources/META-INF/properties-fileOutput.xml
+++ b/examples/fileIO/src/main/resources/META-INF/properties-fileOutput.xml
@@ -1,4 +1,24 @@
 <?xml version="1.0"?>
+<!--
+
+    Licensed to the Apache Software Foundation (ASF) under one
+    or more contributor license agreements.  See the NOTICE file
+    distributed with this work for additional information
+    regarding copyright ownership.  The ASF licenses this file
+    to you under the Apache License, Version 2.0 (the
+    "License"); you may not use this file except in compliance
+    with the License.  You may obtain a copy of the License at
+
+      http://www.apache.org/licenses/LICENSE-2.0
+
+    Unless required by applicable law or agreed to in writing,
+    software distributed under the License is distributed on an
+    "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+    KIND, either express or implied.  See the License for the
+    specific language governing permissions and limitations
+    under the License.
+
+-->
 <configuration>
   <!-- 
   <property>
diff --git a/examples/fileIO/src/main/resources/unused-log4j.properties b/examples/fileIO/src/main/resources/unused-log4j.properties
index a83a30b457..625497b1c8 100644
--- a/examples/fileIO/src/main/resources/unused-log4j.properties
+++ b/examples/fileIO/src/main/resources/unused-log4j.properties
@@ -1,3 +1,22 @@
+#
+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contributor license agreements.  See the NOTICE file
+# distributed with this work for additional information
+# regarding copyright ownership.  The ASF licenses this file
+# to you under the Apache License, Version 2.0 (the
+# "License"); you may not use this file except in compliance
+# with the License.  You may obtain a copy of the License at
+#
+#   http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing,
+# software distributed under the License is distributed on an
+# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+# KIND, either express or implied.  See the License for the
+# specific language governing permissions and limitations
+# under the License.
+#
+
 log4j.rootLogger=DEBUG,CONSOLE
 
 log4j.appender.CONSOLE=org.apache.log4j.ConsoleAppender
diff --git a/examples/fileIO/src/test/java/org/apache/apex/examples/fileIO/ApplicationTest.java b/examples/fileIO/src/test/java/org/apache/apex/examples/fileIO/ApplicationTest.java
index 9306dd1e45..ed3a5448c7 100644
--- a/examples/fileIO/src/test/java/org/apache/apex/examples/fileIO/ApplicationTest.java
+++ b/examples/fileIO/src/test/java/org/apache/apex/examples/fileIO/ApplicationTest.java
@@ -1,3 +1,22 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
 package org.apache.apex.examples.fileIO;
 
 import java.io.File;
@@ -21,7 +40,8 @@
 /**
  * Test application in local mode.
  */
-public class ApplicationTest {
+public class ApplicationTest
+{
 
   private static final String baseDirName   = "target/fileIO";
   private static final String inputDirName  = baseDirName + "input-dir";
@@ -34,7 +54,8 @@ public class ApplicationTest {
   private static final int numPartitions = 3;     // number of partitions of input operator
 
   // create nFiles files with nLines lines in each
-  private void createFiles(final int nFiles, final int nLines) throws IOException {
+  private void createFiles(final int nFiles, final int nLines) throws IOException
+  {
     for (int file = 0; file < nFiles; file++) {
       ArrayList<String> lines = new ArrayList<>();
       for (int line = 0; line < nLines; line++) {
@@ -78,7 +99,8 @@ private Configuration getConfig()
   }
 
   @Before
-  public void beforeTest() throws Exception {
+  public void beforeTest() throws Exception
+  {
     cleanup();
     FileUtils.forceMkdir(inputDirFile);
     FileUtils.forceMkdir(outputDirFile);
@@ -88,12 +110,14 @@ public void beforeTest() throws Exception {
   }
 
   @After
-  public void afterTest() {
+  public void afterTest()
+  {
     cleanup();
   }
 
   @Test
-  public void testApplication() throws Exception {
+  public void testApplication() throws Exception
+  {
     try {
       LocalMode lma = LocalMode.newInstance();
       lma.prepareDAG(new Application(), getConfig());
@@ -101,8 +125,7 @@ public void testApplication() throws Exception {
       lc.runAsync();
 
       // wait for output files to show up
-      while ( ! check(numFiles) ) {
-        System.out.println("Sleeping ....");
+      while (!check(numFiles) ) {
         Thread.sleep(1000);
       }
     } catch (ConstraintViolationException e) {
diff --git a/examples/fileIO/src/test/java/org/apache/apex/examples/fileIO/ThroughputBasedApplicationTest.java b/examples/fileIO/src/test/java/org/apache/apex/examples/fileIO/ThroughputBasedApplicationTest.java
index eccf66bb1f..2a33257db3 100644
--- a/examples/fileIO/src/test/java/org/apache/apex/examples/fileIO/ThroughputBasedApplicationTest.java
+++ b/examples/fileIO/src/test/java/org/apache/apex/examples/fileIO/ThroughputBasedApplicationTest.java
@@ -1,3 +1,22 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
 package org.apache.apex.examples.fileIO;
 
 import java.io.File;
@@ -6,14 +25,15 @@
 
 import javax.validation.ConstraintViolationException;
 
-import org.apache.commons.io.FileUtils;
-import org.apache.commons.lang3.StringUtils;
-import org.apache.hadoop.conf.Configuration;
 import org.junit.After;
 import org.junit.Assert;
 import org.junit.Before;
 import org.junit.Test;
 
+import org.apache.commons.io.FileUtils;
+import org.apache.commons.lang3.StringUtils;
+import org.apache.hadoop.conf.Configuration;
+
 import com.datatorrent.api.LocalMode;
 
 public class ThroughputBasedApplicationTest
@@ -112,7 +132,6 @@ public void testApplication() throws Exception
 
       // wait for output files to show up
       while (!checkFilesCopied(numFiles)) {
-        System.out.println("Waiting for files to get copied.");
         Thread.sleep(1000);
       }
       lc.shutdown();
diff --git a/examples/fileIO/src/test/java/org/apache/apex/examples/fileIOMultiDir/ApplicationTest.java b/examples/fileIO/src/test/java/org/apache/apex/examples/fileIOMultiDir/ApplicationTest.java
index 2f4ae6854f..1244d32910 100644
--- a/examples/fileIO/src/test/java/org/apache/apex/examples/fileIOMultiDir/ApplicationTest.java
+++ b/examples/fileIO/src/test/java/org/apache/apex/examples/fileIOMultiDir/ApplicationTest.java
@@ -1,3 +1,22 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
 package org.apache.apex.examples.fileIOMultiDir;
 
 import java.io.File;
@@ -21,7 +40,8 @@
 /**
  * Test application in local mode.
  */
-public class ApplicationTest {
+public class ApplicationTest
+{
 
   private static final String baseDirName   = "target/fileIO";
   private static final String inputDirName1 = baseDirName + "/in1";
@@ -36,14 +56,17 @@ public class ApplicationTest {
   private static final int numPartitions = 3;     // number of partitions of input operator
 
   // create nFiles files with nLines lines in each
-  private void createFiles() throws IOException {
-    
-    String[] lines1 = {"line-1", "line-2"}, lines2 = {"line-3", "line-4"};
+  private void createFiles() throws IOException
+  {
+
+    String[] lines1 = {"line-1", "line-2"};
+    String[] lines2 = {"line-3", "line-4"};
+
     try {
       FileUtils.write(new File(inputDirFile1, "file1.txt"),
-                      StringUtils.join(lines1, "\n"));
+          StringUtils.join(lines1, "\n"));
       FileUtils.write(new File(inputDirFile2, "file2.txt"),
-                      StringUtils.join(lines2, "\n"));
+          StringUtils.join(lines2, "\n"));
     } catch (IOException e) {
       System.out.format("Error: Failed to create file %s%n");
       e.printStackTrace();
@@ -67,9 +90,10 @@ private boolean check(final int nFiles)
   {
     String[] ext = {"txt"};
     Collection<File> list = FileUtils.listFiles(outputDirFile, ext, false);
-    
-    if (list.size() < 2)
+
+    if (list.size() < 2) {
       return false;
+    }
 
     // we have 2 files; check that the rename from .tmp to .txt has happened
     int found = 0;
@@ -89,14 +113,15 @@ private Configuration getConfig()
     //conf.addResource(this.getClass().getResourceAsStream("/META-INF/properties-fileIOMultiDir.xml"));
     result.set("dt.application.FileIO.operator.read.prop.directory", "dummy");
     result.set("dt.application.FileIO.operator.read.prop.directories",
-               "\"target/fileIO/in1\",\"target/fileIO/in2\"");
+        "\"target/fileIO/in1\",\"target/fileIO/in2\"");
     result.set("dt.application.FileIO.operator.read.prop.partitionCounts", "2,3");
     result.set("dt.application.FileIO.operator.write.prop.filePath", outputDirName);
     return result;
   }
 
   @Before
-  public void beforeTest() throws Exception {
+  public void beforeTest() throws Exception
+  {
     cleanup();
     FileUtils.forceMkdir(inputDirFile1);
     FileUtils.forceMkdir(inputDirFile2);
@@ -107,12 +132,14 @@ public void beforeTest() throws Exception {
   }
 
   @After
-  public void afterTest() {
+  public void afterTest()
+  {
     cleanup();
   }
 
   @Test
-  public void testApplication() throws Exception {
+  public void testApplication() throws Exception
+  {
     try {
       LocalMode lma = LocalMode.newInstance();
       lma.prepareDAG(new Application(), getConfig());
@@ -120,8 +147,7 @@ public void testApplication() throws Exception {
       lc.runAsync();
 
       // wait for output files to show up
-      while ( ! check(numFiles) ) {
-        System.out.println("Sleeping ....");
+      while (!check(numFiles)) {
         Thread.sleep(1000);
       }
     } catch (ConstraintViolationException e) {
diff --git a/examples/fileIO/src/test/java/org/apache/apex/examples/fileIOSimple/ApplicationTest.java b/examples/fileIO/src/test/java/org/apache/apex/examples/fileIOSimple/ApplicationTest.java
index bdab6f7e54..fff96065ce 100644
--- a/examples/fileIO/src/test/java/org/apache/apex/examples/fileIOSimple/ApplicationTest.java
+++ b/examples/fileIO/src/test/java/org/apache/apex/examples/fileIOSimple/ApplicationTest.java
@@ -1,3 +1,22 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
 package org.apache.apex.examples.fileIOSimple;
 
 import java.io.File;
@@ -22,7 +41,8 @@
 /**
  * Test application in local mode.
  */
-public class ApplicationTest {
+public class ApplicationTest
+{
 
   private static final String baseDirName   = "target/SimpleFileIO";
   private static final String inputDirName  = baseDirName + "/input-dir";
@@ -35,7 +55,8 @@ public class ApplicationTest {
   private static final int numPartitions = 3;     // number of partitions of input operator
 
   // create nFiles files with nLines lines in each
-  private void createFiles(final int nFiles, final int nLines) throws IOException {
+  private void createFiles(final int nFiles, final int nLines) throws IOException
+  {
     for (int file = 0; file < nFiles; file++) {
       ArrayList<String> lines = new ArrayList<>();
       for (int line = 0; line < nLines; line++) {
@@ -67,8 +88,8 @@ private boolean check()
     // Look for files with a single digit extension
     String[] ext = {"0","1","2","3","4","5","6","7","8","9"};
     Collection<File> list = FileUtils.listFiles(outputDirFile, ext, false);
-    
-    return ! list.isEmpty();
+
+    return !list.isEmpty();
   }
 
   // return Configuration with suitable properties set
@@ -84,7 +105,8 @@ private Configuration getConfig()
   }
 
   @Before
-  public void beforeTest() throws Exception {
+  public void beforeTest() throws Exception
+  {
     cleanup();
     FileUtils.forceMkdir(inputDirFile);
     FileUtils.forceMkdir(outputDirFile);
@@ -94,12 +116,14 @@ public void beforeTest() throws Exception {
   }
 
   @After
-  public void afterTest() {
+  public void afterTest()
+  {
     cleanup();
   }
 
   @Test
-  public void testApplication() throws Exception {
+  public void testApplication() throws Exception
+  {
     try {
       LocalMode lma = LocalMode.newInstance();
       lma.prepareDAG(new Application(), getConfig());
@@ -107,8 +131,7 @@ public void testApplication() throws Exception {
       lc.runAsync();
 
       // wait for output files to show up
-      while ( ! check() ) {
-        System.out.println("Sleeping ....");
+      while (!check()) {
         Thread.sleep(1000);
       }
     } catch (ConstraintViolationException e) {
diff --git a/examples/fileIO/src/test/java/org/apache/apex/examples/fileOutput/ApplicationTest.java b/examples/fileIO/src/test/java/org/apache/apex/examples/fileOutput/ApplicationTest.java
index 21cbbb6174..ad8c323e64 100644
--- a/examples/fileIO/src/test/java/org/apache/apex/examples/fileOutput/ApplicationTest.java
+++ b/examples/fileIO/src/test/java/org/apache/apex/examples/fileOutput/ApplicationTest.java
@@ -1,3 +1,22 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
 package org.apache.apex.examples.fileOutput;
 
 import java.io.File;
@@ -20,7 +39,8 @@
 /**
  * Test application in local mode.
  */
-public class ApplicationTest {
+public class ApplicationTest
+{
 
   private static final String baseDirName   = "target/fileOutput";
   private static final String outputDirName = baseDirName + "/output-dir";
@@ -42,7 +62,7 @@ private boolean check()
     String[] ext = {"0","1","2","3","4","5","6","7","8","9"};
     Collection<File> list = FileUtils.listFiles(outputDirFile, ext, false);
 
-    return ! list.isEmpty();
+    return !list.isEmpty();
   }
 
   // return Configuration with suitable properties set
@@ -56,18 +76,21 @@ private Configuration getConfig()
   }
 
   @Before
-  public void beforeTest() throws Exception {
+  public void beforeTest() throws Exception
+  {
     cleanup();
     FileUtils.forceMkdir(outputDirFile);
   }
 
   @After
-  public void afterTest() {
+  public void afterTest()
+  {
     cleanup();
   }
 
   @Test
-  public void testApplication() throws Exception {
+  public void testApplication() throws Exception
+  {
     try {
       LocalMode lma = LocalMode.newInstance();
       lma.prepareDAG(new Application(), getConfig());
@@ -75,8 +98,7 @@ public void testApplication() throws Exception {
       lc.runAsync();
 
       // wait for output files to show up
-      while ( ! check() ) {
-        System.out.println("Sleeping ....");
+      while (!check()) {
         Thread.sleep(1000);
       }
     } catch (ConstraintViolationException e) {
diff --git a/examples/fileIO/src/test/resources/log4j.properties b/examples/fileIO/src/test/resources/log4j.properties
index 3bfcdc5517..0a1b8cba5b 100644
--- a/examples/fileIO/src/test/resources/log4j.properties
+++ b/examples/fileIO/src/test/resources/log4j.properties
@@ -1,8 +1,29 @@
+#
+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contributor license agreements.  See the NOTICE file
+# distributed with this work for additional information
+# regarding copyright ownership.  The ASF licenses this file
+# to you under the Apache License, Version 2.0 (the
+# "License"); you may not use this file except in compliance
+# with the License.  You may obtain a copy of the License at
+#
+#   http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing,
+# software distributed under the License is distributed on an
+# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+# KIND, either express or implied.  See the License for the
+# specific language governing permissions and limitations
+# under the License.
+#
+
 log4j.rootLogger=DEBUG,CONSOLE
 
 log4j.appender.CONSOLE=org.apache.log4j.ConsoleAppender
 log4j.appender.CONSOLE.layout=org.apache.log4j.PatternLayout
 log4j.appender.CONSOLE.layout.ConversionPattern=%d{ISO8601} [%t] %-5p %c{2} %M - %m%n
+log4j.appender.CONSOLE.threshold=${test.log.console.threshold}
+test.log.console.threshold=WARN
 
 log4j.appender.RFA=org.apache.log4j.RollingFileAppender
 log4j.appender.RFA.layout=org.apache.log4j.PatternLayout