software.amazon.kinesis.coordinator.migration

Class TableMigrationStatusProvider

java.lang.Object

software.amazon.kinesis.coordinator.migration.TableMigrationStatusProvider

@ThreadSafe
public class TableMigrationStatusProvider
extends Object

Provides the table migration status using which dependent classes will decide whether to read from Lease Table or Legacy table or both and merge the results. The methods and internal state is guarded for concurrent access to allow both all DAO layers to access the TableMode concurrently while it could be dynamically updated.

Constructor Summary

Constructors

Constructor and Description
TableMigrationStatusProvider()

Method Summary

Modifier and Type	Method and Description
boolean	dynamicModeChangeSupportNeeded() Specify whether both tables should be initialized to support dynamically changing table migration status.
TableMigrationStatus	getTableMigrationStatus() Provide the current table migration status in which KCL should access entities from DDB storage.

Methods inherited from class java.lang.Object

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

Constructor Detail

TableMigrationStatusProvider

public TableMigrationStatusProvider()

Method Detail

dynamicModeChangeSupportNeeded

public boolean dynamicModeChangeSupportNeeded()

Specify whether both tables should be initialized to support dynamically changing table migration status.

Returns:

true if table migration status can change dynamically false otherwise.

getTableMigrationStatus

public TableMigrationStatus getTableMigrationStatus()

Provide the current table migration status in which KCL should access entities from DDB storage. Returns UNKNOWN if not yet initialized.

Returns:

the current table migration status