From cc088fd69319788a28d2767aac60c72bce248bce Mon Sep 17 00:00:00 2001 From: Reuven Lax Date: Tue, 13 Dec 2016 17:15:31 -0800 Subject: [PATCH] Remove some extra imports. --- .../beam/sdk/io/gcp/bigquery/BigQueryIOTest.java | 15 +-------------- 1 file changed, 1 insertion(+), 14 deletions(-) diff --git a/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIOTest.java b/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIOTest.java index c37506119e08a..3ccc1a9e9bfd3 100644 --- a/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIOTest.java +++ b/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIOTest.java @@ -25,7 +25,6 @@ import static org.apache.beam.sdk.transforms.display.DisplayDataMatchers.hasDisplayItem; import static org.hamcrest.Matchers.containsInAnyOrder; import static org.hamcrest.Matchers.hasItem; -import static org.hamcrest.Matchers.hasItems; import static org.junit.Assert.assertArrayEquals; import static org.junit.Assert.assertEquals; import static org.junit.Assert.assertNull; @@ -88,7 +87,6 @@ import java.util.Set; import javax.annotation.Nullable; -import com.google.common.collect.Lists; import org.apache.avro.file.DataFileWriter; import org.apache.avro.generic.GenericDatumWriter; import org.apache.avro.generic.GenericRecord; @@ -108,13 +106,8 @@ import org.apache.beam.sdk.io.gcp.bigquery.BigQueryIO.BigQueryQuerySource; import org.apache.beam.sdk.io.gcp.bigquery.BigQueryIO.BigQueryTableSource; import org.apache.beam.sdk.io.gcp.bigquery.BigQueryIO.JsonSchemaToTableSchema; -import org.apache.beam.sdk.io.gcp.bigquery.BigQueryIO.PassThroughThenCleanup; -import org.apache.beam.sdk.io.gcp.bigquery.BigQueryIO.PassThroughThenCleanup.CleanupOperation; import org.apache.beam.sdk.io.gcp.bigquery.BigQueryIO.Status; -import org.apache.beam.sdk.io.gcp.bigquery.BigQueryIO.TransformingSource; import org.apache.beam.sdk.io.gcp.bigquery.BigQueryIO.Write.Bound; - -import org.apache.beam.sdk.io.gcp.bigquery.BigQueryIO.Status; import org.apache.beam.sdk.io.gcp.bigquery.BigQueryIO.Write.CreateDisposition; import org.apache.beam.sdk.io.gcp.bigquery.BigQueryIO.Write.WriteDisposition; import org.apache.beam.sdk.io.gcp.bigquery.BigQueryServices.DatasetService; @@ -127,9 +120,6 @@ import org.apache.beam.sdk.options.ValueProvider; import org.apache.beam.sdk.options.ValueProvider.NestedValueProvider; import org.apache.beam.sdk.options.ValueProvider.StaticValueProvider; -import org.apache.beam.sdk.options.PipelineOptions; -import org.apache.beam.sdk.options.PipelineOptionsFactory; -import org.apache.beam.sdk.options.StreamingOptions; import org.apache.beam.sdk.testing.ExpectedLogs; import org.apache.beam.sdk.testing.NeedsRunner; import org.apache.beam.sdk.testing.PAssert; @@ -163,9 +153,6 @@ import org.apache.beam.sdk.values.PDone; import org.apache.beam.sdk.values.TupleTag; import org.hamcrest.CoreMatchers; -import org.hamcrest.Matcher; -import org.apache.beam.sdk.values.TupleTag; -import org.hamcrest.CoreMatchers; import org.hamcrest.Matchers; import org.joda.time.Instant; import org.junit.Assert; @@ -1710,7 +1697,7 @@ public void testCoder_nullCell() throws CoderException { TableRow newRow = CoderUtils.decodeFromByteArray(TableRowJsonCoder.of(), bytes); byte[] newBytes = CoderUtils.encodeToByteArray(TableRowJsonCoder.of(), newRow); - Assert.assertArrayEquals(bytes, newBytes); + assertArrayEquals(bytes, newBytes); } @Test