software.amazon.kinesis.leader

Class MigrationAdaptiveLeaderDecider

java.lang.Object

software.amazon.kinesis.leader.MigrationAdaptiveLeaderDecider

All Implemented Interfaces:

LeaderDecider

@ThreadSafe
public class MigrationAdaptiveLeaderDecider
extends Object
implements LeaderDecider

MigrationAdaptiveLeaderDecider that wraps around the actual LeaderDecider which can dynamically change based on the MigrationStateMachine.

Field Summary

Fields inherited from interface software.amazon.kinesis.coordinator.LeaderDecider

METRIC_OPERATION_LEADER_DECIDER, METRIC_OPERATION_LEADER_DECIDER_IS_LEADER

Constructor Summary

Constructors

Constructor and Description
MigrationAdaptiveLeaderDecider(MetricsFactory metricsFactory)

Method Summary

Modifier and Type	Method and Description
Boolean	isLeader(String workerId) Method invoked to check the given workerId corresponds to one of the workers designated to execute shard-syncs periodically.
void	shutdown() Can be invoked, if needed, to shutdown any clients/thread-pools being used in the LeaderDecider implementation.
void	updateLeaderDecider(LeaderDecider leaderDecider)

Methods inherited from class java.lang.Object

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

Methods inherited from interface software.amazon.kinesis.coordinator.LeaderDecider

initialize, releaseLeadershipIfHeld

Constructor Detail

MigrationAdaptiveLeaderDecider

public MigrationAdaptiveLeaderDecider(MetricsFactory metricsFactory)

Method Detail

isLeader

public Boolean isLeader(String workerId)

Description copied from interface: LeaderDecider

Method invoked to check the given workerId corresponds to one of the workers designated to execute shard-syncs periodically.

Specified by:

isLeader in interface LeaderDecider

Parameters:

workerId - ID of the worker

Returns:

True if the worker with ID workerId can execute shard-sync. False otherwise.

updateLeaderDecider

public void updateLeaderDecider(LeaderDecider leaderDecider)

shutdown

public void shutdown()

Description copied from interface: LeaderDecider

Can be invoked, if needed, to shutdown any clients/thread-pools being used in the LeaderDecider implementation.

Specified by:

shutdown in interface LeaderDecider