FsShelter Namespace
| Type/Module | Description |
|
|
|
|
|
|
|
|
|
|
Storm configuration options |
|
|
Dispatch functions for spouts and bolts |
|
|
Converters into GraphViz |
|
|
Embedded DSL for defining the topologies |
|
|
|
|
|
File system utilities |
|
|
Json multilang IO |
|
|
Logger signature |
|
|
Storm log levels |
|
|
Defines 'multilang' storm interaction as described here: http://FsShelter.apache.org/documentation/Multilang-protocol.html |
|
|
Identifies a stream that should be "unfolded" into individual substream for each nested DU case. Only applies to single-argument constructor case that takes another DU case as nested. |
|
|
Nimbus client module |
|
|
JAR package creation |
|
|
Protobuf IO implementation |
|
|
Executable startup helpers |
|
|
Task execution |
|
|
Converters into Nimbus (Thrift) model |
|
|
Topology data model |
|
|
Tuple id - opaque identifier for tuple tracking. |
|
|
DU/Stream schema mapping functions |
FsShelter