Sha256: 5818876b922ae0c77acdc2a63bd3ced2c6b0e51892812108820c89bbb9487787

Contents?: true

Size: 1.2 KB

Versions: 2

Compression:

Stored size: 1.2 KB

Contents

# Wukong Storm

## Usage

The Wukong Storm plugin is very basic at the moment. It functions entirely over STDIN and STDOUT. Taken from the `wu-storm` executable:

```
usage: wu-storm PROCESSOR|FLOW [...--param=value...]

wu-storm is a commandline tool for running Wukong processors and flows in
a storm or trident topology.

wu-storm operates over STDIN and STDOUT and has a one-to-one message guarantee.
For example, when using an identity processor, wu-storm, given an event 'foo', will return
'foo|'. The '|' character is the specified End-Of-File delimiter. 

If there is ever a suppressed error in pricessing, or a skipped record for any reason,
wu-storm will still respond with a '|', signifying an empty return event.

If there are multiple messages that have resulted from a single event, wu-storm will return
them newline separated, followed by the delimite, e.g. 'foo\nbar\nbaz|'.


Params:
   -t, --delimiter=String       The EOF specifier when returning events [Default: |]
   -r, --run=String             Name of the processor or dataflow to use. Defaults to basename of the given path
```

## TODO

The configuration file has __all__ of the options for storm listed. Slowly translating into real Configliere options.

Version data entries

2 entries across 2 versions & 1 rubygems

Version Path
wukong-storm-0.0.2 README.md
wukong-storm-0.0.1 README.md