AVRO-2117: Cleanup Java - Remove unused imports
Project: http://git-wip-us.apache.org/repos/asf/avro/repo Commit: http://git-wip-us.apache.org/repos/asf/avro/commit/61ab7383 Tree: http://git-wip-us.apache.org/repos/asf/avro/tree/61ab7383 Diff: http://git-wip-us.apache.org/repos/asf/avro/diff/61ab7383 Branch: refs/heads/master Commit: 61ab73837a56b5ce89b6a05d205b38b78d58cea9 Parents: 2bbb996 Author: Niels Basjes <[email protected]> Authored: Wed Dec 13 16:01:18 2017 +0100 Committer: Niels Basjes <[email protected]> Committed: Fri Dec 29 17:52:54 2017 +0100 ---------------------------------------------------------------------- .../org/apache/avro/TestDataFileCustomSync.java | 5 ----- .../org/apache/avro/io/TestJsonDecoder.java | 1 - .../org/apache/avro/reflect/TestByteBuffer.java | 1 - .../apache/avro/reflect/TestReflectData.java | 4 +--- .../org/apache/avro/util/TestCaseFinder.java | 2 +- .../java/org/apache/avro/util/TestUtf8.java | 2 -- .../org/apache/avro/DataFileInteropTest.java | 1 - .../org/apache/avro/TestDataFileSpecific.java | 4 ---- .../java/org/apache/avro/TestProtocolHttp.java | 1 - .../apache/avro/TestProtocolReflectMeta.java | 1 - .../org/apache/avro/TestProtocolSpecific.java | 2 -- .../test/java/org/apache/avro/TestSchema.java | 1 - .../ipc/NettyTransceiverWhenFailsToConnect.java | 2 -- .../ipc/TestNettyServerWithCompression.java | 17 ----------------- .../TestNettyTransceiverWhenServerStops.java | 1 - .../avro/specific/TestSpecificBuilderTree.java | 2 -- .../apache/avro/specific/TestSpecificData.java | 1 - .../avro/hadoop/io/TestAvroSerialization.java | 6 ------ .../avro/mapred/TestAvroMultipleOutputs.java | 5 ----- .../org/apache/avro/mapred/TestWeather.java | 1 - .../org/apache/avro/mapred/WordCountUtil.java | 2 -- .../avro/mapred/tether/TetherTaskRunner.java | 4 ---- .../avro/mapreduce/TestAvroKeyOutputFormat.java | 2 -- .../avro/mapreduce/TestAvroMultipleOutputs.java | 2 -- .../avro/mapreduce/TestKeyValueWordCount.java | 1 - .../java/org/apache/avro/thrift/test/E.java | 4 ---- .../java/org/apache/avro/thrift/test/Error.java | 13 +------------ .../java/org/apache/avro/thrift/test/Foo.java | 9 ++------- .../org/apache/avro/thrift/test/FooOrBar.java | 20 +------------------- .../org/apache/avro/thrift/test/Nested.java | 13 +------------ .../java/org/apache/avro/thrift/test/Test.java | 8 +------- .../org/apache/avro/tool/TestConcatTool.java | 1 - .../avro/tool/TestDataFileRepairTool.java | 1 - .../tool/TestJsonToFromBinaryFragmentTools.java | 1 - .../org/apache/avro/tool/TestTetherTool.java | 4 ---- .../org/apache/avro/tool/TestTextFileTools.java | 6 ------ .../org/apache/avro/tool/TestToTrevniTool.java | 2 -- .../java/org/apache/trevni/avro/RandomData.java | 1 - .../java/org/apache/trevni/avro/TestCases.java | 3 --- .../apache/trevni/avro/TestEvolvedSchema.java | 2 -- .../org/apache/trevni/avro/TestWordCount.java | 8 -------- .../org/apache/trevni/avro/WordCountUtil.java | 15 --------------- .../java/org/apache/trevni/TestColumnFile.java | 3 --- .../java/org/apache/trevni/TestInputBytes.java | 3 --- .../test/java/org/apache/trevni/TestUtil.java | 1 - 45 files changed, 8 insertions(+), 181 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/avro/blob/61ab7383/lang/java/avro/src/test/java/org/apache/avro/TestDataFileCustomSync.java ---------------------------------------------------------------------- diff --git a/lang/java/avro/src/test/java/org/apache/avro/TestDataFileCustomSync.java b/lang/java/avro/src/test/java/org/apache/avro/TestDataFileCustomSync.java index 342c38b..d9f564d 100644 --- a/lang/java/avro/src/test/java/org/apache/avro/TestDataFileCustomSync.java +++ b/lang/java/avro/src/test/java/org/apache/avro/TestDataFileCustomSync.java @@ -18,18 +18,13 @@ package org.apache.avro; import java.io.ByteArrayOutputStream; -import java.io.File; -import java.io.FileOutputStream; import java.io.IOException; import java.security.MessageDigest; import java.security.NoSuchAlgorithmException; import java.util.Arrays; import java.util.UUID; import org.apache.avro.Schema.Type; -import org.apache.avro.file.DataFileConstants; -import org.apache.avro.file.DataFileReader; import org.apache.avro.file.DataFileWriter; -import org.apache.avro.generic.GenericDatumReader; import org.apache.avro.generic.GenericDatumWriter; import org.apache.avro.util.Utf8; import org.junit.Test; http://git-wip-us.apache.org/repos/asf/avro/blob/61ab7383/lang/java/avro/src/test/java/org/apache/avro/io/TestJsonDecoder.java ---------------------------------------------------------------------- diff --git a/lang/java/avro/src/test/java/org/apache/avro/io/TestJsonDecoder.java b/lang/java/avro/src/test/java/org/apache/avro/io/TestJsonDecoder.java index 8486e5c..c637498 100644 --- a/lang/java/avro/src/test/java/org/apache/avro/io/TestJsonDecoder.java +++ b/lang/java/avro/src/test/java/org/apache/avro/io/TestJsonDecoder.java @@ -18,7 +18,6 @@ package org.apache.avro.io; import org.apache.avro.Schema; -import org.apache.avro.Schema.Parser; import org.apache.avro.generic.GenericRecord; import org.apache.avro.generic.GenericDatumReader; http://git-wip-us.apache.org/repos/asf/avro/blob/61ab7383/lang/java/avro/src/test/java/org/apache/avro/reflect/TestByteBuffer.java ---------------------------------------------------------------------- diff --git a/lang/java/avro/src/test/java/org/apache/avro/reflect/TestByteBuffer.java b/lang/java/avro/src/test/java/org/apache/avro/reflect/TestByteBuffer.java index e2bdbfa..a8a8b74 100644 --- a/lang/java/avro/src/test/java/org/apache/avro/reflect/TestByteBuffer.java +++ b/lang/java/avro/src/test/java/org/apache/avro/reflect/TestByteBuffer.java @@ -43,7 +43,6 @@ import org.apache.avro.io.DatumWriter; import org.apache.avro.reflect.ReflectData; import org.apache.avro.reflect.ReflectDatumReader; import org.apache.avro.reflect.ReflectDatumWriter; -import org.junit.After; import org.junit.Before; import org.junit.Test; http://git-wip-us.apache.org/repos/asf/avro/blob/61ab7383/lang/java/avro/src/test/java/org/apache/avro/reflect/TestReflectData.java ---------------------------------------------------------------------- diff --git a/lang/java/avro/src/test/java/org/apache/avro/reflect/TestReflectData.java b/lang/java/avro/src/test/java/org/apache/avro/reflect/TestReflectData.java index aa4bb42..6d198d5 100644 --- a/lang/java/avro/src/test/java/org/apache/avro/reflect/TestReflectData.java +++ b/lang/java/avro/src/test/java/org/apache/avro/reflect/TestReflectData.java @@ -20,10 +20,8 @@ package org.apache.avro.reflect; import org.apache.avro.Schema; import org.junit.Test; -import java.io.IOException; -import java.lang.reflect.Field; + import java.util.Collections; -import java.util.Map; import static org.hamcrest.Matchers.lessThan; import static org.junit.Assert.assertThat; http://git-wip-us.apache.org/repos/asf/avro/blob/61ab7383/lang/java/avro/src/test/java/org/apache/avro/util/TestCaseFinder.java ---------------------------------------------------------------------- diff --git a/lang/java/avro/src/test/java/org/apache/avro/util/TestCaseFinder.java b/lang/java/avro/src/test/java/org/apache/avro/util/TestCaseFinder.java index 9b85221..4cf6bda 100644 --- a/lang/java/avro/src/test/java/org/apache/avro/util/TestCaseFinder.java +++ b/lang/java/avro/src/test/java/org/apache/avro/util/TestCaseFinder.java @@ -28,7 +28,7 @@ import org.junit.runner.RunWith; import org.junit.runners.Parameterized; import org.junit.runners.Parameterized.Parameters; import org.junit.experimental.runners.Enclosed; -import static org.junit.Assert.assertEquals; + import static org.junit.Assert.assertTrue; @RunWith(Enclosed.class) http://git-wip-us.apache.org/repos/asf/avro/blob/61ab7383/lang/java/avro/src/test/java/org/apache/avro/util/TestUtf8.java ---------------------------------------------------------------------- diff --git a/lang/java/avro/src/test/java/org/apache/avro/util/TestUtf8.java b/lang/java/avro/src/test/java/org/apache/avro/util/TestUtf8.java index 2fe9875..3272ea3 100644 --- a/lang/java/avro/src/test/java/org/apache/avro/util/TestUtf8.java +++ b/lang/java/avro/src/test/java/org/apache/avro/util/TestUtf8.java @@ -19,8 +19,6 @@ package org.apache.avro.util; import java.io.UnsupportedEncodingException; -import junit.framework.Assert; - import org.junit.Test; import static junit.framework.Assert.assertSame; http://git-wip-us.apache.org/repos/asf/avro/blob/61ab7383/lang/java/ipc/src/test/java/org/apache/avro/DataFileInteropTest.java ---------------------------------------------------------------------- diff --git a/lang/java/ipc/src/test/java/org/apache/avro/DataFileInteropTest.java b/lang/java/ipc/src/test/java/org/apache/avro/DataFileInteropTest.java index 33d2682..ed4c95b 100644 --- a/lang/java/ipc/src/test/java/org/apache/avro/DataFileInteropTest.java +++ b/lang/java/ipc/src/test/java/org/apache/avro/DataFileInteropTest.java @@ -24,7 +24,6 @@ import org.apache.avro.file.DataFileReader; import org.apache.avro.file.FileReader; import org.apache.avro.generic.GenericDatumReader; import org.apache.avro.io.DatumReader; -import org.apache.avro.reflect.ReflectDatumReader; import org.apache.avro.specific.SpecificDatumReader; import org.junit.Assert; import org.junit.BeforeClass; http://git-wip-us.apache.org/repos/asf/avro/blob/61ab7383/lang/java/ipc/src/test/java/org/apache/avro/TestDataFileSpecific.java ---------------------------------------------------------------------- diff --git a/lang/java/ipc/src/test/java/org/apache/avro/TestDataFileSpecific.java b/lang/java/ipc/src/test/java/org/apache/avro/TestDataFileSpecific.java index fa5a894..ba0c3b1 100644 --- a/lang/java/ipc/src/test/java/org/apache/avro/TestDataFileSpecific.java +++ b/lang/java/ipc/src/test/java/org/apache/avro/TestDataFileSpecific.java @@ -18,11 +18,7 @@ package org.apache.avro; import java.io.File; -import java.io.FileOutputStream; import java.io.IOException; -import java.util.ArrayList; -import java.util.Arrays; -import java.util.List; import org.apache.avro.file.DataFileReader; import org.apache.avro.file.DataFileWriter; http://git-wip-us.apache.org/repos/asf/avro/blob/61ab7383/lang/java/ipc/src/test/java/org/apache/avro/TestProtocolHttp.java ---------------------------------------------------------------------- diff --git a/lang/java/ipc/src/test/java/org/apache/avro/TestProtocolHttp.java b/lang/java/ipc/src/test/java/org/apache/avro/TestProtocolHttp.java index a1a3534..d73f22d 100644 --- a/lang/java/ipc/src/test/java/org/apache/avro/TestProtocolHttp.java +++ b/lang/java/ipc/src/test/java/org/apache/avro/TestProtocolHttp.java @@ -18,7 +18,6 @@ package org.apache.avro; import org.apache.avro.Schema; -import org.apache.avro.Schema.Field; import org.apache.avro.ipc.Server; import org.apache.avro.ipc.Transceiver; import org.apache.avro.ipc.Responder; http://git-wip-us.apache.org/repos/asf/avro/blob/61ab7383/lang/java/ipc/src/test/java/org/apache/avro/TestProtocolReflectMeta.java ---------------------------------------------------------------------- diff --git a/lang/java/ipc/src/test/java/org/apache/avro/TestProtocolReflectMeta.java b/lang/java/ipc/src/test/java/org/apache/avro/TestProtocolReflectMeta.java index 7814539..dfd34b4 100644 --- a/lang/java/ipc/src/test/java/org/apache/avro/TestProtocolReflectMeta.java +++ b/lang/java/ipc/src/test/java/org/apache/avro/TestProtocolReflectMeta.java @@ -21,7 +21,6 @@ import org.apache.avro.ipc.SocketServer; import org.apache.avro.ipc.SocketTransceiver; import org.apache.avro.ipc.reflect.ReflectRequestor; import org.apache.avro.ipc.reflect.ReflectResponder; -import org.apache.avro.test.Simple; import org.junit.Before; import java.net.InetSocketAddress; http://git-wip-us.apache.org/repos/asf/avro/blob/61ab7383/lang/java/ipc/src/test/java/org/apache/avro/TestProtocolSpecific.java ---------------------------------------------------------------------- diff --git a/lang/java/ipc/src/test/java/org/apache/avro/TestProtocolSpecific.java b/lang/java/ipc/src/test/java/org/apache/avro/TestProtocolSpecific.java index 9ce0f39..5e7603b 100644 --- a/lang/java/ipc/src/test/java/org/apache/avro/TestProtocolSpecific.java +++ b/lang/java/ipc/src/test/java/org/apache/avro/TestProtocolSpecific.java @@ -37,11 +37,9 @@ import org.apache.avro.test.Kind; import org.apache.avro.test.MD5; import org.apache.avro.test.TestError; import org.apache.avro.test.TestRecord; -import org.junit.After; import org.junit.Test; import org.junit.Before; import org.junit.AfterClass; -import static org.junit.Assert.assertTrue; import static org.junit.Assert.*; http://git-wip-us.apache.org/repos/asf/avro/blob/61ab7383/lang/java/ipc/src/test/java/org/apache/avro/TestSchema.java ---------------------------------------------------------------------- diff --git a/lang/java/ipc/src/test/java/org/apache/avro/TestSchema.java b/lang/java/ipc/src/test/java/org/apache/avro/TestSchema.java index 1d7e4c9..31d1943 100644 --- a/lang/java/ipc/src/test/java/org/apache/avro/TestSchema.java +++ b/lang/java/ipc/src/test/java/org/apache/avro/TestSchema.java @@ -49,7 +49,6 @@ import org.apache.avro.io.DecoderFactory; import org.apache.avro.io.Encoder; import org.apache.avro.io.EncoderFactory; import org.apache.avro.util.Utf8; -import org.codehaus.jackson.JsonNode; import org.junit.Test; public class TestSchema { http://git-wip-us.apache.org/repos/asf/avro/blob/61ab7383/lang/java/ipc/src/test/java/org/apache/avro/ipc/NettyTransceiverWhenFailsToConnect.java ---------------------------------------------------------------------- diff --git a/lang/java/ipc/src/test/java/org/apache/avro/ipc/NettyTransceiverWhenFailsToConnect.java b/lang/java/ipc/src/test/java/org/apache/avro/ipc/NettyTransceiverWhenFailsToConnect.java index 2c33c68..6776353 100644 --- a/lang/java/ipc/src/test/java/org/apache/avro/ipc/NettyTransceiverWhenFailsToConnect.java +++ b/lang/java/ipc/src/test/java/org/apache/avro/ipc/NettyTransceiverWhenFailsToConnect.java @@ -17,7 +17,6 @@ */ package org.apache.avro.ipc; -import junit.framework.Assert; import org.jboss.netty.channel.ChannelFactory; import org.jboss.netty.channel.ChannelPipeline; import org.jboss.netty.channel.socket.SocketChannel; @@ -27,7 +26,6 @@ import org.junit.Test; import java.io.IOException; import java.net.InetSocketAddress; import java.net.ServerSocket; -import java.util.concurrent.Executors; import static org.junit.Assert.assertEquals; http://git-wip-us.apache.org/repos/asf/avro/blob/61ab7383/lang/java/ipc/src/test/java/org/apache/avro/ipc/TestNettyServerWithCompression.java ---------------------------------------------------------------------- diff --git a/lang/java/ipc/src/test/java/org/apache/avro/ipc/TestNettyServerWithCompression.java b/lang/java/ipc/src/test/java/org/apache/avro/ipc/TestNettyServerWithCompression.java index 1fe20ce..ab8de99 100644 --- a/lang/java/ipc/src/test/java/org/apache/avro/ipc/TestNettyServerWithCompression.java +++ b/lang/java/ipc/src/test/java/org/apache/avro/ipc/TestNettyServerWithCompression.java @@ -17,23 +17,10 @@ */ package org.apache.avro.ipc; -import static org.junit.Assert.assertEquals; - import java.io.IOException; import java.net.InetSocketAddress; -import java.security.KeyStore; -import java.security.Security; -import java.security.cert.X509Certificate; -import java.util.concurrent.CountDownLatch; import java.util.concurrent.Executors; -import java.util.concurrent.TimeUnit; - -import junit.framework.Assert; -import org.apache.avro.ipc.specific.SpecificRequestor; -import org.apache.avro.ipc.specific.SpecificResponder; -import org.apache.avro.test.Mail; -import org.apache.avro.test.Message; import org.jboss.netty.channel.ChannelFactory; import org.jboss.netty.channel.ChannelPipeline; import org.jboss.netty.channel.ChannelPipelineFactory; @@ -43,10 +30,6 @@ import org.jboss.netty.channel.socket.nio.NioClientSocketChannelFactory; import org.jboss.netty.channel.socket.nio.NioServerSocketChannelFactory; import org.jboss.netty.handler.codec.compression.ZlibDecoder; import org.jboss.netty.handler.codec.compression.ZlibEncoder; -import org.junit.AfterClass; -import static org.junit.Assert.assertEquals; -import org.junit.BeforeClass; -import org.junit.Test; public class TestNettyServerWithCompression extends TestNettyServer{ http://git-wip-us.apache.org/repos/asf/avro/blob/61ab7383/lang/java/ipc/src/test/java/org/apache/avro/ipc/TestNettyTransceiverWhenServerStops.java ---------------------------------------------------------------------- diff --git a/lang/java/ipc/src/test/java/org/apache/avro/ipc/TestNettyTransceiverWhenServerStops.java b/lang/java/ipc/src/test/java/org/apache/avro/ipc/TestNettyTransceiverWhenServerStops.java index 6550375..d79ce45 100644 --- a/lang/java/ipc/src/test/java/org/apache/avro/ipc/TestNettyTransceiverWhenServerStops.java +++ b/lang/java/ipc/src/test/java/org/apache/avro/ipc/TestNettyTransceiverWhenServerStops.java @@ -21,7 +21,6 @@ import org.apache.avro.ipc.specific.SpecificRequestor; import org.apache.avro.ipc.specific.SpecificResponder; import org.apache.avro.test.Mail; import org.apache.avro.test.Message; -import org.junit.Test; import java.net.InetSocketAddress; import java.util.ArrayList; http://git-wip-us.apache.org/repos/asf/avro/blob/61ab7383/lang/java/ipc/src/test/java/org/apache/avro/specific/TestSpecificBuilderTree.java ---------------------------------------------------------------------- diff --git a/lang/java/ipc/src/test/java/org/apache/avro/specific/TestSpecificBuilderTree.java b/lang/java/ipc/src/test/java/org/apache/avro/specific/TestSpecificBuilderTree.java index a68bd6d..53ed754 100644 --- a/lang/java/ipc/src/test/java/org/apache/avro/specific/TestSpecificBuilderTree.java +++ b/lang/java/ipc/src/test/java/org/apache/avro/specific/TestSpecificBuilderTree.java @@ -19,13 +19,11 @@ package org.apache.avro.specific; import org.apache.avro.AvroMissingFieldException; import org.apache.avro.test.http.*; -import org.apache.avro.test.nullable.Nullable; import org.apache.avro.test.nullable.RecordWithNullables; import org.junit.Test; import java.util.ArrayList; -import static org.apache.avro.test.nullable.Nullable.*; import static org.junit.Assert.assertEquals; import static org.junit.Assert.assertFalse; import static org.junit.Assert.assertTrue; http://git-wip-us.apache.org/repos/asf/avro/blob/61ab7383/lang/java/ipc/src/test/java/org/apache/avro/specific/TestSpecificData.java ---------------------------------------------------------------------- diff --git a/lang/java/ipc/src/test/java/org/apache/avro/specific/TestSpecificData.java b/lang/java/ipc/src/test/java/org/apache/avro/specific/TestSpecificData.java index 893cf97..de0da4e 100644 --- a/lang/java/ipc/src/test/java/org/apache/avro/specific/TestSpecificData.java +++ b/lang/java/ipc/src/test/java/org/apache/avro/specific/TestSpecificData.java @@ -38,7 +38,6 @@ import org.junit.Assert; import org.apache.avro.Schema; import org.apache.avro.generic.GenericData; -import org.apache.avro.util.Utf8; import org.apache.avro.TestSchema; import org.apache.avro.test.TestRecord; http://git-wip-us.apache.org/repos/asf/avro/blob/61ab7383/lang/java/mapred/src/test/java/org/apache/avro/hadoop/io/TestAvroSerialization.java ---------------------------------------------------------------------- diff --git a/lang/java/mapred/src/test/java/org/apache/avro/hadoop/io/TestAvroSerialization.java b/lang/java/mapred/src/test/java/org/apache/avro/hadoop/io/TestAvroSerialization.java index 55dc945..67a0e84 100644 --- a/lang/java/mapred/src/test/java/org/apache/avro/hadoop/io/TestAvroSerialization.java +++ b/lang/java/mapred/src/test/java/org/apache/avro/hadoop/io/TestAvroSerialization.java @@ -23,18 +23,12 @@ import static org.junit.Assert.*; import java.io.ByteArrayInputStream; import java.io.ByteArrayOutputStream; import java.io.IOException; -import java.util.Arrays; -import java.util.List; import org.apache.avro.Schema; import org.apache.avro.reflect.ReflectData; import org.apache.avro.reflect.ReflectDatumReader; import org.apache.avro.util.Utf8; import org.apache.avro.generic.GenericData; -import org.apache.avro.generic.GenericDatumReader; -import org.apache.avro.generic.GenericDatumWriter; -import org.apache.avro.io.DatumReader; -import org.apache.avro.io.DatumWriter; import org.apache.avro.mapred.AvroKey; import org.apache.avro.mapred.AvroValue; import org.apache.avro.mapred.AvroWrapper; http://git-wip-us.apache.org/repos/asf/avro/blob/61ab7383/lang/java/mapred/src/test/java/org/apache/avro/mapred/TestAvroMultipleOutputs.java ---------------------------------------------------------------------- diff --git a/lang/java/mapred/src/test/java/org/apache/avro/mapred/TestAvroMultipleOutputs.java b/lang/java/mapred/src/test/java/org/apache/avro/mapred/TestAvroMultipleOutputs.java index 45e5728..feb328a 100644 --- a/lang/java/mapred/src/test/java/org/apache/avro/mapred/TestAvroMultipleOutputs.java +++ b/lang/java/mapred/src/test/java/org/apache/avro/mapred/TestAvroMultipleOutputs.java @@ -33,12 +33,7 @@ import org.apache.hadoop.mapred.JobConf; import org.apache.hadoop.mapred.FileInputFormat; import org.apache.hadoop.mapred.FileOutputFormat; import org.apache.hadoop.mapred.Reporter; -import java.io.OutputStreamWriter; -import java.io.PrintWriter; -import java.io.UnsupportedEncodingException; -import java.util.Locale; -import org.apache.hadoop.io.Text; import org.apache.avro.Schema; import org.apache.avro.util.Utf8; import org.junit.Test; http://git-wip-us.apache.org/repos/asf/avro/blob/61ab7383/lang/java/mapred/src/test/java/org/apache/avro/mapred/TestWeather.java ---------------------------------------------------------------------- diff --git a/lang/java/mapred/src/test/java/org/apache/avro/mapred/TestWeather.java b/lang/java/mapred/src/test/java/org/apache/avro/mapred/TestWeather.java index c6ba4a3..0140c76 100644 --- a/lang/java/mapred/src/test/java/org/apache/avro/mapred/TestWeather.java +++ b/lang/java/mapred/src/test/java/org/apache/avro/mapred/TestWeather.java @@ -36,7 +36,6 @@ import org.apache.avro.specific.SpecificDatumReader; import org.apache.avro.file.DataFileReader; import static org.apache.avro.file.DataFileConstants.SNAPPY_CODEC; import static org.junit.Assert.assertEquals; -import static org.junit.Assert.assertTrue; import org.junit.After; import org.junit.Test; http://git-wip-us.apache.org/repos/asf/avro/blob/61ab7383/lang/java/mapred/src/test/java/org/apache/avro/mapred/WordCountUtil.java ---------------------------------------------------------------------- diff --git a/lang/java/mapred/src/test/java/org/apache/avro/mapred/WordCountUtil.java b/lang/java/mapred/src/test/java/org/apache/avro/mapred/WordCountUtil.java index f85f21f..a47675e 100644 --- a/lang/java/mapred/src/test/java/org/apache/avro/mapred/WordCountUtil.java +++ b/lang/java/mapred/src/test/java/org/apache/avro/mapred/WordCountUtil.java @@ -20,8 +20,6 @@ package org.apache.avro.mapred; import static org.junit.Assert.*; -import java.io.BufferedReader; -import java.io.FileReader; import java.io.IOException; import java.io.File; import java.io.InputStream; http://git-wip-us.apache.org/repos/asf/avro/blob/61ab7383/lang/java/mapred/src/test/java/org/apache/avro/mapred/tether/TetherTaskRunner.java ---------------------------------------------------------------------- diff --git a/lang/java/mapred/src/test/java/org/apache/avro/mapred/tether/TetherTaskRunner.java b/lang/java/mapred/src/test/java/org/apache/avro/mapred/tether/TetherTaskRunner.java index aac6ca3..39cdc42 100644 --- a/lang/java/mapred/src/test/java/org/apache/avro/mapred/tether/TetherTaskRunner.java +++ b/lang/java/mapred/src/test/java/org/apache/avro/mapred/tether/TetherTaskRunner.java @@ -20,17 +20,13 @@ package org.apache.avro.mapred.tether; import java.io.IOException; import java.net.InetSocketAddress; -import java.net.URL; import java.nio.ByteBuffer; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.apache.avro.ipc.HttpServer; -import org.apache.avro.ipc.HttpTransceiver; import org.apache.avro.ipc.SaslSocketServer; -import org.apache.avro.ipc.SaslSocketTransceiver; -import org.apache.avro.ipc.specific.SpecificRequestor; import org.apache.avro.ipc.specific.SpecificResponder; import org.apache.avro.ipc.Server; http://git-wip-us.apache.org/repos/asf/avro/blob/61ab7383/lang/java/mapred/src/test/java/org/apache/avro/mapreduce/TestAvroKeyOutputFormat.java ---------------------------------------------------------------------- diff --git a/lang/java/mapred/src/test/java/org/apache/avro/mapreduce/TestAvroKeyOutputFormat.java b/lang/java/mapred/src/test/java/org/apache/avro/mapreduce/TestAvroKeyOutputFormat.java index 1556250..0248037 100644 --- a/lang/java/mapred/src/test/java/org/apache/avro/mapreduce/TestAvroKeyOutputFormat.java +++ b/lang/java/mapred/src/test/java/org/apache/avro/mapreduce/TestAvroKeyOutputFormat.java @@ -29,7 +29,6 @@ import org.apache.avro.file.CodecFactory; import org.apache.avro.file.DataFileConstants; import org.apache.avro.generic.GenericData; import org.apache.avro.mapred.AvroKey; -import org.apache.avro.mapred.AvroOutputFormat; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.io.NullWritable; import org.apache.hadoop.mapreduce.Job; @@ -37,7 +36,6 @@ import org.apache.hadoop.mapreduce.RecordWriter; import org.apache.hadoop.mapreduce.TaskAttemptContext; import org.apache.hadoop.mapreduce.TaskAttemptID; import org.easymock.Capture; -import org.easymock.EasyMock; import org.junit.Rule; import org.junit.Test; import org.junit.rules.TemporaryFolder; http://git-wip-us.apache.org/repos/asf/avro/blob/61ab7383/lang/java/mapred/src/test/java/org/apache/avro/mapreduce/TestAvroMultipleOutputs.java ---------------------------------------------------------------------- diff --git a/lang/java/mapred/src/test/java/org/apache/avro/mapreduce/TestAvroMultipleOutputs.java b/lang/java/mapred/src/test/java/org/apache/avro/mapreduce/TestAvroMultipleOutputs.java index baaa342..f4df991 100644 --- a/lang/java/mapred/src/test/java/org/apache/avro/mapreduce/TestAvroMultipleOutputs.java +++ b/lang/java/mapred/src/test/java/org/apache/avro/mapreduce/TestAvroMultipleOutputs.java @@ -27,7 +27,6 @@ import org.apache.avro.Schema; import org.apache.avro.file.DataFileReader; import org.apache.avro.generic.GenericData; import org.apache.avro.generic.GenericDatumReader; -import org.apache.avro.reflect.ReflectDatumReader; import org.apache.avro.mapred.AvroKey; import org.apache.avro.mapred.FsInput; @@ -50,7 +49,6 @@ import org.junit.Assert; import org.junit.Rule; import org.junit.Test; import org.junit.rules.TemporaryFolder; -import org.apache.avro.mapred.Pair; public class TestAvroMultipleOutputs { @Rule http://git-wip-us.apache.org/repos/asf/avro/blob/61ab7383/lang/java/mapred/src/test/java/org/apache/avro/mapreduce/TestKeyValueWordCount.java ---------------------------------------------------------------------- diff --git a/lang/java/mapred/src/test/java/org/apache/avro/mapreduce/TestKeyValueWordCount.java b/lang/java/mapred/src/test/java/org/apache/avro/mapreduce/TestKeyValueWordCount.java index 1cf6695..c73b394 100644 --- a/lang/java/mapred/src/test/java/org/apache/avro/mapreduce/TestKeyValueWordCount.java +++ b/lang/java/mapred/src/test/java/org/apache/avro/mapreduce/TestKeyValueWordCount.java @@ -40,7 +40,6 @@ import org.apache.hadoop.mapreduce.Reducer; import org.apache.hadoop.mapreduce.lib.input.FileInputFormat; import org.apache.hadoop.mapreduce.lib.input.TextInputFormat; import org.apache.hadoop.mapreduce.lib.output.FileOutputFormat; -import org.apache.hadoop.mapreduce.lib.reduce.IntSumReducer; import org.junit.Rule; import org.junit.Test; import org.junit.rules.TemporaryFolder; http://git-wip-us.apache.org/repos/asf/avro/blob/61ab7383/lang/java/thrift/src/test/java/org/apache/avro/thrift/test/E.java ---------------------------------------------------------------------- diff --git a/lang/java/thrift/src/test/java/org/apache/avro/thrift/test/E.java b/lang/java/thrift/src/test/java/org/apache/avro/thrift/test/E.java index 899d113..8f7f8a8 100644 --- a/lang/java/thrift/src/test/java/org/apache/avro/thrift/test/E.java +++ b/lang/java/thrift/src/test/java/org/apache/avro/thrift/test/E.java @@ -7,10 +7,6 @@ package org.apache.avro.thrift.test; -import java.util.Map; -import java.util.HashMap; -import org.apache.thrift.TEnum; - public enum E implements org.apache.thrift.TEnum { X(1), Y(2), http://git-wip-us.apache.org/repos/asf/avro/blob/61ab7383/lang/java/thrift/src/test/java/org/apache/avro/thrift/test/Error.java ---------------------------------------------------------------------- diff --git a/lang/java/thrift/src/test/java/org/apache/avro/thrift/test/Error.java b/lang/java/thrift/src/test/java/org/apache/avro/thrift/test/Error.java index a832605..a76f89b 100644 --- a/lang/java/thrift/src/test/java/org/apache/avro/thrift/test/Error.java +++ b/lang/java/thrift/src/test/java/org/apache/avro/thrift/test/Error.java @@ -12,25 +12,14 @@ import org.apache.thrift.scheme.StandardScheme; import org.apache.thrift.scheme.TupleScheme; import org.apache.thrift.protocol.TTupleProtocol; -import org.apache.thrift.protocol.TProtocolException; -import org.apache.thrift.EncodingUtils; import org.apache.thrift.TException; -import org.apache.thrift.async.AsyncMethodCallback; -import org.apache.thrift.server.AbstractNonblockingServer.*; -import java.util.List; -import java.util.ArrayList; + import java.util.Map; import java.util.HashMap; import java.util.EnumMap; -import java.util.Set; -import java.util.HashSet; import java.util.EnumSet; import java.util.Collections; import java.util.BitSet; -import java.nio.ByteBuffer; -import java.util.Arrays; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; public class Error extends TException implements org.apache.thrift.TBase<Error, Error._Fields>, java.io.Serializable, Cloneable, Comparable<Error> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("Error"); http://git-wip-us.apache.org/repos/asf/avro/blob/61ab7383/lang/java/thrift/src/test/java/org/apache/avro/thrift/test/Foo.java ---------------------------------------------------------------------- diff --git a/lang/java/thrift/src/test/java/org/apache/avro/thrift/test/Foo.java b/lang/java/thrift/src/test/java/org/apache/avro/thrift/test/Foo.java index 281d7f4..d10658f 100644 --- a/lang/java/thrift/src/test/java/org/apache/avro/thrift/test/Foo.java +++ b/lang/java/thrift/src/test/java/org/apache/avro/thrift/test/Foo.java @@ -12,23 +12,18 @@ import org.apache.thrift.scheme.StandardScheme; import org.apache.thrift.scheme.TupleScheme; import org.apache.thrift.protocol.TTupleProtocol; -import org.apache.thrift.protocol.TProtocolException; import org.apache.thrift.EncodingUtils; import org.apache.thrift.TException; import org.apache.thrift.async.AsyncMethodCallback; import org.apache.thrift.server.AbstractNonblockingServer.*; -import java.util.List; -import java.util.ArrayList; + import java.util.Map; import java.util.HashMap; import java.util.EnumMap; -import java.util.Set; -import java.util.HashSet; import java.util.EnumSet; import java.util.Collections; import java.util.BitSet; -import java.nio.ByteBuffer; -import java.util.Arrays; + import org.slf4j.Logger; import org.slf4j.LoggerFactory; http://git-wip-us.apache.org/repos/asf/avro/blob/61ab7383/lang/java/thrift/src/test/java/org/apache/avro/thrift/test/FooOrBar.java ---------------------------------------------------------------------- diff --git a/lang/java/thrift/src/test/java/org/apache/avro/thrift/test/FooOrBar.java b/lang/java/thrift/src/test/java/org/apache/avro/thrift/test/FooOrBar.java index f326eb5..5330bfa 100644 --- a/lang/java/thrift/src/test/java/org/apache/avro/thrift/test/FooOrBar.java +++ b/lang/java/thrift/src/test/java/org/apache/avro/thrift/test/FooOrBar.java @@ -6,31 +6,13 @@ */ package org.apache.avro.thrift.test; -import org.apache.thrift.scheme.IScheme; -import org.apache.thrift.scheme.SchemeFactory; -import org.apache.thrift.scheme.StandardScheme; - -import org.apache.thrift.scheme.TupleScheme; -import org.apache.thrift.protocol.TTupleProtocol; import org.apache.thrift.protocol.TProtocolException; -import org.apache.thrift.EncodingUtils; -import org.apache.thrift.TException; -import org.apache.thrift.async.AsyncMethodCallback; -import org.apache.thrift.server.AbstractNonblockingServer.*; -import java.util.List; -import java.util.ArrayList; + import java.util.Map; import java.util.HashMap; import java.util.EnumMap; -import java.util.Set; -import java.util.HashSet; import java.util.EnumSet; import java.util.Collections; -import java.util.BitSet; -import java.nio.ByteBuffer; -import java.util.Arrays; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; public class FooOrBar extends org.apache.thrift.TUnion<FooOrBar, FooOrBar._Fields> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("FooOrBar"); http://git-wip-us.apache.org/repos/asf/avro/blob/61ab7383/lang/java/thrift/src/test/java/org/apache/avro/thrift/test/Nested.java ---------------------------------------------------------------------- diff --git a/lang/java/thrift/src/test/java/org/apache/avro/thrift/test/Nested.java b/lang/java/thrift/src/test/java/org/apache/avro/thrift/test/Nested.java index f2a2426..86c273d 100644 --- a/lang/java/thrift/src/test/java/org/apache/avro/thrift/test/Nested.java +++ b/lang/java/thrift/src/test/java/org/apache/avro/thrift/test/Nested.java @@ -12,25 +12,14 @@ import org.apache.thrift.scheme.StandardScheme; import org.apache.thrift.scheme.TupleScheme; import org.apache.thrift.protocol.TTupleProtocol; -import org.apache.thrift.protocol.TProtocolException; import org.apache.thrift.EncodingUtils; -import org.apache.thrift.TException; -import org.apache.thrift.async.AsyncMethodCallback; -import org.apache.thrift.server.AbstractNonblockingServer.*; -import java.util.List; -import java.util.ArrayList; + import java.util.Map; import java.util.HashMap; import java.util.EnumMap; -import java.util.Set; -import java.util.HashSet; import java.util.EnumSet; import java.util.Collections; import java.util.BitSet; -import java.nio.ByteBuffer; -import java.util.Arrays; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; public class Nested implements org.apache.thrift.TBase<Nested, Nested._Fields>, java.io.Serializable, Cloneable, Comparable<Nested> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("Nested"); http://git-wip-us.apache.org/repos/asf/avro/blob/61ab7383/lang/java/thrift/src/test/java/org/apache/avro/thrift/test/Test.java ---------------------------------------------------------------------- diff --git a/lang/java/thrift/src/test/java/org/apache/avro/thrift/test/Test.java b/lang/java/thrift/src/test/java/org/apache/avro/thrift/test/Test.java index 3ad2330..8b07ae9 100644 --- a/lang/java/thrift/src/test/java/org/apache/avro/thrift/test/Test.java +++ b/lang/java/thrift/src/test/java/org/apache/avro/thrift/test/Test.java @@ -12,11 +12,8 @@ import org.apache.thrift.scheme.StandardScheme; import org.apache.thrift.scheme.TupleScheme; import org.apache.thrift.protocol.TTupleProtocol; -import org.apache.thrift.protocol.TProtocolException; import org.apache.thrift.EncodingUtils; -import org.apache.thrift.TException; -import org.apache.thrift.async.AsyncMethodCallback; -import org.apache.thrift.server.AbstractNonblockingServer.*; + import java.util.List; import java.util.ArrayList; import java.util.Map; @@ -28,9 +25,6 @@ import java.util.EnumSet; import java.util.Collections; import java.util.BitSet; import java.nio.ByteBuffer; -import java.util.Arrays; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; public class Test implements org.apache.thrift.TBase<Test, Test._Fields>, java.io.Serializable, Cloneable, Comparable<Test> { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("Test"); http://git-wip-us.apache.org/repos/asf/avro/blob/61ab7383/lang/java/tools/src/test/java/org/apache/avro/tool/TestConcatTool.java ---------------------------------------------------------------------- diff --git a/lang/java/tools/src/test/java/org/apache/avro/tool/TestConcatTool.java b/lang/java/tools/src/test/java/org/apache/avro/tool/TestConcatTool.java index f318727..c4e26ce 100644 --- a/lang/java/tools/src/test/java/org/apache/avro/tool/TestConcatTool.java +++ b/lang/java/tools/src/test/java/org/apache/avro/tool/TestConcatTool.java @@ -27,7 +27,6 @@ import java.io.File; import java.io.FileInputStream; import java.io.FileNotFoundException; import java.io.PrintStream; -import java.util.ArrayList; import java.util.Collections; import java.util.HashMap; import java.util.Iterator; http://git-wip-us.apache.org/repos/asf/avro/blob/61ab7383/lang/java/tools/src/test/java/org/apache/avro/tool/TestDataFileRepairTool.java ---------------------------------------------------------------------- diff --git a/lang/java/tools/src/test/java/org/apache/avro/tool/TestDataFileRepairTool.java b/lang/java/tools/src/test/java/org/apache/avro/tool/TestDataFileRepairTool.java index ad42cd3..2a4ed49 100644 --- a/lang/java/tools/src/test/java/org/apache/avro/tool/TestDataFileRepairTool.java +++ b/lang/java/tools/src/test/java/org/apache/avro/tool/TestDataFileRepairTool.java @@ -41,7 +41,6 @@ import org.junit.Test; import static org.junit.Assert.assertEquals; import static org.junit.Assert.assertFalse; import static org.junit.Assert.assertTrue; -import static org.junit.Assert.fail; public class TestDataFileRepairTool { http://git-wip-us.apache.org/repos/asf/avro/blob/61ab7383/lang/java/tools/src/test/java/org/apache/avro/tool/TestJsonToFromBinaryFragmentTools.java ---------------------------------------------------------------------- diff --git a/lang/java/tools/src/test/java/org/apache/avro/tool/TestJsonToFromBinaryFragmentTools.java b/lang/java/tools/src/test/java/org/apache/avro/tool/TestJsonToFromBinaryFragmentTools.java index 55f47af..8499687 100644 --- a/lang/java/tools/src/test/java/org/apache/avro/tool/TestJsonToFromBinaryFragmentTools.java +++ b/lang/java/tools/src/test/java/org/apache/avro/tool/TestJsonToFromBinaryFragmentTools.java @@ -33,7 +33,6 @@ import java.util.List; import org.apache.avro.AvroTestUtil; import org.apache.avro.Schema; import org.apache.avro.Schema.Type; -import org.junit.BeforeClass; import org.junit.Test; /** http://git-wip-us.apache.org/repos/asf/avro/blob/61ab7383/lang/java/tools/src/test/java/org/apache/avro/tool/TestTetherTool.java ---------------------------------------------------------------------- diff --git a/lang/java/tools/src/test/java/org/apache/avro/tool/TestTetherTool.java b/lang/java/tools/src/test/java/org/apache/avro/tool/TestTetherTool.java index 8bed7af..118ccf7 100644 --- a/lang/java/tools/src/test/java/org/apache/avro/tool/TestTetherTool.java +++ b/lang/java/tools/src/test/java/org/apache/avro/tool/TestTetherTool.java @@ -32,15 +32,11 @@ import org.apache.avro.AvroTestUtil; import org.apache.avro.Schema; import org.apache.avro.file.DataFileStream; import org.apache.avro.io.DatumReader; -import org.apache.avro.mapred.AvroJob; import org.apache.avro.mapred.Pair; import org.apache.avro.mapred.WordCountUtil; -import org.apache.avro.mapred.tether.TetherJob; import org.apache.avro.specific.SpecificDatumReader; import org.apache.avro.util.Utf8; import org.apache.hadoop.fs.Path; -import org.apache.hadoop.mapred.FileInputFormat; -import org.apache.hadoop.mapred.FileOutputFormat; import org.apache.hadoop.mapred.JobConf; import org.junit.Test; http://git-wip-us.apache.org/repos/asf/avro/blob/61ab7383/lang/java/tools/src/test/java/org/apache/avro/tool/TestTextFileTools.java ---------------------------------------------------------------------- diff --git a/lang/java/tools/src/test/java/org/apache/avro/tool/TestTextFileTools.java b/lang/java/tools/src/test/java/org/apache/avro/tool/TestTextFileTools.java index dec6ec8..9d1615c 100644 --- a/lang/java/tools/src/test/java/org/apache/avro/tool/TestTextFileTools.java +++ b/lang/java/tools/src/test/java/org/apache/avro/tool/TestTextFileTools.java @@ -18,9 +18,7 @@ package org.apache.avro.tool; import static org.junit.Assert.assertEquals; -import static org.junit.Assert.fail; -import java.io.ByteArrayOutputStream; import java.io.File; import java.io.OutputStream; import java.io.InputStream; @@ -29,19 +27,15 @@ import java.io.FileInputStream; import java.io.BufferedOutputStream; import java.io.BufferedInputStream; import java.io.IOException; -import java.io.PrintStream; import java.nio.ByteBuffer; import java.util.ArrayList; import java.util.Arrays; -import java.util.Collections; -import java.util.List; import java.util.Random; import org.apache.avro.AvroTestUtil; import org.apache.avro.Schema; import org.apache.avro.Schema.Type; import org.apache.avro.file.DataFileReader; -import org.apache.avro.file.DataFileWriter; import org.apache.avro.generic.GenericDatumReader; import org.junit.BeforeClass; import org.junit.AfterClass; http://git-wip-us.apache.org/repos/asf/avro/blob/61ab7383/lang/java/tools/src/test/java/org/apache/avro/tool/TestToTrevniTool.java ---------------------------------------------------------------------- diff --git a/lang/java/tools/src/test/java/org/apache/avro/tool/TestToTrevniTool.java b/lang/java/tools/src/test/java/org/apache/avro/tool/TestToTrevniTool.java index a0067a9..663c6c8 100644 --- a/lang/java/tools/src/test/java/org/apache/avro/tool/TestToTrevniTool.java +++ b/lang/java/tools/src/test/java/org/apache/avro/tool/TestToTrevniTool.java @@ -20,9 +20,7 @@ package org.apache.avro.tool; import java.io.ByteArrayOutputStream; import java.io.File; import java.io.PrintStream; -import java.util.ArrayList; import java.util.Arrays; -import java.util.List; import java.util.Iterator; import org.apache.avro.Schema; http://git-wip-us.apache.org/repos/asf/avro/blob/61ab7383/lang/java/trevni/avro/src/test/java/org/apache/trevni/avro/RandomData.java ---------------------------------------------------------------------- diff --git a/lang/java/trevni/avro/src/test/java/org/apache/trevni/avro/RandomData.java b/lang/java/trevni/avro/src/test/java/org/apache/trevni/avro/RandomData.java index 5020a11..227549a 100644 --- a/lang/java/trevni/avro/src/test/java/org/apache/trevni/avro/RandomData.java +++ b/lang/java/trevni/avro/src/test/java/org/apache/trevni/avro/RandomData.java @@ -18,7 +18,6 @@ package org.apache.trevni.avro; import java.io.File; -import java.nio.ByteBuffer; import java.util.HashMap; import java.util.Iterator; import java.util.List; http://git-wip-us.apache.org/repos/asf/avro/blob/61ab7383/lang/java/trevni/avro/src/test/java/org/apache/trevni/avro/TestCases.java ---------------------------------------------------------------------- diff --git a/lang/java/trevni/avro/src/test/java/org/apache/trevni/avro/TestCases.java b/lang/java/trevni/avro/src/test/java/org/apache/trevni/avro/TestCases.java index 2bafe2e..2430e51 100644 --- a/lang/java/trevni/avro/src/test/java/org/apache/trevni/avro/TestCases.java +++ b/lang/java/trevni/avro/src/test/java/org/apache/trevni/avro/TestCases.java @@ -18,15 +18,12 @@ package org.apache.trevni.avro; import java.io.File; -import java.io.IOException; import java.io.EOFException; import java.io.InputStream; import java.io.FileInputStream; import java.util.List; import java.util.ArrayList; -import org.apache.trevni.ValueType; -import org.apache.trevni.ColumnMetaData; import org.apache.trevni.ColumnFileMetaData; import org.apache.avro.Schema; http://git-wip-us.apache.org/repos/asf/avro/blob/61ab7383/lang/java/trevni/avro/src/test/java/org/apache/trevni/avro/TestEvolvedSchema.java ---------------------------------------------------------------------- diff --git a/lang/java/trevni/avro/src/test/java/org/apache/trevni/avro/TestEvolvedSchema.java b/lang/java/trevni/avro/src/test/java/org/apache/trevni/avro/TestEvolvedSchema.java index 0a70eeb..9d0c851 100644 --- a/lang/java/trevni/avro/src/test/java/org/apache/trevni/avro/TestEvolvedSchema.java +++ b/lang/java/trevni/avro/src/test/java/org/apache/trevni/avro/TestEvolvedSchema.java @@ -18,9 +18,7 @@ package org.apache.trevni.avro; import java.io.File; -import java.io.FileOutputStream; import java.io.IOException; -import java.io.OutputStream; import junit.framework.TestCase; http://git-wip-us.apache.org/repos/asf/avro/blob/61ab7383/lang/java/trevni/avro/src/test/java/org/apache/trevni/avro/TestWordCount.java ---------------------------------------------------------------------- diff --git a/lang/java/trevni/avro/src/test/java/org/apache/trevni/avro/TestWordCount.java b/lang/java/trevni/avro/src/test/java/org/apache/trevni/avro/TestWordCount.java index 7241ded..871751f 100644 --- a/lang/java/trevni/avro/src/test/java/org/apache/trevni/avro/TestWordCount.java +++ b/lang/java/trevni/avro/src/test/java/org/apache/trevni/avro/TestWordCount.java @@ -20,15 +20,8 @@ package org.apache.trevni.avro; import java.io.IOException; import java.util.StringTokenizer; -import java.io.File; -import junit.framework.Assert; - -import org.apache.hadoop.fs.FileStatus; -import org.apache.hadoop.fs.FileSystem; import org.apache.hadoop.fs.Path; -import org.apache.hadoop.io.NullWritable; -import org.apache.hadoop.mapred.FileSplit; import org.apache.hadoop.mapred.JobClient; import org.apache.hadoop.mapred.JobConf; import org.apache.hadoop.mapred.FileInputFormat; @@ -36,7 +29,6 @@ import org.apache.hadoop.mapred.FileOutputFormat; import org.apache.hadoop.mapred.lib.NullOutputFormat; import org.apache.hadoop.mapred.Reporter; -import org.apache.avro.Schema; import org.apache.avro.generic.GenericData; import org.apache.avro.generic.GenericRecord; import org.apache.avro.mapred.AvroJob; http://git-wip-us.apache.org/repos/asf/avro/blob/61ab7383/lang/java/trevni/avro/src/test/java/org/apache/trevni/avro/WordCountUtil.java ---------------------------------------------------------------------- diff --git a/lang/java/trevni/avro/src/test/java/org/apache/trevni/avro/WordCountUtil.java b/lang/java/trevni/avro/src/test/java/org/apache/trevni/avro/WordCountUtil.java index fdbb7b8..9b5598a 100644 --- a/lang/java/trevni/avro/src/test/java/org/apache/trevni/avro/WordCountUtil.java +++ b/lang/java/trevni/avro/src/test/java/org/apache/trevni/avro/WordCountUtil.java @@ -20,35 +20,20 @@ package org.apache.trevni.avro; import static org.junit.Assert.*; -import java.io.BufferedReader; -import java.io.FileReader; import java.io.IOException; import java.io.File; -import java.io.InputStream; -import java.io.FileInputStream; -import java.io.BufferedInputStream; -import java.io.PrintStream; -import java.nio.ByteBuffer; -import java.util.ArrayList; -import java.util.Arrays; -import java.util.Collections; -import java.util.List; import java.util.StringTokenizer; import java.util.Map; import java.util.TreeMap; import org.apache.hadoop.fs.FileUtil; -import org.apache.hadoop.mapred.JobConf; import org.apache.avro.Schema; -import org.apache.avro.hadoop.io.AvroKeyValue; -import org.apache.avro.io.DatumReader; import org.apache.avro.io.DatumWriter; import org.apache.avro.generic.GenericDatumWriter; import org.apache.avro.generic.GenericRecord; import org.apache.avro.specific.SpecificData; import org.apache.avro.file.DataFileWriter; -import org.apache.avro.file.DataFileStream; import org.apache.avro.mapred.Pair; public class WordCountUtil { http://git-wip-us.apache.org/repos/asf/avro/blob/61ab7383/lang/java/trevni/core/src/test/java/org/apache/trevni/TestColumnFile.java ---------------------------------------------------------------------- diff --git a/lang/java/trevni/core/src/test/java/org/apache/trevni/TestColumnFile.java b/lang/java/trevni/core/src/test/java/org/apache/trevni/TestColumnFile.java index 4063a60..2ba6f09 100644 --- a/lang/java/trevni/core/src/test/java/org/apache/trevni/TestColumnFile.java +++ b/lang/java/trevni/core/src/test/java/org/apache/trevni/TestColumnFile.java @@ -17,10 +17,7 @@ */ package org.apache.trevni; -import java.io.ByteArrayOutputStream; import java.io.File; -import java.util.ArrayList; -import java.util.List; import java.util.Random; import java.util.Collection; import java.util.Arrays; http://git-wip-us.apache.org/repos/asf/avro/blob/61ab7383/lang/java/trevni/core/src/test/java/org/apache/trevni/TestInputBytes.java ---------------------------------------------------------------------- diff --git a/lang/java/trevni/core/src/test/java/org/apache/trevni/TestInputBytes.java b/lang/java/trevni/core/src/test/java/org/apache/trevni/TestInputBytes.java index 40c5f97..ccdd24c 100644 --- a/lang/java/trevni/core/src/test/java/org/apache/trevni/TestInputBytes.java +++ b/lang/java/trevni/core/src/test/java/org/apache/trevni/TestInputBytes.java @@ -17,9 +17,6 @@ */ package org.apache.trevni; -import java.io.ByteArrayOutputStream; -import java.util.ArrayList; -import java.util.List; import java.util.Random; import java.util.Arrays; http://git-wip-us.apache.org/repos/asf/avro/blob/61ab7383/lang/java/trevni/core/src/test/java/org/apache/trevni/TestUtil.java ---------------------------------------------------------------------- diff --git a/lang/java/trevni/core/src/test/java/org/apache/trevni/TestUtil.java b/lang/java/trevni/core/src/test/java/org/apache/trevni/TestUtil.java index f78502d..9d364d8 100644 --- a/lang/java/trevni/core/src/test/java/org/apache/trevni/TestUtil.java +++ b/lang/java/trevni/core/src/test/java/org/apache/trevni/TestUtil.java @@ -19,7 +19,6 @@ package org.apache.trevni; import java.util.Random; -import java.io.ByteArrayOutputStream; import java.nio.ByteBuffer; import org.junit.Assert;
