Repository: incubator-apex-malhar Updated Branches: refs/heads/MLHR-1880-3.2 [created] 8cf1a2bb0
- 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/MLHR-1880-3.2 Commit: 8cf1a2bb0ff7a192bbfe9a654997cb710a21a9dc Parents: 6b43059 Author: Timothy Farkas <[email protected]> Authored: Fri Oct 23 14:56:23 2015 -0700 Committer: Chandni Singh <[email protected]> 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) {
