FsStorm


FsStorm

StormDSL Namespace

TypeDescription
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

ModuleDescription
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.

Fork me on GitHub