avro-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From cutt...@apache.org
Subject svn commit: r922427 - in /hadoop/avro/trunk: CHANGES.txt lang/java/src/java/org/apache/avro/file/DataFileStream.java
Date Fri, 12 Mar 2010 21:13:44 GMT
Author: cutting
Date: Fri Mar 12 21:13:44 2010
New Revision: 922427

URL: http://svn.apache.org/viewvc?rev=922427&view=rev
Log:
AVRO-454.  Change DataFileStream to implement Closeable.

Modified:
    hadoop/avro/trunk/CHANGES.txt
    hadoop/avro/trunk/lang/java/src/java/org/apache/avro/file/DataFileStream.java

Modified: hadoop/avro/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/hadoop/avro/trunk/CHANGES.txt?rev=922427&r1=922426&r2=922427&view=diff
==============================================================================
--- hadoop/avro/trunk/CHANGES.txt (original)
+++ hadoop/avro/trunk/CHANGES.txt Fri Mar 12 21:13:44 2010
@@ -41,6 +41,8 @@ Avro 1.3.1 (16 March 2010)
 
     AVRO-446. Add a build.sh task that signs and checksums artifacts. (cutting)
 
+    AVRO-454. Change DataFileStream to implement Closeable. (cutting)
+
   BUG FIXES
 
     AVRO-424. Fix the specification of the deflate codec.

Modified: hadoop/avro/trunk/lang/java/src/java/org/apache/avro/file/DataFileStream.java
URL: http://svn.apache.org/viewvc/hadoop/avro/trunk/lang/java/src/java/org/apache/avro/file/DataFileStream.java?rev=922427&r1=922426&r2=922427&view=diff
==============================================================================
--- hadoop/avro/trunk/lang/java/src/java/org/apache/avro/file/DataFileStream.java (original)
+++ hadoop/avro/trunk/lang/java/src/java/org/apache/avro/file/DataFileStream.java Fri Mar
12 21:13:44 2010
@@ -20,6 +20,7 @@ package org.apache.avro.file;
 import java.io.EOFException;
 import java.io.IOException;
 import java.io.InputStream;
+import java.io.Closeable;
 import java.io.UnsupportedEncodingException;
 import java.nio.ByteBuffer;
 import java.util.Arrays;
@@ -38,7 +39,7 @@ import org.apache.avro.io.DatumReader;
  * DataFileReader} for file-based input.
  * @see DataFileWriter
  */
-public class DataFileStream<D> implements Iterator<D>, Iterable<D> {
+public class DataFileStream<D> implements Iterator<D>, Iterable<D>, Closeable
{
 
   private Schema schema;
   private DatumReader<D> reader;



Mime
View raw message