Uses of Interface
org.apache.storm.spout.ISpout
-
-
Uses of ISpout in org.apache.storm
Classes in org.apache.storm that implement ISpout Modifier and Type Class Description static classExclamationTopology.FixedOrderWordSpout -
Uses of ISpout in org.apache.storm.clojure
Classes in org.apache.storm.clojure that implement ISpout Modifier and Type Class Description classClojureSpoutclassRichShellSpout -
Uses of ISpout in org.apache.storm.drpc
Classes in org.apache.storm.drpc that implement ISpout Modifier and Type Class Description classDRPCSpout -
Uses of ISpout in org.apache.storm.executor.spout
Constructors in org.apache.storm.executor.spout with parameters of type ISpout Constructor Description SpoutOutputCollectorImpl(ISpout spout, SpoutExecutor executor, Task taskData, MutableLong emittedCount, boolean hasAckers, Random random, Boolean isEventLoggers, Boolean isDebug, RotatingMap<Long,TupleInfo> pending) -
Uses of ISpout in org.apache.storm.flux.wrappers.spouts
Classes in org.apache.storm.flux.wrappers.spouts that implement ISpout 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 ISpout in org.apache.storm.hdfs.bolt
Classes in org.apache.storm.hdfs.bolt that implement ISpout Modifier and Type Class Description static classHdfsFileTopology.SentenceSpoutstatic classSequenceFileTopology.SentenceSpout -
Uses of ISpout in org.apache.storm.hdfs.spout
Classes in org.apache.storm.hdfs.spout that implement ISpout Modifier and Type Class Description classHdfsSpout -
Uses of ISpout in org.apache.storm.hive.bolt
Classes in org.apache.storm.hive.bolt that implement ISpout Modifier and Type Class Description static classBucketTestHiveTopology.UserDataSpoutstatic classHiveTopology.UserDataSpoutstatic classHiveTopologyPartitioned.UserDataSpout -
Uses of ISpout in org.apache.storm.jdbc.spout
Classes in org.apache.storm.jdbc.spout that implement ISpout Modifier and Type Class Description classUserSpout -
Uses of ISpout in org.apache.storm.jms.spout
Classes in org.apache.storm.jms.spout that implement ISpout 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 ISpout in org.apache.storm.kafka.spout
Classes in org.apache.storm.kafka.spout that implement ISpout Modifier and Type Class Description classKafkaSpout<K,V> -
Uses of ISpout in org.apache.storm.lambda
Classes in org.apache.storm.lambda that implement ISpout Modifier and Type Class Description classLambdaSpout -
Uses of ISpout in org.apache.storm.loadgen
Classes in org.apache.storm.loadgen that implement ISpout Modifier and Type Class Description classLoadSpoutA spout that simulates a real world spout based off of statistics about it.static classThroughputVsLatency.FastRandomSentenceSpout -
Uses of ISpout in org.apache.storm.perf.spout
Classes in org.apache.storm.perf.spout that implement ISpout Modifier and Type Class Description classConstSpoutclassFileReadSpoutclassStringGenSpoutSpout pre-computes a list with 30k fixed length random strings.classWordGenSpout -
Uses of ISpout in org.apache.storm.redis.topology
Classes in org.apache.storm.redis.topology that implement ISpout Modifier and Type Class Description classWordSpout -
Uses of ISpout in org.apache.storm.spout
Classes in org.apache.storm.spout that implement ISpout Modifier and Type Class Description classCheckpointSpoutEmits checkpoint tuples which is used to save the state of theIStatefulComponentacross the topology.classShellSpout -
Uses of ISpout in org.apache.storm.sql.runtime.datasource.socket.spout
Classes in org.apache.storm.sql.runtime.datasource.socket.spout that implement ISpout Modifier and Type Class Description classSocketSpoutSpout for Socket data. -
Uses of ISpout in org.apache.storm.st.topology.window
Classes in org.apache.storm.st.topology.window that implement ISpout Modifier and Type Class Description classIncrementingSpoutclassTimeDataIncrementingSpout -
Uses of ISpout in org.apache.storm.starter
Classes in org.apache.storm.starter that implement ISpout Modifier and Type Class Description static classAnchoredWordCount.RandomSentenceSpoutstatic classBlobStoreAPIWordCountTopology.RandomSentenceSpoutstatic classFastWordCountTopology.FastRandomSentenceSpoutstatic classInOrderDeliveryTest.InOrderSpoutstatic classWordCountTopologyNode.RandomSentence -
Uses of ISpout in org.apache.storm.starter.spout
Classes in org.apache.storm.starter.spout that implement ISpout 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 ISpout in org.apache.storm.testing
Classes in org.apache.storm.testing that implement ISpout Modifier and Type Class Description classFeederSpoutclassFixedTupleSpoutclassPythonShellMetricsSpoutclassSpoutTrackerclassTestEventLogSpoutclassTestPlannerSpoutclassTestWordSpout -
Uses of ISpout in org.apache.storm.topology
Subinterfaces of ISpout in org.apache.storm.topology Modifier and Type Interface Description interfaceIRichSpoutWhen writing topologies using Java,IRichBoltandIRichSpoutare the main interfaces to use to implement components of the topology. -
Uses of ISpout in org.apache.storm.topology.base
Classes in org.apache.storm.topology.base that implement ISpout Modifier and Type Class Description classBaseRichSpout -
Uses of ISpout in org.apache.storm.trident.spout
Classes in org.apache.storm.trident.spout that implement ISpout Modifier and Type Class Description classRichSpoutBatchTriggerer -
Uses of ISpout in org.apache.storm.trident.topology
Classes in org.apache.storm.trident.topology that implement ISpout Modifier and Type Class Description classMasterBatchCoordinator
-