Minor name change
diff --git a/contrib/src/main/java/com/datatorrent/contrib/io/LzoFilterStream.java b/contrib/src/main/java/com/datatorrent/contrib/io/LzoFilterStream.java
index a50f6da..aef557d 100644
--- a/contrib/src/main/java/com/datatorrent/contrib/io/LzoFilterStream.java
+++ b/contrib/src/main/java/com/datatorrent/contrib/io/LzoFilterStream.java
@@ -31,17 +31,17 @@
public class LzoFilterStream
{
- public static class LZOFilterStreamContext extends FilterStreamContext.BaseFilterStreamContext<LzopFilterStream>
+ public static class LzoFilterStreamContext extends FilterStreamContext.BaseFilterStreamContext<LzopFilterOutputStream>
{
- public LZOFilterStreamContext(OutputStream outputStream) throws IOException
+ public LzoFilterStreamContext(OutputStream outputStream) throws IOException
{
- filterStream = new LzopFilterStream(new LzopOutputStream(outputStream, LzoLibrary.getInstance().newCompressor(LzoAlgorithm.LZO1X, LzoConstraint.COMPRESSION)));
+ filterStream = new LzopFilterOutputStream(new LzopOutputStream(outputStream, LzoLibrary.getInstance().newCompressor(LzoAlgorithm.LZO1X, LzoConstraint.COMPRESSION)));
}
}
- static class LzopFilterStream extends FilterOutputStream
+ static class LzopFilterOutputStream extends FilterOutputStream
{
- public LzopFilterStream(OutputStream outputStream)
+ public LzopFilterOutputStream(OutputStream outputStream)
{
super(outputStream);
}
@@ -51,12 +51,12 @@
* A provider for LZO filter The file has to be rewritten from beginning when there is operator failure. The operates
* on entries file and not on file parts.
*/
- public static class LZOFilterStreamProvider extends FilterStreamProvider.SimpleFilterReusableStreamProvider<LzopFilterStream, OutputStream>
+ public static class LzoFilterStreamProvider extends FilterStreamProvider.SimpleFilterReusableStreamProvider<LzopFilterOutputStream, OutputStream>
{
@Override
- protected FilterStreamContext<LzopFilterStream> createFilterStreamContext(OutputStream outputStream) throws IOException
+ protected FilterStreamContext<LzopFilterOutputStream> createFilterStreamContext(OutputStream outputStream) throws IOException
{
- return new LZOFilterStreamContext(outputStream);
+ return new LzoFilterStreamContext(outputStream);
}
}
}
diff --git a/contrib/src/test/java/com/datatorrent/contrib/io/LzoFilterStreamTest.java b/contrib/src/test/java/com/datatorrent/contrib/io/LzoFilterStreamTest.java
index d86e7c6..fb102c2 100644
--- a/contrib/src/test/java/com/datatorrent/contrib/io/LzoFilterStreamTest.java
+++ b/contrib/src/test/java/com/datatorrent/contrib/io/LzoFilterStreamTest.java
@@ -22,12 +22,13 @@
import java.io.InputStreamReader;
import org.anarres.lzo.LzopInputStream;
-import org.apache.commons.io.FileUtils;
import org.junit.Assert;
import org.junit.Rule;
import org.junit.Test;
import org.junit.runner.Description;
+import org.apache.commons.io.FileUtils;
+
import com.datatorrent.lib.helper.OperatorContextTestHelper;
import com.datatorrent.lib.io.fs.AbstractFileOutputOperator;
import com.datatorrent.lib.util.TestUtils.TestInfo;
@@ -81,7 +82,7 @@
public void testLZOCompression() throws Exception
{
FileOutputOperator writer = new FileOutputOperator("compressedData.txt.lzo");
- writer.setFilterStreamProvider(new LzoFilterStream.LZOFilterStreamProvider());
+ writer.setFilterStreamProvider(new LzoFilterStream.LzoFilterStreamProvider());
writer.setFilePath(testMeta.getDir());
writer.setup(testOperatorContext);
