Uses of Interface
org.apache.storm.topology.IComponent
Packages that use IComponent
Package
Description
-
Uses of IComponent in org.apache.storm
Classes in org.apache.storm that implement IComponentModifier and TypeClassDescriptionstatic classstatic class -
Uses of IComponent in org.apache.storm.bolt
Classes in org.apache.storm.bolt that implement IComponent -
Uses of IComponent in org.apache.storm.clojure
Classes in org.apache.storm.clojure that implement IComponentModifier and TypeClassDescriptionclassclassclassclass -
Uses of IComponent in org.apache.storm.coordination
Subinterfaces of IComponent in org.apache.storm.coordinationClasses in org.apache.storm.coordination that implement IComponentModifier and TypeClassDescriptionclassclassCoordination requires the request ids to be globally unique for awhile. -
Uses of IComponent in org.apache.storm.drpc
Classes in org.apache.storm.drpc that implement IComponentModifier and TypeClassDescriptionclassclassclassclassclass -
Uses of IComponent in org.apache.storm.flux.examples
Classes in org.apache.storm.flux.examples that implement IComponentModifier and TypeClassDescriptionclassclassPrints the tuples to stdout.classclassThis bolt is used by the HBase example. -
Uses of IComponent in org.apache.storm.flux.wrappers.bolts
Classes in org.apache.storm.flux.wrappers.bolts that implement IComponentModifier and TypeClassDescriptionclassA generic `ShellBolt` implementation that allows you specify output fields and even streams without having to subclass `ShellBolt` to do so.classSimple bolt that does nothing other than LOG.info() every tuple recieveed. -
Uses of IComponent in org.apache.storm.flux.wrappers.spouts
Classes in org.apache.storm.flux.wrappers.spouts that implement IComponentModifier and TypeClassDescriptionclassA generic `ShellSpout` implementation that allows you specify output fields and even streams without having to subclass `ShellSpout` to do so. -
Uses of IComponent in org.apache.storm.hdfs.bolt
Classes in org.apache.storm.hdfs.bolt that implement IComponentModifier and TypeClassDescriptionclassclassclassstatic classstatic classclassstatic classstatic class -
Uses of IComponent in org.apache.storm.hdfs.spout
Classes in org.apache.storm.hdfs.spout that implement IComponent -
Uses of IComponent in org.apache.storm.jdbc.bolt
Classes in org.apache.storm.jdbc.bolt that implement IComponentModifier and TypeClassDescriptionclassclassBasic bolt for writing to any Database table.classBasic bolt for querying from any database. -
Uses of IComponent in org.apache.storm.jdbc.spout
Classes in org.apache.storm.jdbc.spout that implement IComponent -
Uses of IComponent in org.apache.storm.jms.bolt
Classes in org.apache.storm.jms.bolt that implement IComponentModifier and TypeClassDescriptionclassA JmsBolt receivesorg.apache.storm.tuple.Tupleobjects from a Storm topology and publishes JMS Messages to a destination (topic or queue). -
Uses of IComponent in org.apache.storm.jms.example
Classes in org.apache.storm.jms.example that implement IComponentModifier and TypeClassDescriptionclassA genericorg.apache.storm.topology.IRichBoltimplementation for testing/debugging the Storm JMS Spout and example topologies. -
Uses of IComponent in org.apache.storm.jms.spout
Classes in org.apache.storm.jms.spout that implement IComponentModifier and TypeClassDescriptionclassA StormSpoutimplementation that listens to a JMS topic or queue and outputs tuples based on the messages it receives. -
Uses of IComponent in org.apache.storm.kafka.bolt
Classes in org.apache.storm.kafka.bolt that implement IComponentModifier and TypeClassDescriptionclassKafkaBolt<K,V> Bolt implementation that can send Tuple data to Kafka. -
Uses of IComponent in org.apache.storm.kafka.spout
Classes in org.apache.storm.kafka.spout that implement IComponent -
Uses of IComponent in org.apache.storm.lambda
Classes in org.apache.storm.lambda that implement IComponentModifier and TypeClassDescriptionclassclassclass -
Uses of IComponent in org.apache.storm.loadgen
Classes in org.apache.storm.loadgen that implement IComponentModifier and TypeClassDescriptionclassA bolt that simulates a real world bolt based off of statistics about it.classA spout that simulates a real world spout based off of statistics about it.static classstatic classstatic class -
Uses of IComponent in org.apache.storm.perf.bolt
Classes in org.apache.storm.perf.bolt that implement IComponentModifier and TypeClassDescriptionclassclassclassclass -
Uses of IComponent in org.apache.storm.perf.spout
Classes in org.apache.storm.perf.spout that implement IComponentModifier and TypeClassDescriptionclassclassclassSpout pre-computes a list with 30k fixed length random strings.class -
Uses of IComponent in org.apache.storm.perf.utils
Classes in org.apache.storm.perf.utils that implement IComponent -
Uses of IComponent in org.apache.storm.redis.bolt
Classes in org.apache.storm.redis.bolt that implement IComponentModifier and TypeClassDescriptionclassAbstractRedisBolt class is for users to implement custom bolts which makes interaction with Redis.classBasic bolt for querying from Redis and filters out if key/field doesn't exist.classBasic bolt for querying from Redis and emits response as tuple.classBasic bolt for writing to Redis. -
Uses of IComponent in org.apache.storm.redis.topology
Classes in org.apache.storm.redis.topology that implement IComponentModifier and TypeClassDescriptionstatic classstatic classclassclass -
Uses of IComponent in org.apache.storm.spout
Classes in org.apache.storm.spout that implement IComponentModifier and TypeClassDescriptionclassEmits checkpoint tuples which is used to save the state of theIStatefulComponentacross the topology. -
Uses of IComponent in org.apache.storm.sql.runtime.datasource.socket.bolt
Classes in org.apache.storm.sql.runtime.datasource.socket.bolt that implement IComponent -
Uses of IComponent in org.apache.storm.sql.runtime.datasource.socket.spout
Classes in org.apache.storm.sql.runtime.datasource.socket.spout that implement IComponent -
Uses of IComponent in org.apache.storm.st.topology.window
Classes in org.apache.storm.st.topology.window that implement IComponentModifier and TypeClassDescriptionclassclassclassclass -
Uses of IComponent in org.apache.storm.starter
Classes in org.apache.storm.starter that implement IComponentModifier and TypeClassDescriptionstatic classstatic classstatic classstatic classstatic classstatic classstatic classstatic classstatic classstatic classstatic classstatic classstatic classstatic classstatic classstatic classstatic classstatic classstatic classstatic classstatic classstatic classstatic classstatic classstatic classstatic class -
Uses of IComponent in org.apache.storm.starter.bolt
Classes in org.apache.storm.starter.bolt that implement IComponentModifier and TypeClassDescriptionclassThis abstract bolt provides the basic behavior of bolts that rank objects according to their count.final classThis bolt ranks incoming objects by their count.classclassThis bolt aggregates counts from multiple upstream bolts.classThis bolt performs rolling counts of incoming objects, i.e.classExample of a simple custom bolt for joining two streams.classComputes sliding window sum.final classThis bolt merges incomingRankings.class -
Uses of IComponent in org.apache.storm.starter.spout
Classes in org.apache.storm.starter.spout that implement IComponentModifier and TypeClassDescriptionclassEmits a random integer and a timestamp value (offset by one day), every 100 ms.classstatic class -
Uses of IComponent in org.apache.storm.testing
Classes in org.apache.storm.testing that implement IComponentModifier and TypeClassDescriptionclassclassclassclassclassclassclassclassclassclassclassclassclassclassclassclassclassclassclass -
Uses of IComponent in org.apache.storm.topology
Subinterfaces of IComponent in org.apache.storm.topologyModifier and TypeInterfaceDescriptioninterfaceinterfaceWhen writing topologies using Java,IRichBoltandIRichSpoutare the main interfaces to use to implement components of the topology.interfaceWhen writing topologies using Java,IRichBoltandIRichSpoutare the main interfaces to use to implement components of the topology.interfaceinterfaceIStatefulBolt<T extends State>A bolt abstraction for supporting stateful computation.interfaceIStatefulComponent<T extends State>Common methods for stateful components in the topology.interfaceIStatefulWindowedBolt<T extends State>A windowed bolt abstraction for supporting windowing operation with state.interfaceA bolt abstraction for supporting time and count based sliding & tumbling windows.Classes in org.apache.storm.topology that implement IComponentModifier and TypeClassDescriptionclassBase class that abstracts the common logic for executing bolts in a stateful topology.classclassWrapsIRichBoltand forwards checkpoint tuples in a stateful topology.classPersistentWindowedBoltExecutor<T extends State>Wraps aIStatefulWindowedBoltand handles the execution.classStatefulBoltExecutor<T extends State>Wraps aIStatefulBoltand manages the state of the bolt.classStatefulWindowedBoltExecutor<T extends State>Wraps aIStatefulWindowedBoltand handles the execution.classAnIWindowedBoltwrapper that does the windowing of tuples. -
Uses of IComponent in org.apache.storm.topology.base
Classes in org.apache.storm.topology.base that implement IComponentModifier and TypeClassDescriptionclassclassclassclassclassclassBaseStatefulBolt<T extends State>classBaseStatefulWindowedBolt<T extends State>classThis class is based on BaseRichBolt, but is aware of tick tuple.class -
Uses of IComponent in org.apache.storm.trident.planner
Classes in org.apache.storm.trident.planner that implement IComponentModifier and TypeClassDescriptionclassA Bolt that does processing for a subsection of the complete graph. -
Uses of IComponent in org.apache.storm.trident.spout
Classes in org.apache.storm.trident.spout that implement IComponentModifier and TypeClassDescriptionclassclassclass -
Uses of IComponent in org.apache.storm.trident.topology
Subinterfaces of IComponent in org.apache.storm.trident.topologyClasses in org.apache.storm.trident.topology that implement IComponent -
Uses of IComponent in org.apache.storm.trident.util
Methods in org.apache.storm.trident.util with parameters of type IComponentModifier and TypeMethodDescriptionstatic FieldsTridentUtils.getSingleOutputStreamFields(IComponent component)