hub / github.com/apache/flink-statefun-playground

github.com/apache/flink-statefun-playground @main

423 symbols 869 edges 83 files 91 documented · 22% ● updated 55d ago★ 134

What it actually does AI analysis from the code graph — generated when you open this

loading…

README

Stateful Functions Playground

This repository contains tutorials and examples for Stateful Functions. The material here is a great starting point if you've just started with getting to know the project or looking for specific examples of common usage patterns.

Tutorials and Examples

The repository contains tutorials and examples for all SDKs that Stateful Functions supports:

Each tutorial or example will have it's own README that explains in detail what is being covered and how to build and run the code by yourself.

Moreover, it contains examples for how to deploy Stateful Functions on various platforms.

Code of Conduct

Apache Flink, Stateful Functions, and all its associated repositories follow the Code of Conduct of the Apache Software Foundation.

License

The code in this repository is licensed under the Apache Software License 2.0.

Extension points exported contracts — how you extend this code

—

Core symbols most depended-on inside this repo

send

called by 45

playground-internal/statefun-playground-producer/main.py

get

called by 30

playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/entrypoint/ClassPathUniverseProvider.java

bind

called by 8

playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/binders/egress/v1/PlaygroundEgressBinder.java

sleep

called by 8

java/showcase/src/main/java/org/apache/flink/statefun/playground/java/showcase/part6/serving/StatefulFunctionsRuntimeProcesses.java

stop

called by 6

playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/flink/IngressWebServer.java

env

called by 6

playground-internal/statefun-playground-producer/main.py

build

called by 5

playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/spec/PlaygroundEgressSpec.java

getVertexId

called by 5

java/connected-components/src/main/java/org/apache/flink/statefun/playground/java/connectedcomponents/types/Vertex.java

Shape

Method 293

Class 77

Function 40

Struct 8

Enum 3

Interface 1

TypeAlias 1

Languages

Java86%

Go8%

Python6%

TypeScript1%

Modules by API surface

java/showcase/src/main/java/org/apache/flink/statefun/playground/java/showcase/part1/types/generated/UserProfile.java81 symbols

java/shopping-cart/src/main/java/org/apache/flink/statefun/playground/java/shoppingcart/Messages.java39 symbols

playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/flink/IngressWebServer.java13 symbols

java/showcase/src/main/java/org/apache/flink/statefun/playground/java/showcase/part1/types/generated/UserProfileOrBuilder.java12 symbols

java/shopping-cart/src/main/java/org/apache/flink/statefun/playground/java/shoppingcart/UserShoppingCartFn.java11 symbols

python/showcase/showcase/__main__.py9 symbols

playground-internal/statefun-playground-producer/main.py9 symbols

playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/spec/PlaygroundEgressSpec.java9 symbols

playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/spec/PlaygroundIngressSpec.java8 symbols

playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/flink/EgressWebServer.java8 symbols

java/shopping-cart/src/main/java/org/apache/flink/statefun/playground/java/shoppingcart/Expose.java8 symbols

playground-internal/statefun-playground-entrypoint/src/main/java/org/apache/flink/statefun/playground/internal/io/flink/RefCountedContainer.java7 symbols

For agents

$ claude mcp add flink-statefun-playground \
  -- python -m otcore.mcp_server <graph>

⬇ download graph artifact