org.apache.storm.eventhubs.trident

Class Coordinator

java.lang.Object

org.apache.storm.eventhubs.trident.Coordinator

All Implemented Interfaces:

IOpaquePartitionedTridentSpout.Coordinator<Partitions>, IPartitionedTridentSpout.Coordinator<Partitions>

public class Coordinator
extends Object
implements IPartitionedTridentSpout.Coordinator<Partitions>, IOpaquePartitionedTridentSpout.Coordinator<Partitions>

Constructor Summary

Constructors

Constructor and Description
Coordinator(EventHubSpoutConfig spoutConfig)

Method Summary

Modifier and Type	Method and Description
void	close()
Partitions	getPartitionsForBatch() Return the partitions currently in the source of data.
boolean	isReady(long txid) Indicates whether this coordinator is ready to commit the given transaction.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Coordinator

public Coordinator(EventHubSpoutConfig spoutConfig)

Method Detail

close

public void close()

Specified by:

close in interface IOpaquePartitionedTridentSpout.Coordinator<Partitions>

Specified by:

close in interface IPartitionedTridentSpout.Coordinator<Partitions>

getPartitionsForBatch

public Partitions getPartitionsForBatch()

Description copied from interface: IPartitionedTridentSpout.Coordinator

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.

Specified by:

getPartitionsForBatch in interface IOpaquePartitionedTridentSpout.Coordinator<Partitions>

Specified by:

getPartitionsForBatch in interface IPartitionedTridentSpout.Coordinator<Partitions>

Returns:

The partitions for the following batches.

isReady

public boolean isReady(long txid)

Description copied from interface: IOpaquePartitionedTridentSpout.Coordinator

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.

Specified by:

isReady in interface IOpaquePartitionedTridentSpout.Coordinator<Partitions>

Specified by:

isReady in interface IPartitionedTridentSpout.Coordinator<Partitions>

Parameters:

txid - The transaction id

Returns:

true if this coordinator is ready to commit, false otherwise.