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

Class EgressRecord.Builder

java.lang.Object

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

Enclosing class:

EgressRecord

public static final class EgressRecord.Builder
extends java.lang.Object

Builder for EgressRecord.

Method Summary

Modifier and Type	Method and Description
EgressRecord	build()
EgressRecord.Builder	withData(byte[] data)
EgressRecord.Builder	withExplicitHashKey(java.lang.String explicitHashKey)
EgressRecord.Builder	withPartitionKey(java.lang.String partitionKey)
EgressRecord.Builder	withStream(java.lang.String stream)

Methods inherited from class java.lang.Object

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

Method Detail

withData

public EgressRecord.Builder withData(byte[] data)

withStream

public EgressRecord.Builder withStream(java.lang.String stream)

withPartitionKey

public EgressRecord.Builder withPartitionKey(java.lang.String partitionKey)

withExplicitHashKey

public EgressRecord.Builder withExplicitHashKey(java.lang.String explicitHashKey)

build

public EgressRecord build()