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 2022/02/02 18:36:16 UTC
[flink-statefun-playground] branch release-3.1 updated (ebc83ab -> 9c666fd)
This is an automated email from the ASF dual-hosted git repository.
trohrmann pushed a change to branch release-3.1
in repository https://gitbox.apache.org/repos/asf/flink-statefun-playground.git.
from ebc83ab Change the version to 3.1.1
add 9c666fd [FLINK-25899] Add connected components example
No new revisions were added by this update.
Summary of changes:
java/{greeter => connected-components}/Dockerfile | 4 +-
java/{greeter => connected-components}/README.md | 20 +--
.../docker-compose.yml | 20 +--
java/{greeter => connected-components}/module.yaml | 16 +--
.../pom.xml | 43 ++-----
.../ConnectedComponentsAppServer.java} | 11 +-
.../connectedcomponents/ConnectedComponentsFn.java | 134 +++++++++++++++++++++
.../java/connectedcomponents/types/Types.java | 41 +++++++
.../java/connectedcomponents/types/Vertex.java | 24 ++++
.../types/VertexComponentChange.java | 41 +++++++
.../undertow/UndertowHttpHandler.java | 2 +-
java/connected-components/vertices.txt | 12 ++
12 files changed, 299 insertions(+), 69 deletions(-)
copy java/{greeter => connected-components}/Dockerfile (84%)
copy java/{greeter => connected-components}/README.md (74%)
copy java/{greeter => connected-components}/docker-compose.yml (86%)
copy java/{greeter => connected-components}/module.yaml (75%)
copy java/{shopping-cart => connected-components}/pom.xml (77%)
copy java/{greeter/src/main/java/org/apache/flink/statefun/playground/java/greeter/GreeterAppServer.java => connected-components/src/main/java/org/apache/flink/statefun/playground/java/connectedcomponents/ConnectedComponentsAppServer.java} (83%)
create mode 100644 java/connected-components/src/main/java/org/apache/flink/statefun/playground/java/connectedcomponents/ConnectedComponentsFn.java
create mode 100644 java/connected-components/src/main/java/org/apache/flink/statefun/playground/java/connectedcomponents/types/Types.java
create mode 100644 java/connected-components/src/main/java/org/apache/flink/statefun/playground/java/connectedcomponents/types/Vertex.java
create mode 100644 java/connected-components/src/main/java/org/apache/flink/statefun/playground/java/connectedcomponents/types/VertexComponentChange.java
copy java/{greeter/src/main/java/org/apache/flink/statefun/playground/java/greeter => connected-components/src/main/java/org/apache/flink/statefun/playground/java/connectedcomponents}/undertow/UndertowHttpHandler.java (96%)
create mode 100644 java/connected-components/vertices.txt