Package org.apache.storm.trident.spout

# Interface IPartitionedTridentSpout<PartitionsT,PartitionT extends ISpoutPartition,T>

All Superinterfaces:
  `ITridentDataSource`, `Serializable`

All Known Implementing Classes:
  `KafkaTridentSpoutTransactional`

public interface IPartitionedTridentSpout<PartitionsT,PartitionT extends ISpoutPartition,T> extends ITridentDataSource
This interface defines a transactional spout that reads its tuples from a partitioned set of brokers. It automates the storing of metadata for each partition to ensure that the same batch is always emitted for the same transaction id. The partition metadata is stored in Zookeeper.

- ## Nested Class Summary

  Nested Classes
  Modifier and Type
  Interface
  Description
  `static interface`
  `IPartitionedTridentSpout.Coordinator<PartitionsT>`
  `static interface`
  `IPartitionedTridentSpout.Emitter<PartitionsT,PartitionT extends ISpoutPartition,X>`

- ## Method Summary

  Modifier and Type
  Method
  Description
  `Map<String,Object>`
  `getComponentConfiguration()`
  `IPartitionedTridentSpout.Coordinator<PartitionsT>`
  `getCoordinator(Map<String,Object> conf, TopologyContext context)`
  `IPartitionedTridentSpout.Emitter<PartitionsT,PartitionT,T>`
  `getEmitter(Map<String,Object> conf, TopologyContext context)`
  `Fields`
  `getOutputFields()`

- ## Method Details

  - ### getCoordinator

    IPartitionedTridentSpout.Coordinator<PartitionsT> getCoordinator(Map<String,Object> conf, TopologyContext context)

  - ### getEmitter

    IPartitionedTridentSpout.Emitter<PartitionsT,PartitionT,T> getEmitter(Map<String,Object> conf, TopologyContext context)

  - ### getComponentConfiguration

    Map<String,Object> getComponentConfiguration()

  - ### getOutputFields

    Fields getOutputFields()