FsStorm
StormDSL Namespace
Type | Description |
BoltSpec | Corresponds to https://github.com/apache/storm/blob/master/storm-core/src/storm.thrift#L102 |
Component | Component definition, https://github.com/apache/storm/blob/master/storm-core/src/storm.thrift#L74 |
Grouping | Corresponds to https://github.com/apache/storm/blob/master/storm-core/src/storm.thrift#L52 |
ScriptRef | References the function that will run when Strom invokes the program. The 'Name' is passed in the configuration |
SpoutSpec | Corresponds to https://github.com/apache/storm/blob/master/storm-core/src/storm.thrift#L95 |
StreamId | Input stream reference |
StreamOutput | Output stream definition |
Topology | Aggregate all spouts and bolts |
global Namespace
Module | Description |
Storm | Storm abstractions |
StormDSLTranslate | Translation of Storm DSL into Thrift structures (for submission to Nimbus) |
StormDSLValidate | Topology validation (prior to submission) |
StormDotGraph | |
StormProcessing | Runtime support |
StormTest | Support for unit-testing of components |
FsJson | Json serialization |
Logging | Custom file-based logging that writes to a pid-identified file. |