Package org.apache.storm.trident.spout

# Interface IPartitionedTridentSpout.Coordinator<PartitionsT>

All Known Implementing Classes:
  `KafkaTridentSpoutCoordinator`

Enclosing interface:
  IPartitionedTridentSpout<PartitionsT,PartitionT extends ISpoutPartition,T>

public static interface IPartitionedTridentSpout.Coordinator<PartitionsT>

- ## Method Summary

  Modifier and Type
  Method
  Description
  `void`
  `close()`
  `PartitionsT`
  `getPartitionsForBatch()`
  Return the partitions currently in the source of data.
  `boolean`
  `isReady(long txid)`

- ## Method Details

  - ### getPartitionsForBatch

    PartitionsT getPartitionsForBatch()
    Return the partitions currently in the source of data. The idea is is that if a new partition is added and a prior transaction is replayed, it doesn't emit tuples for the new partition because it knows what partitions were in that transaction.

  - ### isReady

    boolean isReady(long txid)

  - ### close

    void close()