MCPcopy Index your code
hub / github.com/apache/storm

github.com/apache/storm @v2.8.8

Chat with this repo
repository ↗ · DeepWiki ↗ · release v2.8.8 ↗ · + Follow
32,133 symbols 106,588 edges 2,091 files 5,734 documented · 18% ● updated 4d agov2.8.8 · 2026-05-18★ 6,68936 open issues
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

ISpout (Interface)
ISpout is the core interface for implementing spouts. A Spout is responsible for feeding messages into the topology for [9 …
storm-client/src/jvm/org/apache/storm/spout/ISpout.java
TopologySource (Interface)
Marker interface for objects that can produce `StormTopology` objects. If a `topology-source` class implements the [33 …
flux/flux-core/src/main/java/org/apache/storm/flux/api/TopologySource.java
ILocalClusterTrackedTopologyAware (Interface)
This is here mostly for backwards compatibility. Please see org.apache.storm.LocalCluster for more details on te [7 implementers]
storm-server/src/main/java/org/apache/storm/ILocalClusterTrackedTopologyAware.java
KeyFactory (Interface)
KeyFactory defines conversion of state key (which could be compounded) -> Redis key. [25 implementers]
external/storm-redis/src/main/java/org/apache/storm/redis/trident/state/KeyFactory.java
CredentialKeyProvider (Interface)
Provider interface for credential key. [6 implementers]
external/storm-autocreds/src/main/java/org/apache/storm/common/CredentialKeyProvider.java
JmsTupleProducer (Interface)
Interface to define classes that can produce a Storm Values objects from a jakarta.jms.Message [7 implementers]
external/storm-jms/src/main/java/org/apache/storm/jms/JmsTupleProducer.java
Func (Interface)
A simple interface to allow compatibility with non java 8 code bases. [24 implementers]
external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/Func.java
SyncPolicy (Interface)
Interface for controlling when the HdfsBolt syncs and flushes the filesystem. [9 implementers]
external/storm-hdfs/src/main/java/org/apache/storm/hdfs/trident/sync/SyncPolicy.java

Core symbols most depended-on inside this repo

put
called by 3190
storm-client/src/jvm/org/apache/storm/state/KeyValueState.java
get
called by 2311
storm-client/src/jvm/org/apache/storm/windowing/Event.java
size
called by 1541
storm-client/src/jvm/org/apache/storm/tuple/ITuple.java
put
called by 1519
storm-server/src/main/java/org/apache/storm/metricstore/rocksdb/WritableStringMetadataCache.java
get
called by 1452
storm-server/src/main/java/org/apache/storm/metricstore/rocksdb/ReadOnlyStringMetadataCache.java
write
called by 1293
storm-client/src/jvm/org/apache/storm/messaging/netty/INettySerializable.java
getValue
called by 1037
storm-client/src/jvm/org/apache/storm/tuple/ITuple.java
readString
called by 971
storm-client/src/jvm/org/apache/storm/utils/WritableUtils.java

Shape

Method 27,461
Class 3,728
Interface 345
Function 309
Enum 290

Languages

Java92%
Python8%
TypeScript1%

Modules by API surface

storm-client/src/jvm/org/apache/storm/generated/Nimbus.java6,297 symbols
storm-client/src/py/storm/Nimbus.py1,153 symbols
storm-client/src/py/storm/ttypes.py801 symbols
storm-client/src/jvm/org/apache/storm/generated/DistributedRPCInvocations.java458 symbols
storm-client/src/jvm/org/apache/storm/generated/Supervisor.java347 symbols
storm-server/src/main/java/org/apache/storm/daemon/nimbus/Nimbus.java229 symbols
storm-client/src/jvm/org/apache/storm/generated/TopologyPageInfo.java216 symbols
storm-server/src/main/java/org/apache/storm/container/oci/OciContainerExecutorConfig.java209 symbols
storm-client/src/jvm/org/apache/storm/generated/DistributedRPC.java140 symbols
storm-client/src/jvm/org/apache/storm/generated/TopologySummary.java139 symbols
storm-client/src/jvm/org/apache/storm/utils/Utils.java136 symbols
storm-client/src/jvm/org/apache/storm/generated/ComponentPageInfo.java129 symbols

Dependencies from manifests, versioned

com.esotericsoftware:kryo1×
com.fasterxml.jackson.core:jackson-core1×
com.fasterxml.jackson.core:jackson-databind1×
com.fasterxml.jackson.dataformat:jackson-dataformat-smile1×
com.fasterxml.jackson:jackson-bom1×
com.fasterxml.woodstox:woodstox-core7.1.1 · 1×
com.github.ben-manes.caffeine:caffeine1×
com.google.auto.service:auto-service1×
com.google.code.findbugs:jsr3053.0.2 · 1×
com.google.code.gson:gson1×
com.google.errorprone:error_prone_annotations1×
com.google.guava:guava1×

Datastores touched

(mysql)Database · 1 repos

For agents

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

⬇ download graph artifact