Uses of Interface
software.amazon.kinesis.coordinator.assignment.LAMDataManager

Packages that use LAMDataManager

Package	Description
software.amazon.kinesis.coordinator.assignment

Uses of LAMDataManager in software.amazon.kinesis.coordinator.assignment

Classes in software.amazon.kinesis.coordinator.assignment that implement LAMDataManager

Modifier and Type

Class and Description

class

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