IPartitionedTridentSpout.Coordinator (Storm 2.7.1 API)

All Known Implementing Classes:

KafkaTridentSpoutCoordinator

Enclosing interface:

IPartitionedTridentSpout<PartitionsT,PartitionT extends ISpoutPartition,T>
```
public static interface IPartitionedTridentSpout.Coordinator<PartitionsT>
```

Method Summary

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

- Method Detail
  - 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()
```