You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@avro.apache.org by cu...@apache.org on 2010/03/12 22:13:44 UTC
svn commit: r922427 - in /hadoop/avro/trunk: CHANGES.txt
lang/java/src/java/org/apache/avro/file/DataFileStream.java
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;