org.apache.flink.statefun.sdk.io

Interface IngressSpec<T>

Type Parameters:

T - the type of messages produced by this ingress.

All Known Implementing Classes:

KafkaIngressSpec, KinesisIngressSpec, SourceFunctionSpec, SupplyingIngressSpec

public interface IngressSpec<T>

Complete specification for an ingress, containing of the ingress' IngressIdentifier and the IngressType. This fully defines an ingress within a Stateful Functions application.

This serves as a "logical" representation of an input source for invoking stateful functions within an application. Under the scenes, the system translates this to a physical runtime-specific representation corresponding to the specified IngressType.

Method Summary

Modifier and Type	Method and Description
IngressIdentifier<T>	id() Returns the unique identifier of the ingress.
IngressType	type() Returns the type of the ingress.

Method Detail

id

IngressIdentifier<T> id()

Returns the unique identifier of the ingress.

Returns:

the unique identifier of the ingress.

type

IngressType type()

Returns the type of the ingress.

Returns:

the type of the ingress.