org.apache.flink.streaming.connectors.kinesis.model

Class StreamShardMetadata

java.lang.Object

org.apache.flink.streaming.connectors.kinesis.model.StreamShardMetadata

All Implemented Interfaces:

Serializable

@Internal
public class StreamShardMetadata
extends Object
implements Serializable

A serializable representation of a AWS Kinesis Stream shard. It is basically a wrapper class around the information disintegrated from Shard and its nested classes. The disintegration is required to avoid being locked-in to a specific AWS SDK version in order to maintain the consumer's state backwards compatibility.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	StreamShardMetadata.EquivalenceWrapper An equivalence wrapper that only checks for the stream name and shard id for equality.

Constructor Summary

Constructors

Constructor and Description
StreamShardMetadata()

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object obj)
String	getAdjacentParentShardId()
String	getEndingHashKey()
String	getEndingSequenceNumber()
String	getParentShardId()
String	getShardId()
String	getStartingHashKey()
String	getStartingSequenceNumber()
String	getStreamName()
int	hashCode()
void	setAdjacentParentShardId(String adjacentParentShardId)
void	setEndingHashKey(String endingHashKey)
void	setEndingSequenceNumber(String endingSequenceNumber)
void	setParentShardId(String parentShardId)
void	setShardId(String shardId)
void	setStartingHashKey(String startingHashKey)
void	setStartingSequenceNumber(String startingSequenceNumber)
void	setStreamName(String streamName)
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

StreamShardMetadata

public StreamShardMetadata()

Method Detail

setStreamName

public void setStreamName(String streamName)

setShardId

public void setShardId(String shardId)

setParentShardId

public void setParentShardId(String parentShardId)

setAdjacentParentShardId

public void setAdjacentParentShardId(String adjacentParentShardId)

setStartingHashKey

public void setStartingHashKey(String startingHashKey)

setEndingHashKey

public void setEndingHashKey(String endingHashKey)

setStartingSequenceNumber

public void setStartingSequenceNumber(String startingSequenceNumber)

setEndingSequenceNumber

public void setEndingSequenceNumber(String endingSequenceNumber)

getStreamName

public String getStreamName()

getShardId

public String getShardId()

getParentShardId

public String getParentShardId()

getAdjacentParentShardId

public String getAdjacentParentShardId()

getStartingHashKey

public String getStartingHashKey()

getEndingHashKey

public String getEndingHashKey()

getStartingSequenceNumber

public String getStartingSequenceNumber()

getEndingSequenceNumber

public String getEndingSequenceNumber()

toString

public String toString()

Overrides:

toString in class Object

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object