software.amazon.kinesis.coordinator.streamInfo

Class StreamInfo

java.lang.Object

software.amazon.kinesis.coordinator.CoordinatorState

software.amazon.kinesis.coordinator.streamInfo.StreamInfo

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
static String	ENTITY_TYPE_ATTRIBUTE_NAME
static String	STREAM_ID_ATTRIBUTE_NAME

Fields inherited from class software.amazon.kinesis.coordinator.CoordinatorState

COORDINATOR_STATE_TABLE_HASH_KEY_ATTRIBUTE_NAME, entityType, LEADER_HASH_KEY

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)
HashMap<String,software.amazon.awssdk.services.dynamodb.model.AttributeValue>	serialize()

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

ENTITY_TYPE

public static final String ENTITY_TYPE

See Also:

Constant Field Values

Constructor Detail

StreamInfo

public StreamInfo(String key,
                  String streamId)

Method Detail

serialize

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

deserialize

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

multiStreamLeaseKeyToStreamIdentifier

public static String multiStreamLeaseKeyToStreamIdentifier(String multiStreamLeaseKey)