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;
