MCPcopy Index your code
hub / github.com/dataArtisans/flink-dataflow

github.com/dataArtisans/flink-dataflow @main

Chat with this repo
repository ↗ · DeepWiki ↗ · + Follow
982 symbols 2,445 edges 79 files 115 documented · 12% ● updated 10y ago★ 885 open issues

Browse by type

⨍ Functions 813◇ Types & classes 169
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

Core symbols most depended-on inside this repo

Shape

Method 813
Class 156
Interface 12
Enum 1

Languages

Java100%

Modules by API surface

runner/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/streaming/state/FlinkStateInternals.java72 symbols
runner/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/streaming/FlinkGroupAlsoByWindowWrapper.java48 symbols
runner/src/main/java/com/dataartisans/flink/dataflow/translation/FlinkBatchTransformTranslators.java36 symbols
examples/src/main/java/com/dataartisans/flink/dataflow/examples/streaming/AutoComplete.java36 symbols
runner/src/main/java/com/dataartisans/flink/dataflow/translation/FlinkStreamingTransformTranslators.java31 symbols
runner/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/streaming/FlinkAbstractParDoWrapper.java28 symbols
runner/src/test/java/com/dataartisans/flink/dataflow/streaming/UnboundedSourceITCase.java24 symbols
runner/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/streaming/io/UnboundedSocketSource.java24 symbols
runner/src/main/java/com/dataartisans/flink/dataflow/translation/functions/FlinkDoFnFunction.java24 symbols
runner/src/main/java/com/dataartisans/flink/dataflow/translation/types/KvCoderTypeInformation.java23 symbols
runner/src/test/java/com/dataartisans/flink/dataflow/ReadSourceITCase.java22 symbols
runner/src/test/java/com/dataartisans/flink/dataflow/WriteSinkITCase.java21 symbols

For agents

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

⬇ download graph artifact

Ask about this repo answers extend the page