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()