public class Coordinator extends Object implements IPartitionedTridentSpout.Coordinator<Partitions>, IOpaquePartitionedTridentSpout.Coordinator<Partitions>
Constructor and Description |
---|
Coordinator(EventHubSpoutConfig spoutConfig) |
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.
|
public Coordinator(EventHubSpoutConfig spoutConfig)
public void close()
close
in interface IOpaquePartitionedTridentSpout.Coordinator<Partitions>
close
in interface IPartitionedTridentSpout.Coordinator<Partitions>
public Partitions getPartitionsForBatch()
IPartitionedTridentSpout.Coordinator
getPartitionsForBatch
in interface IOpaquePartitionedTridentSpout.Coordinator<Partitions>
getPartitionsForBatch
in interface IPartitionedTridentSpout.Coordinator<Partitions>
public boolean isReady(long txid)
IOpaquePartitionedTridentSpout.Coordinator
isReady
in interface IOpaquePartitionedTridentSpout.Coordinator<Partitions>
isReady
in interface IPartitionedTridentSpout.Coordinator<Partitions>
txid
- The transaction idCopyright © 2023 The Apache Software Foundation. All rights reserved.