Repository: incubator-beam Updated Branches: refs/heads/master fd2548ff2 -> eeb400e11
Remove deprecated sdk.transforms.Write, switch users to sdk.io.Write Post-rename cleanup. Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/e8955cf4 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/e8955cf4 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/e8955cf4 Branch: refs/heads/master Commit: e8955cf4b56623ca71aea78ca65bec33ec8d7fb7 Parents: fd2548f Author: Dan Halperin <[email protected]> Authored: Fri Apr 15 17:06:53 2016 -0700 Committer: Dan Halperin <[email protected]> Committed: Sat Apr 16 10:19:30 2016 -0700 ---------------------------------------------------------------------- .../FlinkBatchTransformTranslators.java | 2 +- .../translation/wrappers/SinkOutputFormat.java | 2 +- .../beam/runners/flink/WriteSinkITCase.java | 2 +- .../org/apache/beam/sdk/transforms/Write.java | 29 -------------------- 4 files changed, 3 insertions(+), 32 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/e8955cf4/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/translation/FlinkBatchTransformTranslators.java ---------------------------------------------------------------------- diff --git a/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/translation/FlinkBatchTransformTranslators.java b/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/translation/FlinkBatchTransformTranslators.java index a7544da..a03352e 100644 --- a/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/translation/FlinkBatchTransformTranslators.java +++ b/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/translation/FlinkBatchTransformTranslators.java @@ -38,6 +38,7 @@ import org.apache.beam.sdk.io.AvroIO; import org.apache.beam.sdk.io.BoundedSource; import org.apache.beam.sdk.io.Read; import org.apache.beam.sdk.io.TextIO; +import org.apache.beam.sdk.io.Write; import org.apache.beam.sdk.transforms.Combine; import org.apache.beam.sdk.transforms.Create; import org.apache.beam.sdk.transforms.DoFn; @@ -46,7 +47,6 @@ import org.apache.beam.sdk.transforms.GroupByKey; import org.apache.beam.sdk.transforms.PTransform; import org.apache.beam.sdk.transforms.ParDo; import org.apache.beam.sdk.transforms.View; -import org.apache.beam.sdk.transforms.Write; import org.apache.beam.sdk.transforms.join.CoGbkResult; import org.apache.beam.sdk.transforms.join.CoGbkResultSchema; import org.apache.beam.sdk.transforms.join.CoGroupByKey; http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/e8955cf4/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/translation/wrappers/SinkOutputFormat.java ---------------------------------------------------------------------- diff --git a/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/translation/wrappers/SinkOutputFormat.java b/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/translation/wrappers/SinkOutputFormat.java index 45267b8..c6a4160 100644 --- a/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/translation/wrappers/SinkOutputFormat.java +++ b/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/translation/wrappers/SinkOutputFormat.java @@ -19,8 +19,8 @@ package org.apache.beam.runners.flink.translation.wrappers; import org.apache.beam.sdk.io.Sink; +import org.apache.beam.sdk.io.Write; import org.apache.beam.sdk.options.PipelineOptions; -import org.apache.beam.sdk.transforms.Write; import com.google.common.base.Preconditions; http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/e8955cf4/runners/flink/runner/src/test/java/org/apache/beam/runners/flink/WriteSinkITCase.java ---------------------------------------------------------------------- diff --git a/runners/flink/runner/src/test/java/org/apache/beam/runners/flink/WriteSinkITCase.java b/runners/flink/runner/src/test/java/org/apache/beam/runners/flink/WriteSinkITCase.java index 71514d3..36d3aef 100644 --- a/runners/flink/runner/src/test/java/org/apache/beam/runners/flink/WriteSinkITCase.java +++ b/runners/flink/runner/src/test/java/org/apache/beam/runners/flink/WriteSinkITCase.java @@ -24,9 +24,9 @@ import org.apache.beam.sdk.Pipeline; import org.apache.beam.sdk.coders.Coder; import org.apache.beam.sdk.coders.StringUtf8Coder; import org.apache.beam.sdk.io.Sink; +import org.apache.beam.sdk.io.Write; import org.apache.beam.sdk.options.PipelineOptions; import org.apache.beam.sdk.transforms.Create; -import org.apache.beam.sdk.transforms.Write; import com.google.common.base.Joiner; http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/e8955cf4/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Write.java ---------------------------------------------------------------------- diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Write.java b/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Write.java deleted file mode 100644 index 417da44..0000000 --- a/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Write.java +++ /dev/null @@ -1,29 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.beam.sdk.transforms; - -/** - * A backwards-compatible {@code Write} class that simply inherits from the - * {@link org.apache.beam.sdk.io.Write} class that should be used instead. - * - * @deprecated: use {@link org.apache.beam.sdk.io.Write} from the - * {@code org.apache.beam.sdk.io} package instead. - */ -@Deprecated -public class Write extends org.apache.beam.sdk.io.Write { -}
