org.apache.flink.statefun.sdk.java.io

Class KafkaEgressMessage.Builder

java.lang.Object

org.apache.flink.statefun.sdk.java.io.KafkaEgressMessage.Builder

Enclosing class:

KafkaEgressMessage

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

Method Summary

Modifier and Type	Method and Description
EgressMessage	build()
KafkaEgressMessage.Builder	withKey(byte[] key)
KafkaEgressMessage.Builder	withKey(Slice slice)
<T> KafkaEgressMessage.Builder	withKey(Type<T> type, T value)
KafkaEgressMessage.Builder	withTopic(Slice topic)
KafkaEgressMessage.Builder	withTopic(java.lang.String topic)
KafkaEgressMessage.Builder	withUtf8Key(java.lang.String key)
KafkaEgressMessage.Builder	withUtf8Value(java.lang.String value)
KafkaEgressMessage.Builder	withValue(byte[] value)
KafkaEgressMessage.Builder	withValue(Slice slice)
<T> KafkaEgressMessage.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

Method Detail

withTopic

public KafkaEgressMessage.Builder withTopic(java.lang.String topic)

withTopic

public KafkaEgressMessage.Builder withTopic(Slice topic)

withUtf8Key

public KafkaEgressMessage.Builder withUtf8Key(java.lang.String key)

withKey

public KafkaEgressMessage.Builder withKey(byte[] key)

withKey

public KafkaEgressMessage.Builder withKey(Slice slice)

withKey

public <T> KafkaEgressMessage.Builder withKey(Type<T> type,
                                              T value)

withUtf8Value

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

withValue

public KafkaEgressMessage.Builder withValue(Slice slice)

withValue

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

withValue

public KafkaEgressMessage.Builder withValue(byte[] value)

build

public EgressMessage build()