Uses of Class
org.apache.flink.statefun.sdk.io.IngressIdentifier

Packages that use IngressIdentifier

Package	Description
org.apache.flink.statefun.e2e.smoke.driver
org.apache.flink.statefun.flink.core
org.apache.flink.statefun.flink.harness
org.apache.flink.statefun.flink.harness.io
org.apache.flink.statefun.flink.io.common.json
org.apache.flink.statefun.flink.io.datastream
org.apache.flink.statefun.flink.io.kinesis.binders.ingress.v1
org.apache.flink.statefun.sdk.io
org.apache.flink.statefun.sdk.kafka
org.apache.flink.statefun.sdk.kinesis.ingress
org.apache.flink.statefun.sdk.spi

Uses of IngressIdentifier in org.apache.flink.statefun.e2e.smoke.driver

Fields in org.apache.flink.statefun.e2e.smoke.driver declared as IngressIdentifier

Modifier and Type	Field and Description
static IngressIdentifier<TypedValue>	Constants.IN

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

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

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

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

Modifier and Type	Method and Description
<T> void	StatefulFunctionsUniverse.bindIngressRouter(IngressIdentifier<T> ingressIdentifier, Router<T> router)

Uses of IngressIdentifier in org.apache.flink.statefun.flink.harness

Methods in org.apache.flink.statefun.flink.harness with parameters of type IngressIdentifier

Modifier and Type	Method and Description
<T> Harness	Harness.withFlinkSourceFunction(IngressIdentifier<T> identifier, org.apache.flink.streaming.api.functions.source.SourceFunction<T> supplier)
<T> Harness	Harness.withSupplyingIngress(IngressIdentifier<T> identifier, SerializableSupplier<T> supplier)

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

Methods in org.apache.flink.statefun.flink.harness.io that return IngressIdentifier

Modifier and Type	Method and Description
IngressIdentifier<T>	SupplyingIngressSpec.id()

Constructors in org.apache.flink.statefun.flink.harness.io with parameters of type IngressIdentifier

Constructor and Description
SupplyingIngressSpec(IngressIdentifier<T> id, SerializableSupplier<T> supplier, long productionDelayInMilliseconds)

Uses of IngressIdentifier in org.apache.flink.statefun.flink.io.common.json

Methods in org.apache.flink.statefun.flink.io.common.json that return IngressIdentifier

Modifier and Type	Method and Description
IngressIdentifier<com.google.protobuf.Message>	IngressIdentifierJsonDeserializer.deserialize(org.apache.flink.shaded.jackson2.com.fasterxml.jackson.core.JsonParser jsonParser, org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.DeserializationContext deserializationContext)

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

Methods in org.apache.flink.statefun.flink.io.datastream that return IngressIdentifier

Modifier and Type	Method and Description
IngressIdentifier<T>	SourceFunctionSpec.id()

Constructors in org.apache.flink.statefun.flink.io.datastream with parameters of type IngressIdentifier

Constructor and Description
SourceFunctionSpec(IngressIdentifier<T> id, org.apache.flink.streaming.api.functions.source.SourceFunction<T> delegate)

Uses of IngressIdentifier in org.apache.flink.statefun.flink.io.kinesis.binders.ingress.v1

Methods in org.apache.flink.statefun.flink.io.kinesis.binders.ingress.v1 that return IngressIdentifier

Modifier and Type	Method and Description
IngressIdentifier<com.google.protobuf.Message>	RoutableKinesisIngressSpec.id()

Uses of IngressIdentifier in org.apache.flink.statefun.sdk.io

Methods in org.apache.flink.statefun.sdk.io that return IngressIdentifier

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

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

Methods in org.apache.flink.statefun.sdk.kafka that return IngressIdentifier

Modifier and Type	Method and Description
IngressIdentifier<T>	KafkaIngressSpec.id()

Methods in org.apache.flink.statefun.sdk.kafka with parameters of type IngressIdentifier

Modifier and Type	Method and Description
static <T> KafkaIngressBuilder<T>	KafkaIngressBuilder.forIdentifier(IngressIdentifier<T> id)

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

Methods in org.apache.flink.statefun.sdk.kinesis.ingress that return IngressIdentifier

Modifier and Type	Method and Description
IngressIdentifier<T>	KinesisIngressSpec.id()

Methods in org.apache.flink.statefun.sdk.kinesis.ingress with parameters of type IngressIdentifier

Modifier and Type	Method and Description
static <T> KinesisIngressBuilder<T>	KinesisIngressBuilder.forIdentifier(IngressIdentifier<T> id)

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

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

Modifier and Type	Method and Description
<T> void	StatefulFunctionModule.Binder.bindIngressRouter(IngressIdentifier<T> id, Router<T> router) Binds a Router for a given ingress to the Stateful Functions application.