Package software.amazon.kinesis.coordinator.assignment

Interface Summary

Interface	Description
LAMDataManager	Manages data loading, validation, and cleanup for LeaseAssignmentManager.
LeaseAssignmentDecider

Class Summary

Class	Description
LAMDataSnapshot	Immutable snapshot of the data loaded by LAMDataManager for a single LeaseAssignmentManager assignment cycle.
LeaseAssignmentManager	Performs the LeaseAssignment for the application.
LeaseCountBasedLeaseAssignmentDecider	A lease assignment decider that distributes leases based on lease count balancing.
MigrationAwareLAMDataManager	Migration-aware implementation of LAMDataManager that encapsulates: Reading leases and worker metrics from the lease table (via EntityDAO) and optionally the legacy table (via WorkerMetricStatsDAO's legacy delegate) Filtering out invalid worker metrics (logging + emitting metrics) Filtering to only valid, non-expired worker metrics Async deletion of stale worker metrics (using the correct delegate based on origin) Computing and publishing TableMigrationSummary for migration state decisions
VarianceBasedLeaseAssignmentDecider	VarianceBasedLeaseAssignmentDecider This implementation of LeaseAssignmentDecider performs lease assignment by considering the WorkerMetricStats values of workers with respect to fleet level average of that WorkerMetricStats.