| Modifier and Type | Class and Description |
|---|---|
class |
CoordinatorState
DataModel for CoordinatorState, this data model is used to store various state information required
for coordination across the KCL worker fleet.
|
| Modifier and Type | Class and Description |
|---|---|
class |
MigrationState
Data model of the Migration state.
|
class |
TableMigrationState
Data model of the TableMigration state.
|
| Modifier and Type | Class and Description |
|---|---|
class |
StreamInfo
Data model of the StreamInfo state.
|
| Modifier and Type | Class and Description |
|---|---|
class |
LeaderLock
Data model of the KCL Lock.
|
| Modifier and Type | Class and Description |
|---|---|
class |
Lease
This class contains data pertaining to a Lease.
|
class |
MultiStreamLease |
| Modifier and Type | Class and Description |
|---|---|
class |
WorkerMetricStats
DataModel for a WorkerMetric, this data model is used to store the current state of a Worker in terms of relevant
WorkerMetric(CPU, Memory, Network).
|
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.
|
Copyright © 2026. All rights reserved.