Uses of Interface
org.apache.storm.topology.IBasicBolt
Package
Description
-
Uses of IBasicBolt in org.apache.storm.coordination
Modifier and TypeMethodDescriptionBatchSubtopologyBuilder.setBolt
(String id, IBasicBolt bolt) BatchSubtopologyBuilder.setBolt
(String id, IBasicBolt bolt, Number parallelism) ModifierConstructorDescriptionBatchSubtopologyBuilder
(String masterBoltId, IBasicBolt masterBolt) BatchSubtopologyBuilder
(String masterBoltId, IBasicBolt masterBolt, Number boltParallelism) -
Uses of IBasicBolt in org.apache.storm.drpc
Modifier and TypeMethodDescriptionLinearDRPCTopologyBuilder.addBolt
(IBasicBolt bolt) LinearDRPCTopologyBuilder.addBolt
(IBasicBolt bolt, Number parallelism) -
Uses of IBasicBolt in org.apache.storm.flux.examples
Modifier and TypeClassDescriptionclass
Prints the tuples to stdout.class
This bolt is used by the HBase example. -
Uses of IBasicBolt in org.apache.storm.flux.wrappers.bolts
Modifier and TypeClassDescriptionclass
Simple bolt that does nothing other than LOG.info() every tuple recieveed. -
Uses of IBasicBolt in org.apache.storm.lambda
-
Uses of IBasicBolt in org.apache.storm.loadgen
Modifier and TypeClassDescriptionstatic class
static class
-
Uses of IBasicBolt in org.apache.storm.perf.bolt
-
Uses of IBasicBolt in org.apache.storm.redis.topology
-
Uses of IBasicBolt in org.apache.storm.starter
Modifier and TypeClassDescriptionstatic class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
static class
-
Uses of IBasicBolt in org.apache.storm.starter.bolt
Modifier and TypeClassDescriptionclass
This abstract bolt provides the basic behavior of bolts that rank objects according to their count.final class
This bolt ranks incoming objects by their count.class
final class
This bolt merges incomingRankings
.class
-
Uses of IBasicBolt in org.apache.storm.streams
Modifier and TypeMethodDescriptionvoid
Stream.to
(IBasicBolt bolt) Sends the elements of this stream to a bolt.void
Stream.to
(IBasicBolt bolt, int parallelism) Sends the elements of this stream to a bolt. -
Uses of IBasicBolt in org.apache.storm.testing
Modifier and TypeClassDescriptionclass
class
class
class
class
-
Uses of IBasicBolt in org.apache.storm.topology
Modifier and TypeMethodDescriptionTopologyBuilder.setBolt
(String id, IBasicBolt bolt) Define a new bolt in this topology.TopologyBuilder.setBolt
(String id, IBasicBolt bolt, Number parallelismHint) Define a new bolt in this topology. -
Uses of IBasicBolt in org.apache.storm.topology.base
-
Uses of IBasicBolt in org.apache.storm.trident.spout