You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by dh...@apache.org on 2016/04/16 19:19:55 UTC
[1/2] incubator-beam git commit: Remove deprecated
sdk.transforms.Write, switch users to sdk.io.Write
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 <dh...@google.com>
Authored: Fri Apr 15 17:06:53 2016 -0700
Committer: Dan Halperin <dh...@google.com>
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 {
-}
[2/2] incubator-beam git commit: Closes #195
Posted by dh...@apache.org.
Closes #195
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/eeb400e1
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/eeb400e1
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/eeb400e1
Branch: refs/heads/master
Commit: eeb400e11ba8e12204029a3ecf35d51a1be3ce8c
Parents: fd2548f e8955cf
Author: Dan Halperin <dh...@google.com>
Authored: Sat Apr 16 10:19:31 2016 -0700
Committer: Dan Halperin <dh...@google.com>
Committed: Sat Apr 16 10:19:31 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(-)
----------------------------------------------------------------------