Index

A D E F G L O S
All Classes and Interfaces|All Packages|Serialized Form

A

addComponentConfig(String, Object) - Method in class org.apache.storm.flux.wrappers.bolts.FluxShellBolt

Add configuration for this bolt.

addComponentConfig(String, Object) - Method in class org.apache.storm.flux.wrappers.spouts.FluxShellSpout

Add configuration for this spout.

addComponentConfig(String, List<Object>) - Method in class org.apache.storm.flux.wrappers.bolts.FluxShellBolt

Add configuration for this bolt.

addComponentConfig(String, List<Object>) - Method in class org.apache.storm.flux.wrappers.spouts.FluxShellSpout

Add configuration for this spout.

D

declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.flux.wrappers.bolts.FluxShellBolt

declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.flux.wrappers.bolts.LogInfoBolt

declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.flux.wrappers.spouts.FluxShellSpout

E

execute(Tuple, BasicOutputCollector) - Method in class org.apache.storm.flux.wrappers.bolts.LogInfoBolt

F

FluxShellBolt - Class in org.apache.storm.flux.wrappers.bolts

A generic `ShellBolt` implementation that allows you specify output fields and even streams without having to subclass `ShellBolt` to do so.

FluxShellBolt(String[]) - Constructor for class org.apache.storm.flux.wrappers.bolts.FluxShellBolt

Create a ShellBolt with command line arguments.

FluxShellBolt(String[], String[]) - Constructor for class org.apache.storm.flux.wrappers.bolts.FluxShellBolt

Create a ShellBolt with command line arguments and output fields Keep this constructor for backward compatibility.

FluxShellSpout - Class in org.apache.storm.flux.wrappers.spouts

A generic `ShellSpout` implementation that allows you specify output fields and even streams without having to subclass `ShellSpout` to do so.

FluxShellSpout(String[]) - Constructor for class org.apache.storm.flux.wrappers.spouts.FluxShellSpout

Create a ShellSpout with command line arguments.

FluxShellSpout(String[], String[]) - Constructor for class org.apache.storm.flux.wrappers.spouts.FluxShellSpout

Create a ShellSpout with command line arguments and output fields

G

getComponentConfiguration() - Method in class org.apache.storm.flux.wrappers.bolts.FluxShellBolt

getComponentConfiguration() - Method in class org.apache.storm.flux.wrappers.spouts.FluxShellSpout

L

LogInfoBolt - Class in org.apache.storm.flux.wrappers.bolts

Simple bolt that does nothing other than LOG.info() every tuple recieveed.

LogInfoBolt() - Constructor for class org.apache.storm.flux.wrappers.bolts.LogInfoBolt

O

org.apache.storm.flux.wrappers.bolts - package org.apache.storm.flux.wrappers.bolts

org.apache.storm.flux.wrappers.spouts - package org.apache.storm.flux.wrappers.spouts

S

setDefaultStream(String[]) - Method in class org.apache.storm.flux.wrappers.bolts.FluxShellBolt

Set default stream outputFields, this method is called from YAML file:

setDefaultStream(String[]) - Method in class org.apache.storm.flux.wrappers.spouts.FluxShellSpout

Set default stream outputFields, this method is called from YAML file:

setNamedStream(String, String[]) - Method in class org.apache.storm.flux.wrappers.bolts.FluxShellBolt

Set custom *named* stream outputFields, this method is called from YAML file:

setNamedStream(String, String[]) - Method in class org.apache.storm.flux.wrappers.spouts.FluxShellSpout

Set custom *named* stream outputFields, this method is called from YAML file:

A D E F G L O S
All Classes and Interfaces|All Packages|Serialized Form