This is an automated email from the ASF dual-hosted git repository.
sjwiesman pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 44378fa [FLINK-24839][fs-connector] Increase Timeout of
FsStreamingSinkITCaseBase to 240
new 443b712 [FLINK-24831][examples] Update DataStream Window examples
new dbcce67 [FLINK-24635][examples] Fix deprecations in Twitter example
new cfada41 [FLINK-24635][examples] Fix deprecations in state machine
example
new cce82d5 [FLINK-24635][examples] Fix deprecations in socket example
new cf8053e [FLINK-24635][examples] Fix deprecations in window join
example
new 1eee012 [FLINK-24635][examples] Fix deprecations in side output
example
new 0e3273d [FLINK-24635][examples] Fix deprecations in iterations example
new 25e0140 [FLINK-24635][examples] Fix deprecations in async example
new 84e1a52 [hotfix][examples] Replace StreamingFileSink with FileSink
new b00bfaa [FLINK-24635][examples] Fix deprecations in changelog socket
example
new ef5fb7a [FLINK-24833][examples] Prevent use of deprecated APIs in
flink-examples
The 11 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
flink-examples/flink-examples-batch/pom.xml | 23 ++
flink-examples/flink-examples-streaming/pom.xml | 27 +-
.../streaming/examples/async/AsyncClient.java | 43 ++++
.../streaming/examples/async/AsyncIOExample.java | 277 +++------------------
.../examples/async/util/SimpleSource.java | 77 ++++++
.../streaming/examples/gpu/MatrixVectorMul.java | 6 +-
.../examples/iteration/IterateExample.java | 16 +-
.../flink/streaming/examples/join/WindowJoin.java | 1 -
.../examples/sideoutput/SideOutputExample.java | 57 +++--
.../examples/socket/SocketWindowWordCount.java | 30 +--
.../examples/statemachine/StateMachineExample.java | 20 +-
.../streaming/examples/twitter/TwitterExample.java | 18 +-
.../GroupedProcessingTimeWindowExample.java | 13 +-
.../examples/windowing/SessionWindowing.java | 20 +-
.../examples/windowing/TopSpeedWindowing.java | 151 ++++++-----
.../examples/windowing/WindowWordCount.java | 111 +++++++--
.../examples/windowing/util/CarSource.java | 77 ++++++
.../scala/examples/async/AsyncClient.scala | 31 +--
.../scala/examples/async/AsyncIOExample.scala | 82 +++---
.../scala/examples/iteration/IterateExample.scala | 19 +-
.../streaming/scala/examples/join/WindowJoin.scala | 4 +-
.../examples/socket/SocketWindowWordCount.scala | 2 +-
.../scala/examples/twitter/TwitterExample.scala | 19 +-
.../GroupedProcessingTimeWindowExample.scala | 7 +-
.../examples/windowing/SessionWindowing.scala | 20 +-
.../examples/windowing/TopSpeedWindowing.scala | 133 +++++-----
.../scala/examples/windowing/WindowWordCount.scala | 126 +++++++---
.../scala/examples/windowing/util/CarSource.scala | 62 +++++
.../streaming/test/StreamingExamplesITCase.java | 8 +-
.../windowing/TopSpeedWindowingExampleITCase.java | 9 +-
.../windowing/TopSpeedWindowingExampleITCase.java | 3 +-
.../scala/examples/StreamingExamplesITCase.scala | 13 +-
flink-examples/flink-examples-table/pom.xml | 23 ++
.../java/connectors/ChangelogSocketExample.java | 3 +-
34 files changed, 943 insertions(+), 588 deletions(-)
create mode 100644
flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/async/AsyncClient.java
create mode 100644
flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/async/util/SimpleSource.java
create mode 100644
flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/windowing/util/CarSource.java
copy
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/FinishedTaskStateProvider.java
=>
flink-examples/flink-examples-streaming/src/main/scala/org/apache/flink/streaming/scala/examples/async/AsyncClient.scala
(56%)
create mode 100644
flink-examples/flink-examples-streaming/src/main/scala/org/apache/flink/streaming/scala/examples/windowing/util/CarSource.scala
