SAMOA-47: Integrate Avro Streams with SAMOA
diff --git a/samoa-api/src/main/java/org/apache/samoa/moa/streams/AvroFileStream.java b/samoa-api/src/main/java/org/apache/samoa/moa/streams/AvroFileStream.java
index e684687..0a98acf 100644
--- a/samoa-api/src/main/java/org/apache/samoa/moa/streams/AvroFileStream.java
+++ b/samoa-api/src/main/java/org/apache/samoa/moa/streams/AvroFileStream.java
@@ -40,7 +40,6 @@
* InstanceStream implementation to handle Apache Avro Files.
* Handles both JSON & Binary encoded streams
*
- * @author jayadeepj
*
*/
public class AvroFileStream extends FileStream {
diff --git a/samoa-instances/src/main/java/org/apache/samoa/instances/AvroBinaryLoader.java b/samoa-instances/src/main/java/org/apache/samoa/instances/AvroBinaryLoader.java
index c3e32dc..ad07f62 100644
--- a/samoa-instances/src/main/java/org/apache/samoa/instances/AvroBinaryLoader.java
+++ b/samoa-instances/src/main/java/org/apache/samoa/instances/AvroBinaryLoader.java
@@ -33,7 +33,6 @@
/**
* Load Data from Binary Avro Stream and parse to corresponding Dense & Parse Instances
*
- * @author jayadeepj
*
*/
public class AvroBinaryLoader extends AvroLoader {
@@ -94,7 +93,7 @@
if(record==null)
{
- //closeReader();
+ closeReader();
return null;
}
diff --git a/samoa-instances/src/main/java/org/apache/samoa/instances/AvroJsonLoader.java b/samoa-instances/src/main/java/org/apache/samoa/instances/AvroJsonLoader.java
index 827b507..8a345da 100644
--- a/samoa-instances/src/main/java/org/apache/samoa/instances/AvroJsonLoader.java
+++ b/samoa-instances/src/main/java/org/apache/samoa/instances/AvroJsonLoader.java
@@ -38,7 +38,6 @@
/**
* Load Data from JSON Avro Stream and parse to corresponding Dense & Parse Instances
*
- * @author jayadeepj
*
*/
public class AvroJsonLoader extends AvroLoader {
diff --git a/samoa-instances/src/main/java/org/apache/samoa/instances/AvroLoader.java b/samoa-instances/src/main/java/org/apache/samoa/instances/AvroLoader.java
index 09f410f..33db437 100644
--- a/samoa-instances/src/main/java/org/apache/samoa/instances/AvroLoader.java
+++ b/samoa-instances/src/main/java/org/apache/samoa/instances/AvroLoader.java
@@ -35,7 +35,6 @@
* Load Data from Avro Stream and parse to corresponding Dense & Parse Instances
* Abstract Class: Subclass this class for different types of Avro Encodings
*
- * @author jayadeepj
*
*/
public abstract class AvroLoader implements Loader {
