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/master Commit: 5fce8d2a27e4507012e8e61a1487f51d3293d9d9 Parents: f654ff4 Author: Ismaël MejÃa <ieme...@apache.org> Authored: Tue Apr 18 14:36:44 2017 +0200 Committer: Ismaël MejÃa <ieme...@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>>> {
