Mailing-List: contact commits-help@apex.incubator.apache.org; run by ezmlm
Precedence: bulk
Reply-To: dev@apex.incubator.apache.org
Content-Type: text/plain; charset="us-ascii"
MIME-Version: 1.0
Content-Transfer-Encoding: 7bit
From: davidyan@apache.org
To: commits@apex.incubator.apache.org
Date: Mon, 30 Nov 2015 21:07:15 -0000
Message-Id: <03db72c1288b4a909a9db1176777cdda@git.apache.org>
In-Reply-To: <5b5b1b1327d6412ca3f00c1f8b0781a9@git.apache.org>
References: <5b5b1b1327d6412ca3f00c1f8b0781a9@git.apache.org>
Subject: [69/98] [abbrv] incubator-apex-malhar git commit: - MLHR-1880
 #resolve fixed default value documentation for setMaxLength method.

- MLHR-1880 #resolve fixed default value documentation for setMaxLength method.


Project: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/commit/8cf1a2bb
Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/tree/8cf1a2bb
Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/diff/8cf1a2bb

Branch: refs/heads/master
Commit: 8cf1a2bb0ff7a192bbfe9a654997cb710a21a9dc
Parents: 6b43059
Author: Timothy Farkas <tim@datatorrent.com>
Authored: Fri Oct 23 14:56:23 2015 -0700
Committer: Chandni Singh <csingh@apache.org>
Committed: Thu Nov 5 16:55:17 2015 -0800

----------------------------------------------------------------------
 .../lib/io/fs/AbstractFileOutputOperator.java   | 32 ++++++++++----------
 1 file changed, 16 insertions(+), 16 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/8cf1a2bb/library/src/main/java/com/datatorrent/lib/io/fs/AbstractFileOutputOperator.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/io/fs/AbstractFileOutputOperator.java b/library/src/main/java/com/datatorrent/lib/io/fs/AbstractFileOutputOperator.java
index 58062a1..3819a33 100644
--- a/library/src/main/java/com/datatorrent/lib/io/fs/AbstractFileOutputOperator.java
+++ b/library/src/main/java/com/datatorrent/lib/io/fs/AbstractFileOutputOperator.java
@@ -210,8 +210,8 @@ public abstract class AbstractFileOutputOperator<INPUT> extends BaseOperator imp
   private int rotationCount;
 
   /**
-   * If a filter stream provider is set it is used to obtain the filter that will be applied to data before it is 
-   * stored in the file. If it null no filter is applied and data is written as is. Multiple filters can be chained 
+   * If a filter stream provider is set it is used to obtain the filter that will be applied to data before it is
+   * stored in the file. If it null no filter is applied and data is written as is. Multiple filters can be chained
    * together by using a filter stream chain provider.
    */
   protected FilterStreamProvider filterStreamProvider;
@@ -329,7 +329,7 @@ public abstract class AbstractFileOutputOperator<INPUT> extends BaseOperator imp
       {
         FSFilterStreamContext streamContext = notification.getValue();
         if (streamContext != null) {
-          
+
           //FilterOutputStream filterStream = streamContext.getFilterStream();
           try {
             String filename = notification.getKey();
@@ -938,8 +938,8 @@ public abstract class AbstractFileOutputOperator<INPUT> extends BaseOperator imp
   }
 
   /**
-   * Sets the maximum length of a an output file in bytes. By default this is null,
-   * if this is not null then the output operator is in rolling mode.
+   * Sets the maximum length of a an output file in bytes. By default this is Long.MAX_VALUE,
+   * if this is not Long.MAX_VALUE then the output operator is in rolling mode.
    * @param maxLength The maximum length of an output file in bytes, when in rolling mode.
    */
   public void setMaxLength(long maxLength)
@@ -1014,7 +1014,7 @@ public abstract class AbstractFileOutputOperator<INPUT> extends BaseOperator imp
   }
 
   /**
-   * Get the filter stream provider 
+   * Get the filter stream provider
    * @return The filter stream provider.
    */
   public FilterStreamProvider getFilterStreamProvider()
@@ -1023,7 +1023,7 @@ public abstract class AbstractFileOutputOperator<INPUT> extends BaseOperator imp
   }
 
   /**
-   * Set the filter stream provider. When a non-null provider is specified it will be used to supply the filter that 
+   * Set the filter stream provider. When a non-null provider is specified it will be used to supply the filter that
    * will be  applied to data before it is stored in the file.
    * @param filterStreamProvider The filter stream provider
    */
@@ -1049,15 +1049,15 @@ public abstract class AbstractFileOutputOperator<INPUT> extends BaseOperator imp
 
   private class FSFilterStreamContext implements FilterStreamContext<FilterOutputStream>
   {
-    
+
     private FSDataOutputStream outputStream;
-    
+
     private FilterStreamContext filterContext;
     private NonCloseableFilterOutputStream outputWrapper;
-    
+
     public FSFilterStreamContext(FSDataOutputStream outputStream) throws IOException
     {
-      this.outputStream = outputStream;     
+      this.outputStream = outputStream;
       outputWrapper = new NonCloseableFilterOutputStream(outputStream);
       //resetFilter();
       initializeContext();
@@ -1085,7 +1085,7 @@ public abstract class AbstractFileOutputOperator<INPUT> extends BaseOperator imp
         filterStreamProvider.reclaimFilterStreamContext(filterContext);
       }
     }
-    
+
     @SuppressWarnings("unchecked")
     public void initializeContext() throws IOException
     {
@@ -1093,7 +1093,7 @@ public abstract class AbstractFileOutputOperator<INPUT> extends BaseOperator imp
         filterContext = filterStreamProvider.getFilterStreamContext(outputWrapper);
       }
     }
-    
+
     public void close() throws IOException
     {
       //finalizeContext();
@@ -1102,10 +1102,10 @@ public abstract class AbstractFileOutputOperator<INPUT> extends BaseOperator imp
       }
       outputStream.close();
     }
-    
+
   }
-  
-  private static class NonCloseableFilterOutputStream extends FilterOutputStream 
+
+  private static class NonCloseableFilterOutputStream extends FilterOutputStream
   {
     public NonCloseableFilterOutputStream(OutputStream out)
     {