DSL
Namespace: FsShelter
Embedded DSL for defining the topologies
Nested types and modules
| Type | Description |
| Ack | ack signature |
| Acker | ack/nack tuple |
| All | define all grouping |
| Consume<'a> | bolt function signature |
| Direct | define direct grouping |
| Emit<'t> | emit signature |
| Group | define fields grouping |
| Nack | nack signature |
| Next<'a, 't> | spout function signature |
| Shuffle | define shuffle grouping |
| TopologyBuilder | TopologyBuilder computation expression |
| Module | Description |
| Bolt | |
| Spout |
Functions and values
| Function or value | Description |
( ++ ) t t2
Signature: t:Topology<'t> -> t2:Topology<'t> -> Topology<'t>
Type parameters: 't |
combine two topologies under the first topology's name CompiledName: |
( ==> ) arg1 arg2
Signature: '?8178 -> Bolt<'t> -> bool
Type parameters: '?8178, 't |
stream and anchor subsequent emits CompiledName: |
( --> ) arg1 arg2
Signature: '?8175 -> Bolt<'t> -> bool
Type parameters: '?8175, 't |
stream, subsequent emits are NOT anchored CompiledName: |
asBolt
Signature: Component<'t> -> Bolt<'t>
Type parameters: 't |
|
asSpout
Signature: Component<'t> -> Spout<'t>
Type parameters: 't |
|
java className args
Signature: className:string -> args:string list -> Component<'?8134>
Type parameters: '?8134 |
wrap (Storm native) java component definition |
runBolt
Signature: ((LogLevel -> string -> unit) -> Conf -> '?8139 -> ('?8139 -> unit) -> '?8140) -> Consume<'?8140> -> Bolt<'?8139>
Type parameters: '?8139, '?8140 |
|
runReliableSpout
Signature: ((LogLevel -> string -> unit) -> Conf -> '?8149) -> ('?8149 -> Acker) -> ('?8149 -> unit) -> Next<'?8149,(string * '?8150)> -> Spout<'?8150>
Type parameters: '?8149, '?8150 |
|
runSpout
Signature: ((LogLevel -> string -> unit) -> Conf -> '?8146) -> ('?8146 -> unit) -> Next<'?8146,'?8147> -> Spout<'?8147>
Type parameters: '?8146, '?8147 |
|
runTerminator
Signature: ((LogLevel -> string -> unit) -> Conf -> '?8136 -> '?8137) -> Consume<'?8137> -> Bolt<'?8136>
Type parameters: '?8136, '?8137 |
|
shell command args
Signature: command:string -> args:string -> Component<'?8132>
Type parameters: '?8132 |
wrap (external) shell component definition |
topology name
Signature: name:string -> TopologyBuilder
|
topology builder instance |
withActivation tuple spec
Signature: tuple:'t -> spec:^s -> ^s
Type parameters: 't, ^s |
supply component Activation tuple |
withConf conf spec
Signature: conf:ConfOption list -> spec:^s -> ^s
Type parameters: ^s |
supply component configuration/overrides |
withDeactivation tuple spec
Signature: tuple:'t -> spec:^s -> ^s
Type parameters: 't, ^s |
supply component Deactivation tuple |
withParallelism parallelism spec
Signature: parallelism:^?8152 -> spec:^s -> ^s
Type parameters: ^?8152, ^s |
override default parallelism |
