Class KafkaTridentSpoutCoordinator<K,V> 
java.lang.Object
org.apache.storm.kafka.spout.trident.KafkaTridentSpoutCoordinator<K,V> 
- All Implemented Interfaces:
- Serializable,- IOpaquePartitionedTridentSpout.Coordinator<List<Map<String,,- Object>>> - IPartitionedTridentSpout.Coordinator<List<Map<String,- Object>>> 
public class KafkaTridentSpoutCoordinator<K,V> 
extends Object
implements IOpaquePartitionedTridentSpout.Coordinator<List<Map<String,Object>>>, IPartitionedTridentSpout.Coordinator<List<Map<String,Object>>>, Serializable  
- See Also:
- 
Field SummaryFields
- 
Constructor SummaryConstructorsConstructorDescriptionKafkaTridentSpoutCoordinator(KafkaTridentSpoutConfig<K, V> kafkaSpoutConfig) Creates a new coordinator based on the given spout config.
- 
Method Summary
- 
Field Details- 
TIMER_DELAY_MSpublic static final long TIMER_DELAY_MS- See Also:
 
 
- 
- 
Constructor Details- 
KafkaTridentSpoutCoordinatorCreates a new coordinator based on the given spout config.- Parameters:
- kafkaSpoutConfig- The spout config to use
 
 
- 
- 
Method Details- 
isReadypublic boolean isReady(long txid) Description copied from interface:IOpaquePartitionedTridentSpout.CoordinatorIndicates 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.- Specified by:
- isReadyin interface- IOpaquePartitionedTridentSpout.Coordinator<K>
- Specified by:
- isReadyin interface- IPartitionedTridentSpout.Coordinator<K>
- Parameters:
- txid- The transaction id
- Returns:
- true if this coordinator is ready to commit, false otherwise.
 
- 
getPartitionsForBatchDescription copied from interface:IOpaquePartitionedTridentSpout.CoordinatorGets the partitions for the following batches. The emitter will be asked to refresh partitions when this value changes.- Specified by:
- getPartitionsForBatchin interface- IOpaquePartitionedTridentSpout.Coordinator<K>
- Specified by:
- getPartitionsForBatchin interface- IPartitionedTridentSpout.Coordinator<K>
- Returns:
- The partitions for the following batches.
 
- 
closepublic void close()- Specified by:
- closein interface- IOpaquePartitionedTridentSpout.Coordinator<K>
- Specified by:
- closein interface- IPartitionedTridentSpout.Coordinator<K>
 
- 
toString
 
-