StormDSLTranslate
Namespace: global
Translation of Storm DSL into Thrift structures (for submission to Nimbus)
Functions and values
| Function or value | Description |
makeComponent (...)
Signature: exeName:string -> optionalArgs:string list -> compSpec:Component -> ComponentObject
|
|
makeGlobalId streamId
Signature: streamId:StreamId -> GlobalStreamId
|
|
makeGrouping grp
Signature: grp:Grouping -> Grouping
|
|
makeStreamInfo stream
Signature: stream:StreamOutput -> string * StreamInfo
|
|
translate exeName optionalArgs topology
Signature: exeName:string -> optionalArgs:string list -> topology:Topology -> StormTopology
|
|
