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

Class KafkaEgressMessage

java.lang.Object

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

public final class KafkaEgressMessage
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	KafkaEgressMessage.Builder

Constructor Summary

Constructors

Constructor and Description
KafkaEgressMessage()

Method Summary

Modifier and Type	Method and Description
static KafkaEgressMessage.Builder	forEgress(TypeName targetEgressId)

Methods inherited from class java.lang.Object

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

Constructor Detail

KafkaEgressMessage

public KafkaEgressMessage()

Method Detail

forEgress

public static KafkaEgressMessage.Builder forEgress(TypeName targetEgressId)