apex-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From david...@apache.org
Subject [69/98] [abbrv] incubator-apex-malhar git commit: - MLHR-1880 #resolve fixed default value documentation for setMaxLength method.
Date Mon, 30 Nov 2015 21:07:15 GMT
- 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)
     {


Mime
View raw message