| Modifier and Type | Method and Description |
|---|---|
CoordinatorState |
CoordinatorStateDAO.getCoordinatorState(@NonNull String key)
Get a single
CoordinatorState by key. |
| Modifier and Type | Method and Description |
|---|---|
List<CoordinatorState> |
CoordinatorStateDAO.listCoordinatorState()
List all coordinator states.
|
List<CoordinatorState> |
CoordinatorStateDAO.listCoordinatorStateByEntityType(EntityType.CoordinatorStateType entityType)
List coordinator states by entity type.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
CoordinatorStateDAO.createCoordinatorStateIfNotExists(@NonNull CoordinatorState state)
Create a coordinator state if it does not already exist.
|
boolean |
CoordinatorStateDAO.updateCoordinatorStateWithExpectation(@NonNull CoordinatorState state,
Map<String,software.amazon.awssdk.services.dynamodb.model.ExpectedAttributeValue> expectations)
Update a coordinator state with expectations.
|
| Modifier and Type | Method and Description |
|---|---|
CoordinatorState |
CoordinatorStateDAODelegate.fromDynamoRecord(Map<String,software.amazon.awssdk.services.dynamodb.model.AttributeValue> dynamoRecord) |
CoordinatorState |
LegacyTableCoordinatorStateDAODelegate.getCoordinatorState(String key) |
CoordinatorState |
CoordinatorStateDAODelegate.getCoordinatorState(@NonNull String key) |
| Modifier and Type | Method and Description |
|---|---|
List<CoordinatorState> |
LegacyTableCoordinatorStateDAODelegate.listCoordinatorState() |
List<CoordinatorState> |
CoordinatorStateDAODelegate.listCoordinatorState()
List all the
CoordinatorState from the DDB table synchronously |
List<CoordinatorState> |
LegacyTableCoordinatorStateDAODelegate.listCoordinatorStateByEntityType(EntityType.CoordinatorStateType entityType) |
List<CoordinatorState> |
CoordinatorStateDAODelegate.listCoordinatorStateByEntityType(EntityType.CoordinatorStateType entityType)
List all the
CoordinatorState from the DDB table synchronously |
| Modifier and Type | Method and Description |
|---|---|
boolean |
LegacyTableCoordinatorStateDAODelegate.createCoordinatorStateIfNotExists(CoordinatorState state) |
boolean |
CoordinatorStateDAODelegate.createCoordinatorStateIfNotExists(CoordinatorState state)
Create a new
CoordinatorState if it does not exist. |
software.amazon.awssdk.services.dynamodb.model.TransactWriteItem |
CoordinatorStateDAODelegate.createTransactPut(CoordinatorState state)
Creates a
TransactWriteItem that performs a conditional Put (item must not exist)
for the given coordinator state into this delegate's table. |
Map<String,software.amazon.awssdk.services.dynamodb.model.AttributeValue> |
CoordinatorStateDAODelegate.toTransactRecord(CoordinatorState state)
Converts a
CoordinatorState to its full DDB item representation including the
partition key. |
boolean |
LegacyTableCoordinatorStateDAODelegate.updateCoordinatorStateWithExpectation(CoordinatorState state,
Map<String,software.amazon.awssdk.services.dynamodb.model.ExpectedAttributeValue> expectations) |
boolean |
CoordinatorStateDAODelegate.updateCoordinatorStateWithExpectation(@NonNull CoordinatorState state,
Map<String,software.amazon.awssdk.services.dynamodb.model.ExpectedAttributeValue> expectations)
Update fields of the given coordinator state in DynamoDB.
|
| 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.
|
Copyright © 2026. All rights reserved.