Package org.apache.storm.flux.wrappers.bolts
-
Class Summary Class Description FluxShellBolt A generic `ShellBolt` implementation that allows you specify output fields and even streams without having to subclass `ShellBolt` to do so.LogInfoBolt Simple bolt that does nothing other than LOG.info() every tuple recieveed.