Repository: incubator-beam Updated Branches: refs/heads/master 5918fed8a -> f27354f77
Static import Assert.assertEquals Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/099fd9c7 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/099fd9c7 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/099fd9c7 Branch: refs/heads/master Commit: 099fd9c740bac1bed5d3b7227c2f5b895808e99a Parents: 5918fed Author: Scott Wegner <[email protected]> Authored: Wed Oct 5 13:58:40 2016 -0700 Committer: Scott Wegner <[email protected]> Committed: Wed Oct 5 13:58:40 2016 -0700 ---------------------------------------------------------------------- .../internal/DataflowUnboundedReadFromBoundedSourceTest.java | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/099fd9c7/runners/google-cloud-dataflow-java/src/test/java/org/apache/beam/runners/dataflow/internal/DataflowUnboundedReadFromBoundedSourceTest.java ---------------------------------------------------------------------- diff --git a/runners/google-cloud-dataflow-java/src/test/java/org/apache/beam/runners/dataflow/internal/DataflowUnboundedReadFromBoundedSourceTest.java b/runners/google-cloud-dataflow-java/src/test/java/org/apache/beam/runners/dataflow/internal/DataflowUnboundedReadFromBoundedSourceTest.java index d9e3558..3a88935 100644 --- a/runners/google-cloud-dataflow-java/src/test/java/org/apache/beam/runners/dataflow/internal/DataflowUnboundedReadFromBoundedSourceTest.java +++ b/runners/google-cloud-dataflow-java/src/test/java/org/apache/beam/runners/dataflow/internal/DataflowUnboundedReadFromBoundedSourceTest.java @@ -18,12 +18,13 @@ package org.apache.beam.runners.dataflow.internal; +import static org.junit.Assert.assertEquals; + import java.io.IOException; import java.util.List; import org.apache.beam.sdk.coders.Coder; import org.apache.beam.sdk.io.BoundedSource; import org.apache.beam.sdk.options.PipelineOptions; -import org.junit.Assert; import org.junit.Test; import org.junit.runner.RunWith; import org.junit.runners.JUnit4; @@ -38,7 +39,7 @@ public class DataflowUnboundedReadFromBoundedSourceTest { DataflowUnboundedReadFromBoundedSource<?> read = new DataflowUnboundedReadFromBoundedSource<>(new NoopNamedSource()); - Assert.assertEquals("Read(NoopNamedSource)", read.getKindString()); + assertEquals("Read(NoopNamedSource)", read.getKindString()); } @Test @@ -47,7 +48,7 @@ public class DataflowUnboundedReadFromBoundedSourceTest { DataflowUnboundedReadFromBoundedSource<?> read = new DataflowUnboundedReadFromBoundedSource<>(anonSource); - Assert.assertEquals("Read(AnonymousSource)", read.getKindString()); + assertEquals("Read(AnonymousSource)", read.getKindString()); } /** Source implementation only useful for its identity. */
