public static interface IOpaquePartitionedTridentSpout.Coordinator<Partitions>
Modifier and Type | Method and Description |
---|---|
void |
close() |
Partitions |
getPartitionsForBatch() |
boolean |
isReady(long txid) |
boolean isReady(long txid)
Partitions getPartitionsForBatch()
void close()
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.