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

github.com/nathanmarz/storm @0.9.0.1 sqlite

repository ↗ · DeepWiki ↗ · release 0.9.0.1 ↗
6,804 symbols 15,433 edges 464 files 873 documented · 13%

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 [6 …
storm-core/src/jvm/backtype/storm/spout/ISpout.java
IBolt (Interface)
An IBolt represents a component that takes tuples as input and produces tuples as output. An IBolt can do everything fro [35 …
storm-core/src/jvm/backtype/storm/task/IBolt.java
IOpaquePartitionedTransactionalSpout (Interface)
This defines a transactional spout which does not necessarily replay the same batch every time it emits a batch for a tr [10 …
storm-core/src/jvm/backtype/storm/transactional/partitioned/IOpaquePartitionedTransactionalSpout.java
IPartitionedTransactionalSpout (Interface)
This interface defines a transactional spout that reads its tuples from a partitioned set of brokers. It automates the s [10 …
storm-core/src/jvm/backtype/storm/transactional/partitioned/IPartitionedTransactionalSpout.java
IComponent (Interface)
Common methods for all possible components in a topology. This interface is used when defining topologies using the Java [28 …
storm-core/src/jvm/backtype/storm/topology/IComponent.java

Core symbols most depended-on inside this repo

get
called by 590
storm-core/src/jvm/storm/trident/state/snapshot/ReadOnlySnapshottable.java
put
called by 535
storm-core/src/jvm/backtype/storm/utils/LocalState.java
size
called by 233
storm-core/src/jvm/backtype/storm/tuple/Tuple.java
add
called by 219
storm-core/src/jvm/backtype/storm/state/ISynchronizeOutputCollector.java
getName
called by 175
storm-core/src/jvm/backtype/storm/scheduler/TopologyDetails.java
readString
called by 162
storm-core/src/jvm/backtype/storm/utils/WritableUtils.java
writeString
called by 160
storm-core/src/jvm/backtype/storm/utils/WritableUtils.java
getValue
called by 104
storm-core/src/jvm/backtype/storm/tuple/Tuple.java

Shape

Method 5,828
Class 638
Interface 133
Function 119
Enum 86

Languages

Java86%
Python13%
TypeScript1%

Modules by API surface

storm-core/src/jvm/backtype/storm/generated/Nimbus.java1,374 symbols
storm-core/src/py/storm/Nimbus.py415 symbols
storm-core/src/py/storm/ttypes.py292 symbols
storm-core/src/jvm/backtype/storm/generated/DistributedRPCInvocations.java227 symbols
storm-core/src/jvm/backtype/storm/generated/DistributedRPC.java98 symbols
storm-core/src/py/storm/DistributedRPCInvocations.py73 symbols
storm-core/src/jvm/backtype/storm/generated/TopologySummary.java59 symbols
storm-core/src/jvm/backtype/storm/generated/TopologyInfo.java59 symbols
storm-core/src/jvm/backtype/storm/generated/BoltStats.java59 symbols
storm-core/src/jvm/backtype/storm/tuple/TupleImpl.java56 symbols
storm-core/src/jvm/backtype/storm/generated/Grouping.java55 symbols
storm-core/src/jvm/backtype/storm/generated/ExecutorSummary.java54 symbols

For agents

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

⬇ download graph artifact