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

Class KinesisStreamShard

java.lang.Object

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

All Implemented Interfaces:

Serializable

Deprecated.

Will be remove in a future version in favor of StreamShardHandle.

@Deprecated
 @Internal
public class KinesisStreamShard
extends Object
implements Serializable

A legacy serializable representation of a AWS Kinesis Stream shard. It is basically a wrapper class around the information provided along with Shard.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
KinesisStreamShard(String streamName, com.amazonaws.services.kinesis.model.Shard shard) Deprecated. Create a new KinesisStreamShard.

Method Summary

Modifier and Type	Method and Description
static StreamShardMetadata	convertToStreamShardMetadata(KinesisStreamShard kinesisStreamShard) Deprecated. Utility function to convert KinesisStreamShard into the new StreamShardMetadata model.
boolean	equals(Object obj) Deprecated.
com.amazonaws.services.kinesis.model.Shard	getShard() Deprecated.
String	getStreamName() Deprecated.
int	hashCode() Deprecated.
boolean	isClosed() Deprecated.
String	toString() Deprecated.

Methods inherited from class java.lang.Object

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

Constructor Detail

KinesisStreamShard

public KinesisStreamShard(String streamName,
                          com.amazonaws.services.kinesis.model.Shard shard)

Deprecated.

Create a new KinesisStreamShard.

Parameters:

streamName - the name of the Kinesis stream that this shard belongs to

shard - the actual AWS Shard instance that will be wrapped within this KinesisStreamShard

Method Detail

getStreamName

public String getStreamName()

Deprecated.

isClosed

public boolean isClosed()

Deprecated.

getShard

public com.amazonaws.services.kinesis.model.Shard getShard()

Deprecated.

toString

public String toString()

Deprecated.

Overrides:

toString in class Object

equals

public boolean equals(Object obj)

Deprecated.

Overrides:

equals in class Object

hashCode

public int hashCode()

Deprecated.

Overrides:

hashCode in class Object

convertToStreamShardMetadata

public static StreamShardMetadata convertToStreamShardMetadata(KinesisStreamShard kinesisStreamShard)

Deprecated.

Utility function to convert KinesisStreamShard into the new StreamShardMetadata model.

Parameters:

kinesisStreamShard - the KinesisStreamShard to be converted

Returns:

the converted StreamShardMetadata