You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ar...@apache.org on 2019/01/25 10:17:14 UTC
[beam] branch spark-runner_structured-streaming updated: Fixed
Javadoc error
This is an automated email from the ASF dual-hosted git repository.
aromanenko pushed a commit to branch spark-runner_structured-streaming
in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/spark-runner_structured-streaming by this push:
new f0f0138 Fixed Javadoc error
f0f0138 is described below
commit f0f01389dee96e93b0f9b8a86a78551b9d6bb828
Author: Alexey Romanenko <ar...@gmail.com>
AuthorDate: Fri Jan 25 11:16:37 2019 +0100
Fixed Javadoc error
---
.../runners/spark/structuredstreaming/translation/EncoderHelpers.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/runners/spark-structured-streaming/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/EncoderHelpers.java b/runners/spark-structured-streaming/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/EncoderHelpers.java
index 90797c1..2912e3c 100644
--- a/runners/spark-structured-streaming/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/EncoderHelpers.java
+++ b/runners/spark-structured-streaming/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/EncoderHelpers.java
@@ -31,7 +31,7 @@ public class EncoderHelpers {
// the type inference mechanism to infer Encoder<WindowedValue<T>> to get back the type checking
/**
- * Get a bytes {@link Encoder} for {@link WindowedValue<T>}. Bytes serialisation is issued by Kryo
+ * Get a bytes {@link Encoder} for {@link WindowedValue}. Bytes serialisation is issued by Kryo
*/
@SuppressWarnings("unchecked")
public static <T> Encoder<T> windowedValueEncoder() {