You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tr...@apache.org on 2019/08/22 16:22:20 UTC
[flink] branch release-1.9 updated: [FLINK-13761][scala] Deprecate
Scala SplitStream
This is an automated email from the ASF dual-hosted git repository.
trohrmann pushed a commit to branch release-1.9
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.9 by this push:
new 36366ac [FLINK-13761][scala] Deprecate Scala SplitStream
36366ac is described below
commit 36366ac477342c289fc54c6b613ad40189be9168
Author: 张志豪 <iz...@hotmail.com>
AuthorDate: Sun Aug 18 21:16:20 2019 +0800
[FLINK-13761][scala] Deprecate Scala SplitStream
Deprecate Scala SplitStream which has been superseded by side outputs.
This closes #9474.
---
.../main/scala/org/apache/flink/streaming/api/scala/SplitStream.scala | 1 +
1 file changed, 1 insertion(+)
diff --git a/flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/SplitStream.scala b/flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/SplitStream.scala
index ca4bcc0..16a5a48 100644
--- a/flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/SplitStream.scala
+++ b/flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/SplitStream.scala
@@ -28,6 +28,7 @@ import org.apache.flink.streaming.api.datastream.{ SplitStream => SplitJavaStrea
* To apply a transformation on the whole output simply call
* the appropriate method on this stream.
*/
+@deprecated("Please use side outputs instead of split/select", "deprecated since 1.8.2")
@Public
class SplitStream[T](javaStream: SplitJavaStream[T]) extends DataStream[T](javaStream){