Package org.apache.beam.sdk.io.aws2.kinesis

Class KinesisRecord

java.lang.Object

org.apache.beam.sdk.io.aws2.kinesis.KinesisRecord

public class KinesisRecord
extends Object

KinesisClientRecord enhanced with utility methods.

Constructor Summary

Constructors

Constructor	Description
KinesisRecord(ByteBuffer data, String sequenceNumber, long subSequenceNumber, String partitionKey, Instant approximateArrivalTimestamp, Instant readTime, String streamName, String shardId)
KinesisRecord(software.amazon.kinesis.retrieval.KinesisClientRecord record, String streamName, String shardId)

Method Summary

Modifier and Type	Method	Description
boolean	equals(@Nullable Object obj)
Instant	getApproximateArrivalTimestamp()	Returns the approximate time that the record was inserted into the stream.
ByteBuffer	getData()	Returns the data blob.
byte[]	getDataAsBytes()
software.amazon.kinesis.retrieval.kpl.ExtendedSequenceNumber	getExtendedSequenceNumber()
String	getPartitionKey()
Instant	getReadTime()
String	getSequenceNumber()	Returns the unique identifier of the record within its shard.
String	getShardId()
String	getStreamName()
long	getSubSequenceNumber()
byte[]	getUniqueId()	Returns the unique identifier of the record based on its position in the stream.
int	hashCode()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Details

KinesisRecord

public KinesisRecord(software.amazon.kinesis.retrieval.KinesisClientRecord record,
 String streamName,
 String shardId)

KinesisRecord

public KinesisRecord(ByteBuffer data,
 String sequenceNumber,
 long subSequenceNumber,
 String partitionKey,
 Instant approximateArrivalTimestamp,
 Instant readTime,
 String streamName,
 String shardId)

Method Details

getExtendedSequenceNumber

public software.amazon.kinesis.retrieval.kpl.ExtendedSequenceNumber getExtendedSequenceNumber()

getUniqueId

public byte[] getUniqueId()

Returns the unique identifier of the record based on its position in the stream.

getReadTime

public Instant getReadTime()

getStreamName

public String getStreamName()

getShardId

public String getShardId()

getDataAsBytes

public byte[] getDataAsBytes()

equals

public boolean equals(@Nullable Object obj)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object

getSubSequenceNumber

public long getSubSequenceNumber()

getSequenceNumber

public String getSequenceNumber()

Returns the unique identifier of the record within its shard.

getApproximateArrivalTimestamp

public Instant getApproximateArrivalTimestamp()

Returns the approximate time that the record was inserted into the stream.

getData

public ByteBuffer getData()

Returns the data blob.

getPartitionKey

public String getPartitionKey()