org.apache.flink.statefun.sdk.kinesis.egress

Class EgressRecord

java.lang.Object

org.apache.flink.statefun.sdk.kinesis.egress.EgressRecord

public final class EgressRecord
extends java.lang.Object

A record to be written to AWS Kinesis.

Nested Class Summary

Nested Classes

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

Method Summary

Modifier and Type	Method and Description
byte[]	getData()
java.lang.String	getExplicitHashKey()
java.lang.String	getPartitionKey()
java.lang.String	getStream()
static EgressRecord.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 EgressRecord.Builder newBuilder()

Returns:

A builder for a EgressRecord.

getData

public byte[] getData()

Returns:

data bytes to write

getStream

public java.lang.String getStream()

Returns:

target AWS Kinesis stream to write to.

getPartitionKey

public java.lang.String getPartitionKey()

Returns:

partition key to use when writing the record to AWS Kinesis.

getExplicitHashKey

@Nullable
public java.lang.String getExplicitHashKey()

Returns:

explicit hash key to use when writing the record to AWS Kinesis.