This is an automated email from the ASF dual-hosted git repository. echauchot pushed a commit to branch spark-runner_structured-streaming in repository https://gitbox.apache.org/repos/asf/beam.git
commit 002f0b4913f13d45792ada45145f486059d81b28 Author: Etienne Chauchot <echauc...@apache.org> AuthorDate: Fri Jan 11 10:53:12 2019 +0100 Move SourceTest to same package as tested class --- .../spark/structuredstreaming/{ => translation/batch}/SourceTest.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/runners/spark-structured-streaming/src/test/java/org/apache/beam/runners/spark/structuredstreaming/SourceTest.java b/runners/spark-structured-streaming/src/test/java/org/apache/beam/runners/spark/structuredstreaming/translation/batch/SourceTest.java similarity index 92% rename from runners/spark-structured-streaming/src/test/java/org/apache/beam/runners/spark/structuredstreaming/SourceTest.java rename to runners/spark-structured-streaming/src/test/java/org/apache/beam/runners/spark/structuredstreaming/translation/batch/SourceTest.java index c348ed5..6ef41b8 100644 --- a/runners/spark-structured-streaming/src/test/java/org/apache/beam/runners/spark/structuredstreaming/SourceTest.java +++ b/runners/spark-structured-streaming/src/test/java/org/apache/beam/runners/spark/structuredstreaming/translation/batch/SourceTest.java @@ -1,4 +1,4 @@ -package org.apache.beam.runners.spark.structuredstreaming; +package org.apache.beam.runners.spark.structuredstreaming.translation.batch; import java.io.IOException; import java.io.Serializable; @@ -8,6 +8,8 @@ import java.util.List; import java.util.Map; import org.apache.beam.runners.core.construction.PipelineOptionsSerializationUtils; import org.apache.beam.runners.core.serialization.Base64Serializer; +import org.apache.beam.runners.spark.structuredstreaming.SparkPipelineOptions; +import org.apache.beam.runners.spark.structuredstreaming.SparkRunner; import org.apache.beam.runners.spark.structuredstreaming.translation.batch.DatasetSourceBatch; import org.apache.beam.runners.spark.structuredstreaming.utils.SerializationDebugger; import org.apache.beam.sdk.Pipeline;