Package | Description |
---|---|
org.apache.storm.clojure | |
org.apache.storm.flux.wrappers.spouts | |
org.apache.storm.spout | |
org.apache.storm.starter | |
org.apache.storm.testing |
Modifier and Type | Class and Description |
---|---|
class |
RichShellSpout |
Modifier and Type | Class and Description |
---|---|
class |
FluxShellSpout
A generic
ShellSpout implementation that allows you specify output fields and even streams without having to subclass ShellSpout to do so. |
Modifier and Type | Method and Description |
---|---|
ShellSpout |
ShellSpout.setEnv(Map<String,String> env) |
Modifier and Type | Class and Description |
---|---|
static class |
WordCountTopologyNode.RandomSentence |
Modifier and Type | Class and Description |
---|---|
class |
PythonShellMetricsSpout |
Copyright © 2019 The Apache Software Foundation. All rights reserved.