beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From k...@apache.org
Subject [43/50] [abbrv] beam git commit: Fix Javadoc warnings on Flink Runner
Date Tue, 25 Apr 2017 17:30:38 GMT
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 <iemejia@apache.org>
Authored: Tue Apr 18 14:36:44 2017 +0200
Committer: Ismaël Mejía <iemejia@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>>> {


Mime
View raw message