Skip to content

Commit

Permalink
[FLINK-29740][Scala] Mark Scala APIs as @Deprecated. This closes ap…
Browse files Browse the repository at this point in the history
…ache#21176

* [FLINK-29740][Scala] Remove Scala examples, quickstarts and walkthroughs

* [FLINK-29740][Scala] Mark Scala package and Scala ExecutionEnvironment as @deprecated

* [FLINK-29740][Scala] Remove Scala E2E tests/walkthroughs

- Remove Scala tests that relied on Scala examples
- Remove Scala test from `SocketWindowWordCount`
- Remove Scala example testing from CI

* [FLINK-29740][Scala] Add deprecation hint to the documentation on the DataStream Overview Page, Table Concepts & Common API page and the DataStream Scala Extensions Page

* [FLINK-29740][Scala] Remove Scala quickstart/walkthrough from documentation

* [FLINK-29740][Scala] Add Scala deprecation warning to project configuration overview
  • Loading branch information
MartijnVisser authored Nov 8, 2022
1 parent 488db25 commit 5ac290a
Show file tree
Hide file tree
Showing 74 changed files with 89 additions and 5,729 deletions.
6 changes: 6 additions & 0 deletions docs/content.zh/docs/dev/configuration/overview.md
Original file line number Diff line number Diff line change
Expand Up @@ -57,6 +57,12 @@ under the License.

<a name="maven-command"></a>

{{< hint warning >}}
All Flink Scala APIs are deprecated and will be removed in a future Flink version version. You can still build your application in Scala, but you should move to the Java version of either the DataStream and/or Table API.

See <a href="https://cwiki.apache.org/confluence/display/FLINK/FLIP-265+Deprecate+and+remove+Scala+API+support">FLIP-265 Deprecate and remove Scala API support</a>
{{< /hint >}}

### Maven 命令
```bash
$ mvn archetype:generate \
Expand Down
6 changes: 6 additions & 0 deletions docs/content.zh/docs/dev/datastream/overview.md
Original file line number Diff line number Diff line change
Expand Up @@ -61,6 +61,12 @@ Flink 程序看起来像一个转换 `DataStream` 的常规程序。每个程序
4. 指定计算结果的存储位置;
5. 触发程序执行。

{{< hint warning >}}
All Flink Scala APIs are deprecated and will be removed in a future Flink version version. You can still build your application in Scala, but you should move to the Java version of either the DataStream and/or Table API.

See <a href="https://cwiki.apache.org/confluence/display/FLINK/FLIP-265+Deprecate+and+remove+Scala+API+support">FLIP-265 Deprecate and remove Scala API support</a>
{{< /hint >}}

{{< tabs "fa68701c-59e8-4509-858e-3e8a123eeacf" >}}
{{< tab "Java" >}}

Expand Down
6 changes: 6 additions & 0 deletions docs/content.zh/docs/dev/datastream/scala_api_extensions.md
Original file line number Diff line number Diff line change
Expand Up @@ -25,6 +25,12 @@ specific language governing permissions and limitations
under the License.
-->

{{< hint warning >}}
All Flink Scala APIs are deprecated and will be removed in a future Flink version version. You can still build your application in Scala, but you should move to the Java version of either the DataStream and/or Table API.

See <a href="https://cwiki.apache.org/confluence/display/FLINK/FLIP-265+Deprecate+and+remove+Scala+API+support">FLIP-265 Deprecate and remove Scala API support</a>
{{< /hint >}}

# Scala API 扩展

为了在 Scala 和 Java API 之间保持大致相同的使用体验,在批处理和流处理的标准 API 中省略了一些允许 Scala 高级表达的特性。
Expand Down
6 changes: 6 additions & 0 deletions docs/content.zh/docs/dev/table/common.md
Original file line number Diff line number Diff line change
Expand Up @@ -37,6 +37,12 @@ Table API 和 SQL 程序的结构

所有用于批处理和流处理的 Table API 和 SQL 程序都遵循相同的模式。下面的代码示例展示了 Table API 和 SQL 程序的通用结构。

{{< hint warning >}}
All Flink Scala APIs are deprecated and will be removed in a future Flink version version. You can still build your application in Scala, but you should move to the Java version of either the DataStream and/or Table API.

See <a href="https://cwiki.apache.org/confluence/display/FLINK/FLIP-265+Deprecate+and+remove+Scala+API+support">FLIP-265 Deprecate and remove Scala API support</a>
{{< /hint >}}

{{< tabs "62be8916-7ab4-4831-bd19-05c591181835" >}}
{{< tab "Java" >}}
```java
Expand Down
8 changes: 7 additions & 1 deletion docs/content.zh/docs/learn-flink/datastream_api.md
Original file line number Diff line number Diff line change
Expand Up @@ -28,7 +28,7 @@ under the License.

## 什么能被转化成流?

Flink 的 Java 和 Scala DataStream API 可以将任何可序列化的对象转化为流。Flink 自带的序列化器有
Flink 的 Java DataStream API 可以将任何可序列化的对象转化为流。Flink 自带的序列化器有

- 基本类型,即 String、Long、Integer、Boolean、Array
- 复合类型:Tuples、POJOs 和 Scala case classes
Expand Down Expand Up @@ -80,6 +80,12 @@ Flink 的序列化器[支持的 POJO 类型数据结构升级]({{< ref "docs/dev

如果你了解 Scala,那一定知道 tuple 和 case class。

{{< hint warning >}}
All Flink Scala APIs are deprecated and will be removed in a future Flink version version. You can still build your application in Scala, but you should move to the Java version of either the DataStream and/or Table API.

See <a href="https://cwiki.apache.org/confluence/display/FLINK/FLIP-265+Deprecate+and+remove+Scala+API+support">FLIP-265 Deprecate and remove Scala API support</a>
{{< /hint >}}

{{< top >}}

## 一个完整的示例
Expand Down
Loading

0 comments on commit 5ac290a

Please sign in to comment.