software.amazon.kinesis.coordinator

Class CoordinatorState

java.lang.Object

software.amazon.kinesis.coordinator.CoordinatorState

All Implemented Interfaces:

EntityDAO.Entity

Direct Known Subclasses:

LeaderLock, MigrationState, StreamInfo, TableMigrationState

public class CoordinatorState
extends Object
implements EntityDAO.Entity

DataModel for CoordinatorState, this data model is used to store various state information required for coordination across the KCL worker fleet. Therefore, the model follows a flexible schema. Subclasses override serialize() and getDynamoUpdate() to provide their specific serialization logic. The DAO delegate holds a registry of deserializers and uses polymorphic calls for serialize/update to avoid instanceof checks.

Field Summary

Fields

Modifier and Type	Field and Description
static String	ENTITY_TYPE_ATTRIBUTE_NAME

Constructor Summary

Constructors

Constructor and Description
CoordinatorState()

Method Summary

Modifier and Type	Method and Description
Map<String,software.amazon.awssdk.services.dynamodb.model.AttributeValueUpdate>	getDynamoUpdate() Produce an update map for DynamoDB UpdateItem operations.
EntityType	getEntityType() Returns the parent EntityType for this coordinator state entity.
Map<String,software.amazon.awssdk.services.dynamodb.model.AttributeValue>	serialize() Serialize this state's attributes into a map of DynamoDB attribute values.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

ENTITY_TYPE_ATTRIBUTE_NAME

public static final String ENTITY_TYPE_ATTRIBUTE_NAME

See Also:

Constant Field Values

Constructor Detail

CoordinatorState

public CoordinatorState()

Method Detail

getEntityType

public EntityType getEntityType()

Returns the parent EntityType for this coordinator state entity. Delegates to the EntityType.CoordinatorStateType#getEntityType() method.

Specified by:

getEntityType in interface EntityDAO.Entity

serialize

public Map<String,software.amazon.awssdk.services.dynamodb.model.AttributeValue> serialize()

Serialize this state's attributes into a map of DynamoDB attribute values. Includes the entityType attribute and any generic attributes. Subclasses should call super.serialize() and then add their own domain-specific fields.

Returns:

map of attribute name to AttributeValue for DynamoDB storage

getDynamoUpdate

public Map<String,software.amazon.awssdk.services.dynamodb.model.AttributeValueUpdate> getDynamoUpdate()

Produce an update map for DynamoDB UpdateItem operations. Subclasses should override this to provide their specific update logic. The base implementation converts all attributes to PUT updates.

Returns:

map of attribute name to AttributeValueUpdate for DynamoDB UpdateItem