hub / github.com/coderblack/doit30_flink

github.com/coderblack/doit30_flink @main

Chat with this repo

repository ↗ · DeepWiki ↗ · + Follow

645 symbols 1,357 edges 121 files 136 documented · 21% ● updated 3y ago★ 33

Browse by type

⨍ Functions 478◇ Types & classes 167

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

loading…

Extension points exported contracts — how you extend this code

Collector (Interface)

(no doc) [4 implementers]

datagen/src/main/java/cn/doitedu/module/Collector.java

browse all types & interfaces →

Core symbols most depended-on inside this repo

↓ 36 filesMyEventTimeTrigger

flink_course/src/main/java/cn/doitedu/flink/java/demos/_21_Window_Api_Demo4.java

↓ 35 filesCollector

datagen/src/main/java/cn/doitedu/module/Collector.java

↓ 33 filesMyTimeEvictor

flink_course/src/main/java/cn/doitedu/flink/java/demos/_21_Window_Api_Demo4.java

↓ 14 filesAbstractStreamOperator

Base class for all stream operators. Operators that contain a user function should extend the class AbstractUdfStreamOperator …

flink_course/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperator.java

↓ 9 filesMergingWindowStateStore

Special AbstractPerWindowStateStore that doesn't allow access to per-window state.

flink_course/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperator.java

↓ 8 filesWindowContext

A utility class for handling ProcessWindowFunction invocations. This can be reused by setting the key and window fields. No …

flink_course/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperator.java

browse all functions →

Shape

Method 478

Class 166

Interface 1

Languages

Java100%

Modules by API surface

flink_course/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperator.java68 symbols

flink_course/src/main/java/tmp/pojos/UserSlotGame.java49 symbols

flink_course/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperator.java45 symbols

flink_course/src/main/java/tmp/pojos/MysqlUser.java31 symbols

flink_course/src/main/java/cn/doitedu/flink/java/demos/_21_Window_Api_Demo4.java21 symbols

flink_course/src/main/java/cn/doitedu/flink/java/demos/_06_CustomSourceFunction.java18 symbols

flink_course/src/main/java/cn/doitedu/flinksql/fuxi/Exercise.java15 symbols

flink_course/src/main/java/tmp/FlinkKafkaDemo.java13 symbols

flink_course/src/main/java/org/apache/flink/streaming/runtime/operators/TimestampsAndWatermarksOperator.java12 symbols

flink_course/src/main/java/cn/doitedu/flink/java/demos/_12_RedisSinkOperator_Demo1.java12 symbols

flink_course/src/main/java/cn/doitedu/flinksql/fuxi/KeyedStateDemo.java10 symbols

flink_course/src/main/java/cn/doitedu/flink/java/demos/_20_Window_Api_Demo1.java10 symbols

Datastores touched

(mysql)Database · 1 repos

abcDatabase · 1 repos

flinktestDatabase · 1 repos

domino_adsDatabase · 1 repos

For agents

$ claude mcp add doit30_flink \
  -- python -m otcore.mcp_server <graph>

⬇ download graph artifact

github.com/coderblack/doit30_flink @main

Extension points exported contracts — how you extend this code

Core symbols most depended-on inside this repo

Shape

Languages

Modules by API surface

Datastores touched

For agents

Ask about this repo answers extend the page