software.amazon.kinesis.coordinator.streamInfo

Class StreamInfo

java.lang.Object

software.amazon.kinesis.coordinator.CoordinatorState

software.amazon.kinesis.coordinator.streamInfo.StreamInfo

All Implemented Interfaces:

EntityDAO.Entity

public class StreamInfo
extends CoordinatorState

Data model of the StreamInfo state. This is used to track StreamMetadata

Field Summary

Fields

Modifier and Type	Field and Description
static String	ENTITY_TYPE_ATTRIBUTE_NAME
static String	STREAM_ID_ATTRIBUTE_NAME

Constructor Summary

Constructors

Constructor and Description
StreamInfo(String key, String streamId)

Method Summary

Modifier and Type	Method and Description
static StreamInfo	deserialize(String key, Map<String,software.amazon.awssdk.services.dynamodb.model.AttributeValue> attributes)
static String	multiStreamLeaseKeyToStreamIdentifier(String multiStreamLeaseKey)
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 software.amazon.kinesis.coordinator.CoordinatorState

getDynamoUpdate, getEntityType

Methods inherited from class java.lang.Object

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

Field Detail

STREAM_ID_ATTRIBUTE_NAME

public static final String STREAM_ID_ATTRIBUTE_NAME

See Also:

Constant Field Values

ENTITY_TYPE_ATTRIBUTE_NAME

public static final String ENTITY_TYPE_ATTRIBUTE_NAME

See Also:

Constant Field Values

Constructor Detail

StreamInfo

public StreamInfo(String key,
                  String streamId)

Method Detail

serialize

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

Description copied from class: CoordinatorState

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.

Overrides:

serialize in class CoordinatorState

Returns:

map of attribute name to AttributeValue for DynamoDB storage

deserialize

public static StreamInfo deserialize(String key,
                                     Map<String,software.amazon.awssdk.services.dynamodb.model.AttributeValue> attributes)

multiStreamLeaseKeyToStreamIdentifier

public static String multiStreamLeaseKeyToStreamIdentifier(String multiStreamLeaseKey)