org.apache.flink.statefun.flink.datastream

Class StatefulFunctionEgressStreams

java.lang.Object

org.apache.flink.statefun.flink.datastream.StatefulFunctionEgressStreams

public final class StatefulFunctionEgressStreams
extends java.lang.Object

StatefulFunctionEgressStreams - this class holds a handle for every egress stream defined via StatefulFunctionDataStreamBuilder.withEgressId(EgressIdentifier). see getDataStreamForEgressId(EgressIdentifier).

Method Summary

Modifier and Type	Method and Description
<T> org.apache.flink.streaming.api.datastream.DataStream<T>	getDataStreamForEgressId(EgressIdentifier<T> id) Returns the DataStream that represents a stateful functions egress for an EgressIdentifier.

Methods inherited from class java.lang.Object

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

Method Detail

getDataStreamForEgressId

public <T> org.apache.flink.streaming.api.datastream.DataStream<T> getDataStreamForEgressId(EgressIdentifier<T> id)

Returns the DataStream that represents a stateful functions egress for an EgressIdentifier.

Messages that are sent to an egress with the supplied id, (via Context.send(EgressIdentifier, Object)) would result in the DataStream returned from that method.

Type Parameters:

T - the egress message type.

Parameters:

id - the egress id, as provided to StatefulFunctionDataStreamBuilder.withEgressId(EgressIdentifier).

Returns:

a data stream that represents messages sent to the provided egress.