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 26f2e4bdb257b7be7ef341e7e36ec8d758d27e24 Author: Etienne Chauchot <[email protected]> AuthorDate: Thu Nov 22 11:50:45 2018 +0100 Move SparkTransformOverrides to correct package --- .../spark/structuredstreaming/translation/PipelineTranslator.java | 1 - .../structuredstreaming/translation/SparkTransformOverrides.java | 4 ++-- 2 files changed, 2 insertions(+), 3 deletions(-) diff --git a/runners/spark-structured-streaming/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/PipelineTranslator.java b/runners/spark-structured-streaming/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/PipelineTranslator.java index 51d65ff..c05fc92 100644 --- a/runners/spark-structured-streaming/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/PipelineTranslator.java +++ b/runners/spark-structured-streaming/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/PipelineTranslator.java @@ -2,7 +2,6 @@ package org.apache.beam.runners.spark.structuredstreaming.translation; import org.apache.beam.runners.core.construction.PTransformTranslation; import org.apache.beam.runners.core.construction.PipelineResources; -import org.apache.beam.runners.spark.SparkTransformOverrides; import org.apache.beam.runners.spark.structuredstreaming.SparkPipelineOptions; import org.apache.beam.runners.spark.structuredstreaming.translation.batch.BatchPipelineTranslator; import org.apache.beam.runners.spark.structuredstreaming.translation.streaming.StreamingPipelineTranslator; diff --git a/runners/spark-structured-streaming/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/SparkTransformOverrides.java b/runners/spark-structured-streaming/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/SparkTransformOverrides.java index 897ac01..8e250bd 100644 --- a/runners/spark-structured-streaming/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/SparkTransformOverrides.java +++ b/runners/spark-structured-streaming/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/SparkTransformOverrides.java @@ -15,7 +15,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package org.apache.beam.runners.spark; +package org.apache.beam.runners.spark.structuredstreaming.translation; import com.google.common.collect.ImmutableList; import java.util.List; @@ -27,7 +27,7 @@ import org.apache.beam.runners.core.construction.UnsupportedOverrideFactory; import org.apache.beam.sdk.runners.PTransformOverride; import org.apache.beam.sdk.transforms.PTransform; -/** {@link PTransform} overrides for Flink runner. */ +/** {@link PTransform} overrides for Spark runner. */ public class SparkTransformOverrides { public static List<PTransformOverride> getDefaultOverrides(boolean streaming) { ImmutableList.Builder<PTransformOverride> builder = ImmutableList.builder();
