org.apache.flink.statefun.sdk.kinesis.ingress

Class IngressRecord

java.lang.Object

org.apache.flink.statefun.sdk.kinesis.ingress.IngressRecord

public final class IngressRecord
extends java.lang.Object

A record consumed from AWS Kinesis.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	IngressRecord.Builder Builder for IngressRecord.

Method Summary

Modifier and Type	Method and Description
long	getApproximateArrivalTimestamp()
byte[]	getData()
java.lang.String	getPartitionKey()
java.lang.String	getSequenceNumber()
java.lang.String	getShardId()
java.lang.String	getStream()
static IngressRecord.Builder	newBuilder()

Methods inherited from class java.lang.Object

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

Method Detail

newBuilder

public static IngressRecord.Builder newBuilder()

Returns:

A builder for a IngressRecord.

getData

public byte[] getData()

Returns:

consumed data bytes

getStream

public java.lang.String getStream()

Returns:

source AWS Kinesis stream

getShardId

public java.lang.String getShardId()

Returns:

source AWS Kinesis stream shard

getPartitionKey

public java.lang.String getPartitionKey()

Returns:

attached partition key

getSequenceNumber

public java.lang.String getSequenceNumber()

Returns:

sequence number of the consumed record

getApproximateArrivalTimestamp

public long getApproximateArrivalTimestamp()

Returns:

approximate arrival timestamp (ingestion time at AWS Kinesis) of the consumed record