[FLINK-7547] Make AsyncFunction.scala extends Function

Before, the Scala AsyncFunction was not Serializable. Function is derived from Serializable.
deepfield · Sep 28, 2017 · 09df80f · 09df80f
1 parent 9d7bc7b
commit 09df80f
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/...aming-scala/src/main/scala/org/apache/flink/streaming/api/scala/async/AsyncFunction.scala b/...aming-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