org.apache.flink.statefun.sdk.io

Interface EgressSpec<T>

Type Parameters:

T - the type of messages consumed by this egress.

All Known Implementing Classes:

ConsumingEgressSpec, KafkaEgressSpec, KinesisEgressSpec, SinkFunctionSpec

public interface EgressSpec<T>

Complete specification for an egress, containing of the egress' EgressIdentifier and the EgressType. This fully defines an egress within a Stateful Functions application.

This serves as a "logical" representation of an output sink that stateful functions within an application can send messages to. Under the scenes, the system translates this to a physical runtime-specific representation corresponding to the specified EgressType.

Method Summary

Modifier and Type	Method and Description
EgressIdentifier<T>	id() Returns the unique identifier of the egress.
EgressType	type() Returns the type of the egress.

Method Detail

id

EgressIdentifier<T> id()

Returns the unique identifier of the egress.

Returns:

the unique identifier of the egress.

type

EgressType type()

Returns the type of the egress.

Returns:

the type of the egress.