You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ke...@apache.org on 2017/04/25 17:30:38 UTC
[43/50] [abbrv] beam git commit: Fix Javadoc warnings on Flink Runner
Fix Javadoc warnings on Flink Runner
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/5fce8d2a
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/5fce8d2a
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/5fce8d2a
Branch: refs/heads/jstorm-runner
Commit: 5fce8d2a27e4507012e8e61a1487f51d3293d9d9
Parents: f654ff4
Author: Isma�l Mej�a <ie...@apache.org>
Authored: Tue Apr 18 14:36:44 2017 +0200
Committer: Isma�l Mej�a <ie...@apache.org>
Committed: Tue Apr 18 16:12:47 2017 +0200
----------------------------------------------------------------------
.../translation/wrappers/streaming/SingletonKeyedWorkItem.java | 2 --
.../wrappers/streaming/SingletonKeyedWorkItemCoder.java | 2 --
.../flink/translation/wrappers/streaming/WindowDoFnOperator.java | 3 ---
3 files changed, 7 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/beam/blob/5fce8d2a/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/SingletonKeyedWorkItem.java
----------------------------------------------------------------------
diff --git a/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/SingletonKeyedWorkItem.java b/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/SingletonKeyedWorkItem.java
index b85efef..e843660 100644
--- a/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/SingletonKeyedWorkItem.java
+++ b/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/SingletonKeyedWorkItem.java
@@ -24,8 +24,6 @@ import org.apache.beam.sdk.util.WindowedValue;
/**
* Singleton keyed word item.
- * @param <K>
- * @param <ElemT>
*/
public class SingletonKeyedWorkItem<K, ElemT> implements KeyedWorkItem<K, ElemT> {
http://git-wip-us.apache.org/repos/asf/beam/blob/5fce8d2a/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/SingletonKeyedWorkItemCoder.java
----------------------------------------------------------------------
diff --git a/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/SingletonKeyedWorkItemCoder.java b/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/SingletonKeyedWorkItemCoder.java
index fe96eb1..9a52330 100644
--- a/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/SingletonKeyedWorkItemCoder.java
+++ b/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/SingletonKeyedWorkItemCoder.java
@@ -37,8 +37,6 @@ import org.apache.beam.sdk.util.WindowedValue;
/**
* Singleton keyed work item coder.
- * @param <K>
- * @param <ElemT>
*/
public class SingletonKeyedWorkItemCoder<K, ElemT>
extends StandardCoder<SingletonKeyedWorkItem<K, ElemT>> {
http://git-wip-us.apache.org/repos/asf/beam/blob/5fce8d2a/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/WindowDoFnOperator.java
----------------------------------------------------------------------
diff --git a/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/WindowDoFnOperator.java b/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/WindowDoFnOperator.java
index 8bbc6ef..7b899f4 100644
--- a/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/WindowDoFnOperator.java
+++ b/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/WindowDoFnOperator.java
@@ -44,9 +44,6 @@ import org.apache.flink.streaming.api.operators.InternalTimer;
/**
* Flink operator for executing window {@link DoFn DoFns}.
- *
- * @param <InputT>
- * @param <OutputT>
*/
public class WindowDoFnOperator<K, InputT, OutputT>
extends DoFnOperator<KeyedWorkItem<K, InputT>, KV<K, OutputT>, WindowedValue<KV<K, OutputT>>> {