Uses of Interface
org.apache.storm.topology.IRichSpout
-
-
Uses of IRichSpout in org.apache.storm
Classes in org.apache.storm that implement IRichSpout Modifier and Type Class Description static classExclamationTopology.FixedOrderWordSpoutMethods in org.apache.storm that return IRichSpout Modifier and Type Method Description IRichSpoutThrift.SpoutDetails. getSpout()Methods in org.apache.storm with parameters of type IRichSpout Modifier and Type Method Description static SpoutSpecThrift. prepareSerializedSpoutDetails(IRichSpout spout, Map<String,StreamInfo> outputs)static Thrift.SpoutDetailsThrift. prepareSpoutDetails(IRichSpout spout)static Thrift.SpoutDetailsThrift. prepareSpoutDetails(IRichSpout spout, Integer parallelismHint)static Thrift.SpoutDetailsThrift. prepareSpoutDetails(IRichSpout spout, Integer parallelismHint, Map<String,Object> conf)Constructors in org.apache.storm with parameters of type IRichSpout Constructor Description SpoutDetails(IRichSpout spout, Integer parallelism, Map<String,Object> conf) -
Uses of IRichSpout in org.apache.storm.clojure
Classes in org.apache.storm.clojure that implement IRichSpout Modifier and Type Class Description classClojureSpoutclassRichShellSpout -
Uses of IRichSpout in org.apache.storm.drpc
Classes in org.apache.storm.drpc that implement IRichSpout Modifier and Type Class Description classDRPCSpout -
Uses of IRichSpout in org.apache.storm.flux.model
Methods in org.apache.storm.flux.model with parameters of type IRichSpout Modifier and Type Method Description voidExecutionContext. addSpout(String id, IRichSpout spout) -
Uses of IRichSpout in org.apache.storm.flux.wrappers.spouts
Classes in org.apache.storm.flux.wrappers.spouts that implement IRichSpout Modifier and Type Class Description classFluxShellSpoutA generic `ShellSpout` implementation that allows you specify output fields and even streams without having to subclass `ShellSpout` to do so. -
Uses of IRichSpout in org.apache.storm.hdfs.bolt
Classes in org.apache.storm.hdfs.bolt that implement IRichSpout Modifier and Type Class Description static classHdfsFileTopology.SentenceSpoutstatic classSequenceFileTopology.SentenceSpout -
Uses of IRichSpout in org.apache.storm.hdfs.spout
Classes in org.apache.storm.hdfs.spout that implement IRichSpout Modifier and Type Class Description classHdfsSpout -
Uses of IRichSpout in org.apache.storm.hive.bolt
Classes in org.apache.storm.hive.bolt that implement IRichSpout Modifier and Type Class Description static classBucketTestHiveTopology.UserDataSpoutstatic classHiveTopology.UserDataSpoutstatic classHiveTopologyPartitioned.UserDataSpout -
Uses of IRichSpout in org.apache.storm.jdbc.spout
Classes in org.apache.storm.jdbc.spout that implement IRichSpout Modifier and Type Class Description classUserSpout -
Uses of IRichSpout in org.apache.storm.jms.spout
Classes in org.apache.storm.jms.spout that implement IRichSpout Modifier and Type Class Description classJmsSpoutA StormSpoutimplementation that listens to a JMS topic or queue and outputs tuples based on the messages it receives. -
Uses of IRichSpout in org.apache.storm.kafka.spout
Classes in org.apache.storm.kafka.spout that implement IRichSpout Modifier and Type Class Description classKafkaSpout<K,V> -
Uses of IRichSpout in org.apache.storm.lambda
Classes in org.apache.storm.lambda that implement IRichSpout Modifier and Type Class Description classLambdaSpout -
Uses of IRichSpout in org.apache.storm.loadgen
Classes in org.apache.storm.loadgen that implement IRichSpout Modifier and Type Class Description classLoadSpoutA spout that simulates a real world spout based off of statistics about it.static classThroughputVsLatency.FastRandomSentenceSpout -
Uses of IRichSpout in org.apache.storm.perf.spout
Classes in org.apache.storm.perf.spout that implement IRichSpout Modifier and Type Class Description classConstSpoutclassFileReadSpoutclassStringGenSpoutSpout pre-computes a list with 30k fixed length random strings.classWordGenSpout -
Uses of IRichSpout in org.apache.storm.redis.topology
Classes in org.apache.storm.redis.topology that implement IRichSpout Modifier and Type Class Description classWordSpout -
Uses of IRichSpout in org.apache.storm.spout
Classes in org.apache.storm.spout that implement IRichSpout Modifier and Type Class Description classCheckpointSpoutEmits checkpoint tuples which is used to save the state of theIStatefulComponentacross the topology. -
Uses of IRichSpout in org.apache.storm.sql.runtime
Methods in org.apache.storm.sql.runtime that return IRichSpout Modifier and Type Method Description IRichSpoutISqlStreamsDataSource. getProducer()Provides instance of IRichSpout which can be used as producer in topology. -
Uses of IRichSpout in org.apache.storm.sql.runtime.datasource.socket.spout
Classes in org.apache.storm.sql.runtime.datasource.socket.spout that implement IRichSpout Modifier and Type Class Description classSocketSpoutSpout for Socket data. -
Uses of IRichSpout in org.apache.storm.st.topology.window
Classes in org.apache.storm.st.topology.window that implement IRichSpout Modifier and Type Class Description classIncrementingSpoutclassTimeDataIncrementingSpout -
Uses of IRichSpout in org.apache.storm.starter
Classes in org.apache.storm.starter that implement IRichSpout Modifier and Type Class Description static classAnchoredWordCount.RandomSentenceSpoutstatic classBlobStoreAPIWordCountTopology.RandomSentenceSpoutstatic classFastWordCountTopology.FastRandomSentenceSpoutstatic classInOrderDeliveryTest.InOrderSpoutstatic classWordCountTopologyNode.RandomSentence -
Uses of IRichSpout in org.apache.storm.starter.spout
Classes in org.apache.storm.starter.spout that implement IRichSpout Modifier and Type Class Description classRandomIntegerSpoutEmits a random integer and a timestamp value (offset by one day), every 100 ms.classRandomSentenceSpoutstatic classRandomSentenceSpout.TimeStamped -
Uses of IRichSpout in org.apache.storm.streams
Methods in org.apache.storm.streams with parameters of type IRichSpout Modifier and Type Method Description Stream<Tuple>StreamBuilder. newStream(IRichSpout spout)Creates a newStreamof tuples from the givenIRichSpout.Stream<Tuple>StreamBuilder. newStream(IRichSpout spout, int parallelism)Creates a newStreamof tuples from the givenIRichSpoutwith the given parallelism.<K,V>
PairStream<K,V>StreamBuilder. newStream(IRichSpout spout, PairValueMapper<K,V> pairValueMapper)Creates a newPairStreamof key-value pairs from the givenIRichSpoutby extracting key and value from tuples via the suppliedPairValueMapper.<K,V>
PairStream<K,V>StreamBuilder. newStream(IRichSpout spout, PairValueMapper<K,V> pairValueMapper, int parallelism)Creates a newPairStreamof key-value pairs from the givenIRichSpoutby extracting key and value from tuples via the suppliedPairValueMapperand with the given value of parallelism.<T> Stream<T>StreamBuilder. newStream(IRichSpout spout, TupleValueMapper<T> valueMapper)Creates a newStreamof values from the givenIRichSpoutby extracting field(s) from tuples via the suppliedTupleValueMapper.<T> Stream<T>StreamBuilder. newStream(IRichSpout spout, TupleValueMapper<T> valueMapper, int parallelism)Creates a newStreamof values from the givenIRichSpoutby extracting field(s) from tuples via the suppliedTupleValueMapperwith the given parallelism. -
Uses of IRichSpout in org.apache.storm.testing
Classes in org.apache.storm.testing that implement IRichSpout Modifier and Type Class Description classFeederSpoutclassFixedTupleSpoutclassPythonShellMetricsSpoutclassSpoutTrackerclassTestEventLogSpoutclassTestPlannerSpoutclassTestWordSpoutConstructors in org.apache.storm.testing with parameters of type IRichSpout Constructor Description SpoutTracker(IRichSpout delegate, String trackId) -
Uses of IRichSpout in org.apache.storm.topology
Methods in org.apache.storm.topology with parameters of type IRichSpout Modifier and Type Method Description SpoutDeclarerTopologyBuilder. setSpout(String id, IRichSpout spout)Define a new spout in this topology.SpoutDeclarerTopologyBuilder. setSpout(String id, IRichSpout spout, Number parallelismHint)Define a new spout in this topology with the specified parallelism. -
Uses of IRichSpout in org.apache.storm.topology.base
Classes in org.apache.storm.topology.base that implement IRichSpout Modifier and Type Class Description classBaseRichSpout -
Uses of IRichSpout in org.apache.storm.trident
Methods in org.apache.storm.trident with parameters of type IRichSpout Modifier and Type Method Description StreamTridentTopology. newStream(String txId, IRichSpout spout) -
Uses of IRichSpout in org.apache.storm.trident.spout
Classes in org.apache.storm.trident.spout that implement IRichSpout Modifier and Type Class Description classRichSpoutBatchTriggererConstructors in org.apache.storm.trident.spout with parameters of type IRichSpout Constructor Description RichSpoutBatchExecutor(IRichSpout spout)RichSpoutBatchTriggerer(IRichSpout delegate, String streamName, String batchGroup) -
Uses of IRichSpout in org.apache.storm.trident.topology
Classes in org.apache.storm.trident.topology that implement IRichSpout Modifier and Type Class Description classMasterBatchCoordinatorMethods in org.apache.storm.trident.topology with parameters of type IRichSpout Modifier and Type Method Description SpoutDeclarerTridentTopologyBuilder. setBatchPerTupleSpout(String id, String streamName, IRichSpout spout, Integer parallelism, String batchGroup)
-