KinesisEgressMessage.Builder (statefun-parent 3.4-SNAPSHOT API)

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

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`EgressMessage`	`build()`
`KinesisEgressMessage.Builder`	`withPartitionKey(byte[] key)`
`KinesisEgressMessage.Builder`	`withPartitionKey(Slice key)`
`KinesisEgressMessage.Builder`	`withStream(Slice stream)`
`KinesisEgressMessage.Builder`	`withStream(java.lang.String stream)`
`KinesisEgressMessage.Builder`	`withUtf8ExplicitHashKey(Slice utf8Slice)`
`KinesisEgressMessage.Builder`	`withUtf8ExplicitHashKey(java.lang.String value)`
`KinesisEgressMessage.Builder`	`withUtf8PartitionKey(java.lang.String key)`
`KinesisEgressMessage.Builder`	`withUtf8Value(java.lang.String value)`
`KinesisEgressMessage.Builder`	`withValue(byte[] value)`
`KinesisEgressMessage.Builder`	`withValue(Slice value)`
`<T> KinesisEgressMessage.Builder`	`withValue(Type<T> type, T value)`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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

public KinesisEgressMessage.Builder withStream(Slice stream)

public KinesisEgressMessage.Builder withUtf8PartitionKey(java.lang.String key)

public KinesisEgressMessage.Builder withPartitionKey(byte[] key)

public KinesisEgressMessage.Builder withPartitionKey(Slice key)

public KinesisEgressMessage.Builder withUtf8Value(java.lang.String value)

public KinesisEgressMessage.Builder withValue(byte[] value)

public KinesisEgressMessage.Builder withValue(Slice value)

public <T> KinesisEgressMessage.Builder withValue(Type<T> type,
                                                  T value)

public KinesisEgressMessage.Builder withUtf8ExplicitHashKey(java.lang.String value)

public KinesisEgressMessage.Builder withUtf8ExplicitHashKey(Slice utf8Slice)

Back to Apache Flink Website