org.apache.flink.statefun.sdk.java.message

Class EgressMessageBuilder

java.lang.Object

org.apache.flink.statefun.sdk.java.message.EgressMessageBuilder

public final class EgressMessageBuilder
extends java.lang.Object

A Custom EgressMessage builder.

To use {code Kafka} specific builder please use KafkaEgressMessage. To use {code Kinesis} specific egress please use KinesisEgress.

Use this builder if you need to send message to a custom egress defined via the embedded SDK.

Method Summary

Modifier and Type	Method and Description
EgressMessage	build()
static EgressMessageBuilder	forEgress(TypeName targetEgress)
<T> EgressMessageBuilder	withCustomType(Type<T> customType, T element)
EgressMessageBuilder	withValue(boolean value)
EgressMessageBuilder	withValue(double value)
EgressMessageBuilder	withValue(float value)
EgressMessageBuilder	withValue(int value)
EgressMessageBuilder	withValue(long value)
EgressMessageBuilder	withValue(java.lang.String value)

Methods inherited from class java.lang.Object

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

Method Detail

forEgress

public static EgressMessageBuilder forEgress(TypeName targetEgress)

withValue

public EgressMessageBuilder withValue(long value)

withValue

public EgressMessageBuilder withValue(int value)

withValue

public EgressMessageBuilder withValue(boolean value)

withValue

public EgressMessageBuilder withValue(java.lang.String value)

withValue

public EgressMessageBuilder withValue(float value)

withValue

public EgressMessageBuilder withValue(double value)

withCustomType

public <T> EgressMessageBuilder withCustomType(Type<T> customType,
                                               T element)

build

public EgressMessage build()