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%
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

StreamTransformTranslator (Interface)
The interface that every Flink translator of a Beam operator should implement. This interface is for streaming jo [25 …
runner/src/main/java/com/dataartisans/flink/dataflow/translation/FlinkStreamingPipelineTranslator.java
Options (Interface)
Options supported by WordCount. Inherits standard configuration options.
examples/src/main/java/com/dataartisans/flink/dataflow/examples/WordCount.java
BatchTransformTranslator (Interface)
A translator of a PTransform. [25 implementers]
runner/src/main/java/com/dataartisans/flink/dataflow/translation/FlinkBatchPipelineTranslator.java
KafkaStreamingWordCountOptions (Interface)
(no doc)
examples/src/main/java/com/dataartisans/flink/dataflow/examples/streaming/KafkaWindowedWordCountExample.java
FlinkPipelineOptions (Interface)
Options which can be used to configure a Flink PipelineRunner.
runner/src/main/java/com/dataartisans/flink/dataflow/FlinkPipelineOptions.java
StreamingWordCountOptions (Interface)
(no doc)
examples/src/main/java/com/dataartisans/flink/dataflow/examples/streaming/WindowedWordCount.java

Core symbols most depended-on inside this repo

of
called by 246
runner/src/main/java/com/dataartisans/flink/dataflow/translation/functions/UnionCoder.java
getValue
called by 83
examples/src/main/java/com/dataartisans/flink/dataflow/examples/streaming/AutoComplete.java
add
called by 69
runner/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/CombineFnAggregatorWrapper.java
getKey
called by 45
runner/src/main/java/com/dataartisans/flink/dataflow/translation/wrappers/streaming/FlinkGroupByKeyWrapper.java
getOutput
called by 43
examples/src/main/java/com/dataartisans/flink/dataflow/examples/WordCount.java
apply
called by 42
examples/src/main/java/com/dataartisans/flink/dataflow/examples/streaming/AutoComplete.java
output
called by 39
runner/src/main/java/com/dataartisans/flink/dataflow/translation/functions/FlinkDoFnFunction.java
getInput
called by 35
examples/src/main/java/com/dataartisans/flink/dataflow/examples/WordCount.java

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