| Package | Description |
|---|---|
| software.amazon.kinesis.worker.metricstats | |
| software.amazon.kinesis.worker.metricstats.delegate |
| Modifier and Type | Class and Description |
|---|---|
static class |
WorkerMetricStats.LeaseTableWorkerMetricStats
Schema for lease table uses "leaseKey" as the partition key.
|
static class |
WorkerMetricStats.LegacyWorkerMetricStats
Schema for worker stats table uses "wid" as the partition key.
|
| Modifier and Type | Method and Description |
|---|---|
List<WorkerMetricStats> |
WorkerMetricStatsDAO.getAllWorkerMetricStats()
Get all worker metric stats by combining results from both delegates.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
WorkerMetricStatsDAO.deleteMetrics(WorkerMetricStats workerMetrics)
Delete the worker metric stats entry with a conditional check on lastUpdateTime.
|
void |
WorkerMetricStatsDAO.updateMetrics(WorkerMetricStats workerMetrics)
Update (or create) the worker metric stats for a given worker.
|
| Modifier and Type | Class and Description |
|---|---|
class |
WorkerMetricStatsDAODelegate<T extends WorkerMetricStats>
Data Access Object to abstract accessing
WorkerMetricStats from
the DDB table it is stored in. |
| Modifier and Type | Method and Description |
|---|---|
abstract List<WorkerMetricStats> |
WorkerMetricStatsDAODelegate.getAllWorkerMetricStats()
Retrieve all worker metric stats entries from the backing table
|
List<WorkerMetricStats> |
LegacyTableWorkerMetricStatsDAODelegate.getAllWorkerMetricStats()
Retrieve all worker metric stats entries from the backing table.
|
List<WorkerMetricStats> |
LeaseTableWorkerMetricStatsDAODelegate.getAllWorkerMetricStats()
Retrieve all worker metric stats entries from the backing table, filtered by
entityType = WORKER_METRIC_STATS. |
| Modifier and Type | Method and Description |
|---|---|
boolean |
WorkerMetricStatsDAODelegate.deleteMetrics(WorkerMetricStats workerMetrics)
Delete the worker metric stats entry with a conditional check on lastUpdateTime.
|
boolean |
LegacyTableWorkerMetricStatsDAODelegate.deleteMetrics(WorkerMetricStats workerMetrics) |
protected abstract T |
WorkerMetricStatsDAODelegate.toEntity(WorkerMetricStats workerMetrics)
Convert a base
WorkerMetricStats into the concrete bean type T. |
protected WorkerMetricStats.LegacyWorkerMetricStats |
LegacyTableWorkerMetricStatsDAODelegate.toEntity(WorkerMetricStats workerMetrics)
For the legacy table, simply cast to LegacyWorkerMetricStats using the builder.
|
protected WorkerMetricStats.LeaseTableWorkerMetricStats |
LeaseTableWorkerMetricStatsDAODelegate.toEntity(WorkerMetricStats workerMetrics)
Convert a base
WorkerMetricStats into a WorkerMetricStats.LeaseTableWorkerMetricStats
so the Enhanced Client maps workerId to the leaseKey attribute. |
void |
WorkerMetricStatsDAODelegate.updateMetrics(WorkerMetricStats workerMetrics)
Update (or create) the worker metric stats for a given worker.
|
void |
LegacyTableWorkerMetricStatsDAODelegate.updateMetrics(WorkerMetricStats workerMetrics) |
void |
LeaseTableWorkerMetricStatsDAODelegate.updateMetrics(WorkerMetricStats workerMetrics) |
Copyright © 2026. All rights reserved.