Sha256: 7a361fef8b3f83fea9b62f4f5b4f1a39d5f5dacb93290db103eac636fa7c5e27
Contents?: true
Size: 1.21 KB
Versions: 2
Compression:
Stored size: 1.21 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\n|\n'. The '|' character is the specified End-Of-File delimiter. If there is ever a suppressed error in processing, or a skipped record for any reason, wu-storm will still respond with a '|\n', 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\n|\n'. 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.1.1 | README.md |
wukong-storm-0.1.0 | README.md |