MCPcopy Index your code
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%
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

Core symbols most depended-on inside this repo

of
called by 115
flink_course/src/main/java/cn/doitedu/flink/java/demos/_21_Window_Api_Demo4.java
collect
called by 57
datagen/src/main/java/cn/doitedu/module/Collector.java
create
called by 37
flink_course/src/main/java/cn/doitedu/flink/java/demos/_21_Window_Api_Demo4.java
get
called by 35
flink_course/src/main/java/cn/doitedu/flink/java/demos/_11_JdbcSinkOperator_Demo1.java
map
called by 32
flink_course/src/main/java/cn/doitedu/flink/java/demos/_26_State_TTL_Demo.java
map
called by 23
flink_course/src/main/java/cn/doitedu/flinksql/fuxi/Exercise.java
getRuntimeContext
called by 15
flink_course/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperator.java
equals
called by 12
flink_course/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperator.java

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