MCPcopy Index your code
hub / github.com/dataArtisans/yahoo-streaming-benchmark

github.com/dataArtisans/yahoo-streaming-benchmark @main

Chat with this repo
repository ↗ · DeepWiki ↗ · + Follow
353 symbols 713 edges 45 files 70 documented · 20%
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

QueryableKeyValueState (Interface)
(no doc) [3 implementers]
flink-benchmarks/src/main/java/flink/benchmark/state/QueryableKeyValueState.java
QueryResponse (Interface)
(no doc) [2 implementers]
flink-benchmarks/src/main/java/flink/benchmark/state/QueryResponse.java
RegistrationService (Interface)
(no doc) [2 implementers]
flink-benchmarks/src/main/java/flink/benchmark/state/RegistrationService.java
RetrievalService (Interface)
(no doc) [1 implementers]
flink-benchmarks/src/main/java/flink/benchmark/state/RetrievalService.java

Core symbols most depended-on inside this repo

getValue
called by 32
flink-benchmarks/src/main/java/flink/benchmark/state/QueryableKeyValueState.java
getKey
called by 25
flink-benchmarks/src/main/java/flink/benchmark/state/QueryState.java
toString
called by 20
flink-benchmarks/src/main/java/flink/benchmark/state/StateFound.java
toString
called by 16
streaming-benchmark-common/src/main/java/benchmark/common/advertising/Window.java
getParameters
called by 16
flink-benchmarks/src/main/java/flink/benchmark/BenchmarkConfig.java
execute
called by 14
storm-benchmarks/src/main/java/storm/benchmark/AdvertisingTopology.java
add
called by 10
streaming-benchmark-common/src/main/java/benchmark/common/advertising/PooledRedisConnections.java
equals
called by 10
streaming-benchmark-common/src/main/java/benchmark/common/advertising/Window.java

Shape

Method 268
Class 80
Interface 4
Enum 1

Languages

Java100%

Modules by API surface

flink-benchmarks/src/main/java/flink/benchmark/AdvertisingTopologyFlinkWindows.java39 symbols
storm-benchmarks/src/main/java/storm/benchmark/AdvertisingTopology.java25 symbols
storm-benchmarks/src/main/java/storm/benchmark/AdvertisingTopologyHighKeyCard.java21 symbols
flink-benchmarks/src/main/java/flink/benchmark/state/QueryableWindowOperatorEvicting.java19 symbols
flink-benchmarks/src/main/java/flink/benchmark/state/QueryableWindowOperator.java19 symbols
flink-benchmarks/src/main/java/flink/benchmark/state/AdvertisingTopologyFlinkStateHighKeyCard.java16 symbols
flink-benchmarks/src/main/java/flink/benchmark/AdvertisingTopologyNative.java15 symbols
flink-benchmarks/src/main/java/flink/benchmark/state/QueryActor.java13 symbols
streaming-benchmark-common/src/main/java/benchmark/common/advertising/PooledRedisConnections.java11 symbols
flink-benchmarks/src/main/java/flink/benchmark/state/AdvertisingTopologyFlinkState.java11 symbols
flink-benchmarks/src/main/java/flink/benchmark/AdvertisingTopologyRedisDirect.java11 symbols
streaming-benchmark-common/src/main/java/benchmark/common/advertising/CampaignProcessorCommon.java9 symbols

For agents

$ claude mcp add yahoo-streaming-benchmark \
  -- python -m otcore.mcp_server <graph>

⬇ download graph artifact