flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From aljos...@apache.org
Subject flink git commit: [FLINK-7547] Make AsyncFunction.scala extends Function
Date Thu, 28 Sep 2017 15:32:24 GMT
Repository: flink
Updated Branches:
  refs/heads/master 9d7bc7bd6 -> 09df80f00


[FLINK-7547] Make AsyncFunction.scala extends Function

Before, the Scala AsyncFunction was not Serializable. Function is
derived from Serializable.


Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/09df80f0
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/09df80f0
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/09df80f0

Branch: refs/heads/master
Commit: 09df80f0078142b4c7667b237ef48c51ef029a6b
Parents: 9d7bc7b
Author: yew1eb <yew1eb@gmail.com>
Authored: Tue Aug 29 20:25:49 2017 +0800
Committer: Aljoscha Krettek <aljoscha.krettek@gmail.com>
Committed: Thu Sep 28 17:31:33 2017 +0200

----------------------------------------------------------------------
 .../apache/flink/streaming/api/scala/async/AsyncFunction.scala    | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/09df80f0/flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/async/AsyncFunction.scala
----------------------------------------------------------------------
diff --git a/flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/async/AsyncFunction.scala
b/flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/async/AsyncFunction.scala
index aea6b57..d5e9e28 100644
--- a/flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/async/AsyncFunction.scala
+++ b/flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/async/AsyncFunction.scala
@@ -19,6 +19,7 @@
 package org.apache.flink.streaming.api.scala.async
 
 import org.apache.flink.annotation.PublicEvolving
+import org.apache.flink.api.common.functions.Function
 
 /**
   * A function to trigger async I/O operations.
@@ -36,7 +37,7 @@ import org.apache.flink.annotation.PublicEvolving
   * @tparam OUT The type of the output elements
   */
 @PublicEvolving
-trait AsyncFunction[IN, OUT] {
+trait AsyncFunction[IN, OUT] extends Function {
 
   /**
     * Trigger the async operation for each stream input


Mime
View raw message