public static interface IOpaquePartitionedTridentSpout.Coordinator<PartitionsT>
Coordinator for batches. Trident will only begin committing once at least one coordinator is ready.
Modifier and Type | Method and Description |
---|---|
void |
close() |
PartitionsT |
getPartitionsForBatch()
Gets the partitions for the following batches.
|
boolean |
isReady(long txid)
Indicates whether this coordinator is ready to commit the given transaction.
|
boolean isReady(long txid)
Indicates whether this coordinator is ready to commit the given transaction. The master batch coordinator will only begin committing if at least one coordinator indicates it is ready to commit.
txid
- The transaction idPartitionsT getPartitionsForBatch()
Gets the partitions for the following batches. The emitter will be asked to refresh partitions when this value changes.
void close()
Copyright © 2022 The Apache Software Foundation. All rights reserved.