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 © 2023 The Apache Software Foundation. All rights reserved.