Uses of Interface
org.apache.flink.statefun.sdk.io.IngressSpec

Packages that use IngressSpec

Package	Description
org.apache.flink.statefun.flink.core
org.apache.flink.statefun.flink.harness.io
org.apache.flink.statefun.flink.io.datastream
org.apache.flink.statefun.flink.io.kafka
org.apache.flink.statefun.flink.io.kinesis
org.apache.flink.statefun.flink.io.spi
org.apache.flink.statefun.sdk.kafka
org.apache.flink.statefun.sdk.kinesis.ingress
org.apache.flink.statefun.sdk.spi

Uses of IngressSpec in org.apache.flink.statefun.flink.core

Methods in org.apache.flink.statefun.flink.core that return types with arguments of type IngressSpec

Modifier and Type	Method and Description
java.util.Map<IngressIdentifier<?>,IngressSpec<?>>	StatefulFunctionsUniverse.ingress()

Methods in org.apache.flink.statefun.flink.core with parameters of type IngressSpec

Modifier and Type	Method and Description
<T> void	StatefulFunctionsUniverse.bindIngress(IngressSpec<T> spec)

Uses of IngressSpec in org.apache.flink.statefun.flink.harness.io

Classes in org.apache.flink.statefun.flink.harness.io that implement IngressSpec

Modifier and Type	Class and Description
class	SupplyingIngressSpec<T>

Uses of IngressSpec in org.apache.flink.statefun.flink.io.datastream

Classes in org.apache.flink.statefun.flink.io.datastream that implement IngressSpec

Modifier and Type	Class and Description
class	SourceFunctionSpec<T> An IngressSpec that can run any Apache Flink SourceFunction.

Uses of IngressSpec in org.apache.flink.statefun.flink.io.kafka

Methods in org.apache.flink.statefun.flink.io.kafka with parameters of type IngressSpec

Modifier and Type	Method and Description
<T> org.apache.flink.streaming.api.functions.source.SourceFunction<T>	KafkaSourceProvider.forSpec(IngressSpec<T> ingressSpec)

Uses of IngressSpec in org.apache.flink.statefun.flink.io.kinesis

Methods in org.apache.flink.statefun.flink.io.kinesis with parameters of type IngressSpec

Modifier and Type	Method and Description
<T> org.apache.flink.streaming.api.functions.source.SourceFunction<T>	KinesisSourceProvider.forSpec(IngressSpec<T> spec)

Uses of IngressSpec in org.apache.flink.statefun.flink.io.spi

Methods in org.apache.flink.statefun.flink.io.spi with parameters of type IngressSpec

Modifier and Type	Method and Description
<T> org.apache.flink.streaming.api.functions.source.SourceFunction<T>	SourceProvider.forSpec(IngressSpec<T> spec)

Uses of IngressSpec in org.apache.flink.statefun.sdk.kafka

Classes in org.apache.flink.statefun.sdk.kafka that implement IngressSpec

Modifier and Type	Class and Description
class	KafkaIngressSpec<T>

Uses of IngressSpec in org.apache.flink.statefun.sdk.kinesis.ingress

Classes in org.apache.flink.statefun.sdk.kinesis.ingress that implement IngressSpec

Modifier and Type	Class and Description
class	KinesisIngressSpec<T>

Uses of IngressSpec in org.apache.flink.statefun.sdk.spi

Methods in org.apache.flink.statefun.sdk.spi with parameters of type IngressSpec

Modifier and Type	Method and Description
<T> void	StatefulFunctionModule.Binder.bindIngress(IngressSpec<T> spec) Binds an IngressSpec to the Stateful Functions application.