backtype.storm.topology
Interface IComponent
- All Superinterfaces:
- java.io.Serializable
- All Known Subinterfaces:
- IBasicBolt, IBatchBolt<T>, ICommitterTransactionalSpout<X>, IOpaquePartitionedTransactionalSpout<T>, IPartitionedTransactionalSpout<T>, IRichBolt, IRichSpout, IRichStateSpout, ITransactionalSpout<T>
- All Known Implementing Classes:
- BaseBasicBolt, BaseBatchBolt, BaseComponent, BaseOpaquePartitionedTransactionalSpout, BasePartitionedTransactionalSpout, BaseRichBolt, BaseRichSpout, BaseTransactionalBolt, BaseTransactionalSpout, BasicBoltExecutor, BatchBoltExecutor, BoltTracker, ClojureBolt, ClojureSpout, CoordinatedBolt, CountingBatchBolt, CountingCommitBolt, DRPCSpout, FeederSpout, IdentityBolt, JoinResult, KeyedCountingBatchBolt, KeyedCountingCommitterBolt, KeyedFairBolt, KeyedSummingBatchBolt, MemoryTransactionalSpout, OpaquePartitionedTransactionalSpoutExecutor, PartitionedTransactionalSpoutExecutor, PrepareRequest, ReturnResults, RichShellBolt, RichShellSpout, SpoutTracker, TestAggregatesCounter, TestConfBolt, TestGlobalCount, TestPlannerBolt, TestPlannerSpout, TestWordCounter, TestWordSpout, TransactionalSpoutBatchExecutor, TransactionalSpoutCoordinator, TupleCaptureBolt
public interface IComponent
- extends java.io.Serializable
Common methods for all possible components in a topology. This interface is used
when defining topologies using the Java API.
declareOutputFields
void declareOutputFields(OutputFieldsDeclarer declarer)
- Declare the output schema for all the streams of this topology.
- Parameters:
declarer
- this is used to declare output stream ids, output fields, and whether or not each output stream is a direct stream
getComponentConfiguration
java.util.Map<java.lang.String,java.lang.Object> getComponentConfiguration()
- Declare configuration specific to this component. Only a subset of the "topology.*" configs can
be overridden. The component configuration can be further overridden when constructing the
topology using
TopologyBuilder