SAMOA-47: Integrate Avro Streams with SAMOA
Project: http://git-wip-us.apache.org/repos/asf/incubator-samoa/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-samoa/commit/533f12a1 Tree: http://git-wip-us.apache.org/repos/asf/incubator-samoa/tree/533f12a1 Diff: http://git-wip-us.apache.org/repos/asf/incubator-samoa/diff/533f12a1 Branch: refs/heads/master Commit: 533f12a12822fcde5dbaf48f4ef2c105f97e7087 Parents: 7497978 Author: jayadeepj <[email protected]> Authored: Fri Oct 30 16:54:05 2015 +0530 Committer: Gianmarco De Francisci Morales <[email protected]> Committed: Mon Nov 30 13:20:35 2015 +0200 ---------------------------------------------------------------------- .../main/java/org/apache/samoa/moa/streams/AvroFileStream.java | 1 - .../main/java/org/apache/samoa/instances/AvroBinaryLoader.java | 3 +-- .../src/main/java/org/apache/samoa/instances/AvroJsonLoader.java | 1 - .../src/main/java/org/apache/samoa/instances/AvroLoader.java | 1 - 4 files changed, 1 insertion(+), 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-samoa/blob/533f12a1/samoa-api/src/main/java/org/apache/samoa/moa/streams/AvroFileStream.java ---------------------------------------------------------------------- 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 @@ import com.github.javacliparser.StringOption; * InstanceStream implementation to handle Apache Avro Files. * Handles both JSON & Binary encoded streams * - * @author jayadeepj * */ public class AvroFileStream extends FileStream { http://git-wip-us.apache.org/repos/asf/incubator-samoa/blob/533f12a1/samoa-instances/src/main/java/org/apache/samoa/instances/AvroBinaryLoader.java ---------------------------------------------------------------------- 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 @@ import org.slf4j.LoggerFactory; /** * Load Data from Binary Avro Stream and parse to corresponding Dense & Parse Instances * - * @author jayadeepj * */ public class AvroBinaryLoader extends AvroLoader { @@ -94,7 +93,7 @@ public class AvroBinaryLoader extends AvroLoader { if(record==null) { - //closeReader(); + closeReader(); return null; } http://git-wip-us.apache.org/repos/asf/incubator-samoa/blob/533f12a1/samoa-instances/src/main/java/org/apache/samoa/instances/AvroJsonLoader.java ---------------------------------------------------------------------- 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 @@ import org.slf4j.LoggerFactory; /** * Load Data from JSON Avro Stream and parse to corresponding Dense & Parse Instances * - * @author jayadeepj * */ public class AvroJsonLoader extends AvroLoader { http://git-wip-us.apache.org/repos/asf/incubator-samoa/blob/533f12a1/samoa-instances/src/main/java/org/apache/samoa/instances/AvroLoader.java ---------------------------------------------------------------------- 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 @@ import org.apache.avro.io.DatumReader; * 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 {
