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 2009/06/08 23:54:18 UTC
svn commit: r782809 - in /hadoop/avro/trunk: ./ src/java/org/apache/avro/
src/java/org/apache/avro/file/ src/java/org/apache/avro/generic/
src/java/org/apache/avro/io/ src/java/org/apache/avro/ipc/
src/java/org/apache/avro/reflect/ src/java/org/apache/...
Author: cutting
Date: Mon Jun 8 21:54:17 2009
New Revision: 782809
URL: http://svn.apache.org/viewvc?rev=782809&view=rev
Log:
AVRO-48. Remove unused imports and annotations. Contributed by Thiru.
Modified:
hadoop/avro/trunk/CHANGES.txt
hadoop/avro/trunk/src/java/org/apache/avro/AvroTypeException.java
hadoop/avro/trunk/src/java/org/apache/avro/Protocol.java
hadoop/avro/trunk/src/java/org/apache/avro/Schema.java
hadoop/avro/trunk/src/java/org/apache/avro/file/DataFileReader.java
hadoop/avro/trunk/src/java/org/apache/avro/file/DataFileWriter.java
hadoop/avro/trunk/src/java/org/apache/avro/generic/GenericArray.java
hadoop/avro/trunk/src/java/org/apache/avro/generic/GenericData.java
hadoop/avro/trunk/src/java/org/apache/avro/generic/GenericRequestor.java
hadoop/avro/trunk/src/java/org/apache/avro/io/DatumReader.java
hadoop/avro/trunk/src/java/org/apache/avro/io/DatumWriter.java
hadoop/avro/trunk/src/java/org/apache/avro/ipc/AvroRemoteException.java
hadoop/avro/trunk/src/java/org/apache/avro/ipc/Requestor.java
hadoop/avro/trunk/src/java/org/apache/avro/ipc/SocketServer.java
hadoop/avro/trunk/src/java/org/apache/avro/reflect/ReflectData.java
hadoop/avro/trunk/src/java/org/apache/avro/reflect/ReflectDatumReader.java
hadoop/avro/trunk/src/java/org/apache/avro/reflect/ReflectDatumWriter.java
hadoop/avro/trunk/src/java/org/apache/avro/reflect/ReflectResponder.java
hadoop/avro/trunk/src/java/org/apache/avro/specific/SpecificDatumReader.java
hadoop/avro/trunk/src/java/org/apache/avro/specific/SpecificDatumWriter.java
hadoop/avro/trunk/src/java/org/apache/avro/specific/SpecificRecord.java
hadoop/avro/trunk/src/java/org/apache/avro/specific/SpecificResponder.java
hadoop/avro/trunk/src/test/java/org/apache/avro/TestFsData.java
hadoop/avro/trunk/src/test/java/org/apache/avro/TestProtocolGeneric.java
hadoop/avro/trunk/src/test/java/org/apache/avro/TestSchema.java
hadoop/avro/trunk/src/test/java/org/apache/avro/io/TestValueReader.java
Modified: hadoop/avro/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/hadoop/avro/trunk/CHANGES.txt?rev=782809&r1=782808&r2=782809&view=diff
==============================================================================
--- hadoop/avro/trunk/CHANGES.txt (original)
+++ hadoop/avro/trunk/CHANGES.txt Mon Jun 8 21:54:17 2009
@@ -58,6 +58,9 @@
AVRO-32. Java specific generated record classes now implement
equals() and hashCode(). (cutting)
+ AVRO-48. Remove unused imports and annotations.
+ (Thiruvalluvan M. G. via cutting)
+
OPTIMIZATIONS
BUG FIXES
Modified: hadoop/avro/trunk/src/java/org/apache/avro/AvroTypeException.java
URL: http://svn.apache.org/viewvc/hadoop/avro/trunk/src/java/org/apache/avro/AvroTypeException.java?rev=782809&r1=782808&r2=782809&view=diff
==============================================================================
--- hadoop/avro/trunk/src/java/org/apache/avro/AvroTypeException.java (original)
+++ hadoop/avro/trunk/src/java/org/apache/avro/AvroTypeException.java Mon Jun 8 21:54:17 2009
@@ -18,9 +18,6 @@
package org.apache.avro;
-import java.io.IOException;
-
-import org.apache.avro.*;
/** Thrown when an illegal type is used. */
public class AvroTypeException extends AvroRuntimeException {
Modified: hadoop/avro/trunk/src/java/org/apache/avro/Protocol.java
URL: http://svn.apache.org/viewvc/hadoop/avro/trunk/src/java/org/apache/avro/Protocol.java?rev=782809&r1=782808&r2=782809&view=diff
==============================================================================
--- hadoop/avro/trunk/src/java/org/apache/avro/Protocol.java (original)
+++ hadoop/avro/trunk/src/java/org/apache/avro/Protocol.java Mon Jun 8 21:54:17 2009
@@ -19,21 +19,17 @@
import java.io.ByteArrayInputStream;
import java.io.File;
-import java.io.FileInputStream;
import java.io.IOException;
-import java.io.InputStream;
+import java.security.MessageDigest;
import java.util.ArrayList;
import java.util.Iterator;
import java.util.LinkedHashMap;
import java.util.List;
import java.util.Map;
-import java.security.MessageDigest;
-
-import org.codehaus.jackson.JsonParseException;
-import org.codehaus.jackson.JsonParser;
-import org.codehaus.jackson.JsonNode;
import org.apache.avro.Schema.Field;
+import org.codehaus.jackson.JsonNode;
+import org.codehaus.jackson.JsonParser;
/** A set of messages forming an application protocol.
* <p> A protocol consists of:
Modified: hadoop/avro/trunk/src/java/org/apache/avro/Schema.java
URL: http://svn.apache.org/viewvc/hadoop/avro/trunk/src/java/org/apache/avro/Schema.java?rev=782809&r1=782808&r2=782809&view=diff
==============================================================================
--- hadoop/avro/trunk/src/java/org/apache/avro/Schema.java (original)
+++ hadoop/avro/trunk/src/java/org/apache/avro/Schema.java Mon Jun 8 21:54:17 2009
@@ -18,24 +18,21 @@
package org.apache.avro;
import java.io.File;
-import java.io.FileInputStream;
import java.io.IOException;
-import java.io.InputStream;
import java.io.StringReader;
import java.util.ArrayList;
-import java.util.Iterator;
import java.util.HashMap;
import java.util.HashSet;
-import java.util.LinkedHashMap;
import java.util.IdentityHashMap;
+import java.util.LinkedHashMap;
import java.util.List;
import java.util.Map;
import java.util.Set;
import org.codehaus.jackson.JsonFactory;
+import org.codehaus.jackson.JsonNode;
import org.codehaus.jackson.JsonParseException;
import org.codehaus.jackson.JsonParser;
-import org.codehaus.jackson.JsonNode;
import org.codehaus.jackson.map.ObjectMapper;
/** An abstract data type.
Modified: hadoop/avro/trunk/src/java/org/apache/avro/file/DataFileReader.java
URL: http://svn.apache.org/viewvc/hadoop/avro/trunk/src/java/org/apache/avro/file/DataFileReader.java?rev=782809&r1=782808&r2=782809&view=diff
==============================================================================
--- hadoop/avro/trunk/src/java/org/apache/avro/file/DataFileReader.java (original)
+++ hadoop/avro/trunk/src/java/org/apache/avro/file/DataFileReader.java Mon Jun 8 21:54:17 2009
@@ -17,15 +17,18 @@
*/
package org.apache.avro.file;
-import java.io.*;
-import java.util.*;
+import java.io.BufferedInputStream;
+import java.io.IOException;
+import java.io.InputStream;
+import java.io.UnsupportedEncodingException;
import java.nio.ByteBuffer;
-import java.rmi.server.UID;
-import java.security.MessageDigest;
-
-import org.apache.avro.*;
-import org.apache.avro.io.*;
-import org.apache.avro.util.Utf8;
+import java.util.Arrays;
+import java.util.HashMap;
+import java.util.Map;
+
+import org.apache.avro.Schema;
+import org.apache.avro.io.DatumReader;
+import org.apache.avro.io.ValueReader;
/** Read files written by {@link DataFileWriter}.
* @see DataFileWriter
Modified: hadoop/avro/trunk/src/java/org/apache/avro/file/DataFileWriter.java
URL: http://svn.apache.org/viewvc/hadoop/avro/trunk/src/java/org/apache/avro/file/DataFileWriter.java?rev=782809&r1=782808&r2=782809&view=diff
==============================================================================
--- hadoop/avro/trunk/src/java/org/apache/avro/file/DataFileWriter.java (original)
+++ hadoop/avro/trunk/src/java/org/apache/avro/file/DataFileWriter.java Mon Jun 8 21:54:17 2009
@@ -17,14 +17,20 @@
*/
package org.apache.avro.file;
-import java.io.*;
-import java.util.*;
+import java.io.BufferedOutputStream;
+import java.io.ByteArrayOutputStream;
+import java.io.FilterOutputStream;
+import java.io.IOException;
+import java.io.OutputStream;
+import java.io.UnsupportedEncodingException;
import java.rmi.server.UID;
import java.security.MessageDigest;
+import java.util.HashMap;
+import java.util.Map;
-import org.apache.avro.*;
-import org.apache.avro.io.*;
-import org.apache.avro.util.Utf8;
+import org.apache.avro.Schema;
+import org.apache.avro.io.DatumWriter;
+import org.apache.avro.io.ValueWriter;
/** Stores in a file a sequence of data conforming to a schema. The schema is
* stored in the file with the data. Each datum in a file is of the same
Modified: hadoop/avro/trunk/src/java/org/apache/avro/generic/GenericArray.java
URL: http://svn.apache.org/viewvc/hadoop/avro/trunk/src/java/org/apache/avro/generic/GenericArray.java?rev=782809&r1=782808&r2=782809&view=diff
==============================================================================
--- hadoop/avro/trunk/src/java/org/apache/avro/generic/GenericArray.java (original)
+++ hadoop/avro/trunk/src/java/org/apache/avro/generic/GenericArray.java Mon Jun 8 21:54:17 2009
@@ -17,7 +17,6 @@
*/
package org.apache.avro.generic;
-import java.util.*;
/** An array of objects. */
public interface GenericArray<T> extends Iterable<T> {
Modified: hadoop/avro/trunk/src/java/org/apache/avro/generic/GenericData.java
URL: http://svn.apache.org/viewvc/hadoop/avro/trunk/src/java/org/apache/avro/generic/GenericData.java?rev=782809&r1=782808&r2=782809&view=diff
==============================================================================
--- hadoop/avro/trunk/src/java/org/apache/avro/generic/GenericData.java (original)
+++ hadoop/avro/trunk/src/java/org/apache/avro/generic/GenericData.java Mon Jun 8 21:54:17 2009
@@ -125,7 +125,6 @@
switch (schema.getType()) {
case RECORD:
if (!(datum instanceof GenericRecord)) return false;
- @SuppressWarnings(value="unchecked")
GenericRecord fields = (GenericRecord)datum;
for (Map.Entry<String, Schema> entry : schema.getFieldSchemas())
if (!validate(entry.getValue(), fields.get(entry.getKey())))
@@ -228,7 +227,6 @@
/** Create a schema given an example datum. */
public static Schema induce(Object datum) {
if (datum instanceof GenericRecord) {
- @SuppressWarnings(value="unchecked")
GenericRecord record = (GenericRecord)datum;
LinkedHashMap<String,Field> fields = new LinkedHashMap<String,Field>();
for (Map.Entry<String,Object> entry : record.entrySet())
Modified: hadoop/avro/trunk/src/java/org/apache/avro/generic/GenericRequestor.java
URL: http://svn.apache.org/viewvc/hadoop/avro/trunk/src/java/org/apache/avro/generic/GenericRequestor.java?rev=782809&r1=782808&r2=782809&view=diff
==============================================================================
--- hadoop/avro/trunk/src/java/org/apache/avro/generic/GenericRequestor.java (original)
+++ hadoop/avro/trunk/src/java/org/apache/avro/generic/GenericRequestor.java Mon Jun 8 21:54:17 2009
@@ -18,18 +18,18 @@
package org.apache.avro.generic;
-import java.util.*;
import java.io.IOException;
-import java.nio.ByteBuffer;
+import org.apache.avro.Protocol;
+import org.apache.avro.Schema;
+import org.apache.avro.io.ValueReader;
+import org.apache.avro.io.ValueWriter;
+import org.apache.avro.ipc.AvroRemoteException;
+import org.apache.avro.ipc.Requestor;
+import org.apache.avro.ipc.Transceiver;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-import org.apache.avro.*;
-import org.apache.avro.io.*;
-import org.apache.avro.util.*;
-import org.apache.avro.ipc.*;
-
/** {@link Requestor} implementation for generic Java data. */
public class GenericRequestor extends Requestor {
private static final Logger LOG
Modified: hadoop/avro/trunk/src/java/org/apache/avro/io/DatumReader.java
URL: http://svn.apache.org/viewvc/hadoop/avro/trunk/src/java/org/apache/avro/io/DatumReader.java?rev=782809&r1=782808&r2=782809&view=diff
==============================================================================
--- hadoop/avro/trunk/src/java/org/apache/avro/io/DatumReader.java (original)
+++ hadoop/avro/trunk/src/java/org/apache/avro/io/DatumReader.java Mon Jun 8 21:54:17 2009
@@ -17,10 +17,9 @@
*/
package org.apache.avro.io;
-import java.io.*;
-import java.util.*;
+import java.io.IOException;
-import org.apache.avro.*;
+import org.apache.avro.Schema;
/** Read data of a schema.
* <p>Determines the in-memory data representation.
Modified: hadoop/avro/trunk/src/java/org/apache/avro/io/DatumWriter.java
URL: http://svn.apache.org/viewvc/hadoop/avro/trunk/src/java/org/apache/avro/io/DatumWriter.java?rev=782809&r1=782808&r2=782809&view=diff
==============================================================================
--- hadoop/avro/trunk/src/java/org/apache/avro/io/DatumWriter.java (original)
+++ hadoop/avro/trunk/src/java/org/apache/avro/io/DatumWriter.java Mon Jun 8 21:54:17 2009
@@ -17,10 +17,9 @@
*/
package org.apache.avro.io;
-import java.io.*;
-import java.util.*;
+import java.io.IOException;
-import org.apache.avro.*;
+import org.apache.avro.Schema;
/** Write data of a schema.
* <p>Implemented for different in-memory data representations.
Modified: hadoop/avro/trunk/src/java/org/apache/avro/ipc/AvroRemoteException.java
URL: http://svn.apache.org/viewvc/hadoop/avro/trunk/src/java/org/apache/avro/ipc/AvroRemoteException.java?rev=782809&r1=782808&r2=782809&view=diff
==============================================================================
--- hadoop/avro/trunk/src/java/org/apache/avro/ipc/AvroRemoteException.java (original)
+++ hadoop/avro/trunk/src/java/org/apache/avro/ipc/AvroRemoteException.java Mon Jun 8 21:54:17 2009
@@ -20,10 +20,6 @@
import java.io.IOException;
-import org.apache.avro.*;
-import org.apache.avro.io.*;
-import org.apache.avro.util.*;
-
/** Base class for exceptions thrown to client by server. */
public class AvroRemoteException extends IOException {
private Object value;
Modified: hadoop/avro/trunk/src/java/org/apache/avro/ipc/Requestor.java
URL: http://svn.apache.org/viewvc/hadoop/avro/trunk/src/java/org/apache/avro/ipc/Requestor.java?rev=782809&r1=782808&r2=782809&view=diff
==============================================================================
--- hadoop/avro/trunk/src/java/org/apache/avro/ipc/Requestor.java (original)
+++ hadoop/avro/trunk/src/java/org/apache/avro/ipc/Requestor.java Mon Jun 8 21:54:17 2009
@@ -18,17 +18,22 @@
package org.apache.avro.ipc;
-import java.io.*;
+import java.io.IOException;
import java.nio.ByteBuffer;
-import java.util.*;
-import java.security.*;
-
-import org.apache.avro.*;
+import java.util.Collections;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+import org.apache.avro.AvroRuntimeException;
+import org.apache.avro.Protocol;
+import org.apache.avro.Schema;
import org.apache.avro.Protocol.Message;
-import org.apache.avro.util.*;
-import org.apache.avro.io.*;
-import org.apache.avro.specific.*;
-
+import org.apache.avro.io.ValueReader;
+import org.apache.avro.io.ValueWriter;
+import org.apache.avro.specific.SpecificDatumReader;
+import org.apache.avro.specific.SpecificDatumWriter;
+import org.apache.avro.util.Utf8;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
Modified: hadoop/avro/trunk/src/java/org/apache/avro/ipc/SocketServer.java
URL: http://svn.apache.org/viewvc/hadoop/avro/trunk/src/java/org/apache/avro/ipc/SocketServer.java?rev=782809&r1=782808&r2=782809&view=diff
==============================================================================
--- hadoop/avro/trunk/src/java/org/apache/avro/ipc/SocketServer.java (original)
+++ hadoop/avro/trunk/src/java/org/apache/avro/ipc/SocketServer.java Mon Jun 8 21:54:17 2009
@@ -18,16 +18,12 @@
package org.apache.avro.ipc;
-import java.io.*;
+import java.io.IOException;
import java.net.InetSocketAddress;
import java.net.SocketAddress;
-import java.nio.channels.SocketChannel;
-import java.nio.channels.ServerSocketChannel;
import java.nio.channels.ClosedChannelException;
-import java.nio.ByteBuffer;
-import java.util.*;
-
-import org.apache.avro.*;
+import java.nio.channels.ServerSocketChannel;
+import java.nio.channels.SocketChannel;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
Modified: hadoop/avro/trunk/src/java/org/apache/avro/reflect/ReflectData.java
URL: http://svn.apache.org/viewvc/hadoop/avro/trunk/src/java/org/apache/avro/reflect/ReflectData.java?rev=782809&r1=782808&r2=782809&view=diff
==============================================================================
--- hadoop/avro/trunk/src/java/org/apache/avro/reflect/ReflectData.java (original)
+++ hadoop/avro/trunk/src/java/org/apache/avro/reflect/ReflectData.java Mon Jun 8 21:54:17 2009
@@ -23,7 +23,6 @@
import java.lang.reflect.ParameterizedType;
import java.nio.ByteBuffer;
import java.util.ArrayList;
-import java.util.HashMap;
import java.util.Collections;
import java.util.LinkedHashMap;
import java.util.List;
Modified: hadoop/avro/trunk/src/java/org/apache/avro/reflect/ReflectDatumReader.java
URL: http://svn.apache.org/viewvc/hadoop/avro/trunk/src/java/org/apache/avro/reflect/ReflectDatumReader.java?rev=782809&r1=782808&r2=782809&view=diff
==============================================================================
--- hadoop/avro/trunk/src/java/org/apache/avro/reflect/ReflectDatumReader.java (original)
+++ hadoop/avro/trunk/src/java/org/apache/avro/reflect/ReflectDatumReader.java Mon Jun 8 21:54:17 2009
@@ -17,7 +17,6 @@
*/
package org.apache.avro.reflect;
-import java.io.IOException;
import java.lang.reflect.Constructor;
import java.lang.reflect.Field;
import java.util.Map;
@@ -27,7 +26,6 @@
import org.apache.avro.Schema;
import org.apache.avro.generic.GenericDatumReader;
import org.apache.avro.io.DatumReader;
-import org.apache.avro.io.ValueReader;
/** {@link DatumReader} for existing classes via Java reflection. */
public class ReflectDatumReader extends GenericDatumReader<Object> {
Modified: hadoop/avro/trunk/src/java/org/apache/avro/reflect/ReflectDatumWriter.java
URL: http://svn.apache.org/viewvc/hadoop/avro/trunk/src/java/org/apache/avro/reflect/ReflectDatumWriter.java?rev=782809&r1=782808&r2=782809&view=diff
==============================================================================
--- hadoop/avro/trunk/src/java/org/apache/avro/reflect/ReflectDatumWriter.java (original)
+++ hadoop/avro/trunk/src/java/org/apache/avro/reflect/ReflectDatumWriter.java Mon Jun 8 21:54:17 2009
@@ -19,7 +19,6 @@
import java.io.IOException;
import java.lang.reflect.Field;
-import java.util.Map;
import org.apache.avro.AvroRuntimeException;
import org.apache.avro.Schema;
Modified: hadoop/avro/trunk/src/java/org/apache/avro/reflect/ReflectResponder.java
URL: http://svn.apache.org/viewvc/hadoop/avro/trunk/src/java/org/apache/avro/reflect/ReflectResponder.java?rev=782809&r1=782808&r2=782809&view=diff
==============================================================================
--- hadoop/avro/trunk/src/java/org/apache/avro/reflect/ReflectResponder.java (original)
+++ hadoop/avro/trunk/src/java/org/apache/avro/reflect/ReflectResponder.java Mon Jun 8 21:54:17 2009
@@ -23,7 +23,6 @@
import java.lang.reflect.Method;
import java.nio.ByteBuffer;
import java.util.Map;
-import java.util.Set;
import org.apache.avro.AvroRuntimeException;
import org.apache.avro.Schema;
Modified: hadoop/avro/trunk/src/java/org/apache/avro/specific/SpecificDatumReader.java
URL: http://svn.apache.org/viewvc/hadoop/avro/trunk/src/java/org/apache/avro/specific/SpecificDatumReader.java?rev=782809&r1=782808&r2=782809&view=diff
==============================================================================
--- hadoop/avro/trunk/src/java/org/apache/avro/specific/SpecificDatumReader.java (original)
+++ hadoop/avro/trunk/src/java/org/apache/avro/specific/SpecificDatumReader.java Mon Jun 8 21:54:17 2009
@@ -17,16 +17,8 @@
*/
package org.apache.avro.specific;
-import java.io.IOException;
-import java.util.IdentityHashMap;
-import java.util.Map;
-import java.util.Set;
-import java.util.concurrent.ConcurrentHashMap;
-
-import org.apache.avro.AvroRuntimeException;
import org.apache.avro.Schema;
import org.apache.avro.io.DatumReader;
-import org.apache.avro.io.ValueReader;
import org.apache.avro.reflect.ReflectDatumReader;
/** {@link DatumReader} for generated Java classes. */
Modified: hadoop/avro/trunk/src/java/org/apache/avro/specific/SpecificDatumWriter.java
URL: http://svn.apache.org/viewvc/hadoop/avro/trunk/src/java/org/apache/avro/specific/SpecificDatumWriter.java?rev=782809&r1=782808&r2=782809&view=diff
==============================================================================
--- hadoop/avro/trunk/src/java/org/apache/avro/specific/SpecificDatumWriter.java (original)
+++ hadoop/avro/trunk/src/java/org/apache/avro/specific/SpecificDatumWriter.java Mon Jun 8 21:54:17 2009
@@ -17,12 +17,8 @@
*/
package org.apache.avro.specific;
-import java.io.IOException;
-import java.util.Map;
-
import org.apache.avro.Schema;
import org.apache.avro.io.DatumWriter;
-import org.apache.avro.io.ValueWriter;
import org.apache.avro.reflect.ReflectDatumWriter;
/** {@link DatumWriter} for generated Java classes. */
Modified: hadoop/avro/trunk/src/java/org/apache/avro/specific/SpecificRecord.java
URL: http://svn.apache.org/viewvc/hadoop/avro/trunk/src/java/org/apache/avro/specific/SpecificRecord.java?rev=782809&r1=782808&r2=782809&view=diff
==============================================================================
--- hadoop/avro/trunk/src/java/org/apache/avro/specific/SpecificRecord.java (original)
+++ hadoop/avro/trunk/src/java/org/apache/avro/specific/SpecificRecord.java Mon Jun 8 21:54:17 2009
@@ -17,8 +17,6 @@
*/
package org.apache.avro.specific;
-import java.util.*;
-
import org.apache.avro.Schema;
/** Implemented by generated record classes. Permits efficient access to
Modified: hadoop/avro/trunk/src/java/org/apache/avro/specific/SpecificResponder.java
URL: http://svn.apache.org/viewvc/hadoop/avro/trunk/src/java/org/apache/avro/specific/SpecificResponder.java?rev=782809&r1=782808&r2=782809&view=diff
==============================================================================
--- hadoop/avro/trunk/src/java/org/apache/avro/specific/SpecificResponder.java (original)
+++ hadoop/avro/trunk/src/java/org/apache/avro/specific/SpecificResponder.java Mon Jun 8 21:54:17 2009
@@ -18,16 +18,11 @@
package org.apache.avro.specific;
-import java.util.*;
-import java.nio.ByteBuffer;
-import java.io.*;
-
-import org.apache.avro.*;
-import org.apache.avro.io.*;
-import org.apache.avro.util.*;
-import org.apache.avro.ipc.*;
+import org.apache.avro.Schema;
+import org.apache.avro.io.DatumReader;
+import org.apache.avro.io.DatumWriter;
+import org.apache.avro.ipc.Responder;
import org.apache.avro.reflect.ReflectResponder;
-import org.apache.avro.Protocol.Message;
/** {@link Responder} for generated interfaces.*/
public class SpecificResponder extends ReflectResponder {
Modified: hadoop/avro/trunk/src/test/java/org/apache/avro/TestFsData.java
URL: http://svn.apache.org/viewvc/hadoop/avro/trunk/src/test/java/org/apache/avro/TestFsData.java?rev=782809&r1=782808&r2=782809&view=diff
==============================================================================
--- hadoop/avro/trunk/src/test/java/org/apache/avro/TestFsData.java (original)
+++ hadoop/avro/trunk/src/test/java/org/apache/avro/TestFsData.java Mon Jun 8 21:54:17 2009
@@ -61,7 +61,6 @@
public TestResponder() { super(PROTOCOL); }
public Object respond(Message message, Object request)
throws AvroRemoteException {
- @SuppressWarnings(value="unchecked")
GenericRecord params = (GenericRecord)request;
if ("read".equals(message.getName())) {
Modified: hadoop/avro/trunk/src/test/java/org/apache/avro/TestProtocolGeneric.java
URL: http://svn.apache.org/viewvc/hadoop/avro/trunk/src/test/java/org/apache/avro/TestProtocolGeneric.java?rev=782809&r1=782808&r2=782809&view=diff
==============================================================================
--- hadoop/avro/trunk/src/test/java/org/apache/avro/TestProtocolGeneric.java (original)
+++ hadoop/avro/trunk/src/test/java/org/apache/avro/TestProtocolGeneric.java Mon Jun 8 21:54:17 2009
@@ -60,7 +60,6 @@
public TestResponder() { super(PROTOCOL); }
public Object respond(Message message, Object request)
throws AvroRemoteException {
- @SuppressWarnings(value="unchecked")
GenericRecord params = (GenericRecord)request;
if ("hello".equals(message.getName())) {
Modified: hadoop/avro/trunk/src/test/java/org/apache/avro/TestSchema.java
URL: http://svn.apache.org/viewvc/hadoop/avro/trunk/src/test/java/org/apache/avro/TestSchema.java?rev=782809&r1=782808&r2=782809&view=diff
==============================================================================
--- hadoop/avro/trunk/src/test/java/org/apache/avro/TestSchema.java (original)
+++ hadoop/avro/trunk/src/test/java/org/apache/avro/TestSchema.java Mon Jun 8 21:54:17 2009
@@ -17,7 +17,15 @@
*/
package org.apache.avro;
-import org.apache.avro.Schema.Field;
+import static org.testng.AssertJUnit.assertEquals;
+import static org.testng.AssertJUnit.assertTrue;
+
+import java.io.ByteArrayInputStream;
+import java.io.ByteArrayOutputStream;
+import java.io.IOException;
+import java.nio.ByteBuffer;
+import java.util.HashMap;
+
import org.apache.avro.generic.GenericArray;
import org.apache.avro.generic.GenericData;
import org.apache.avro.generic.GenericDatumReader;
@@ -27,17 +35,8 @@
import org.apache.avro.io.ValueReader;
import org.apache.avro.io.ValueWriter;
import org.apache.avro.util.Utf8;
-import static org.testng.AssertJUnit.assertEquals;
-import static org.testng.AssertJUnit.assertTrue;
import org.testng.annotations.Test;
-import java.io.ByteArrayInputStream;
-import java.io.ByteArrayOutputStream;
-import java.io.IOException;
-import java.nio.ByteBuffer;
-import java.util.HashMap;
-import java.util.LinkedHashMap;
-
public class TestSchema {
private static final int COUNT =
Modified: hadoop/avro/trunk/src/test/java/org/apache/avro/io/TestValueReader.java
URL: http://svn.apache.org/viewvc/hadoop/avro/trunk/src/test/java/org/apache/avro/io/TestValueReader.java?rev=782809&r1=782808&r2=782809&view=diff
==============================================================================
--- hadoop/avro/trunk/src/test/java/org/apache/avro/io/TestValueReader.java (original)
+++ hadoop/avro/trunk/src/test/java/org/apache/avro/io/TestValueReader.java Mon Jun 8 21:54:17 2009
@@ -17,14 +17,12 @@
*/
package org.apache.avro.io;
-import org.apache.avro.util.Utf8;
-import static org.testng.AssertJUnit.fail;
-import org.testng.annotations.Test;
-
import java.io.ByteArrayInputStream;
import java.io.EOFException;
import java.io.IOException;
-import java.io.InputStream;
+
+import org.apache.avro.util.Utf8;
+import org.testng.annotations.Test;
public class TestValueReader {