Uses of Class
org.apache.flink.statefun.sdk.IngressType

Packages that use IngressType

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.spi
org.apache.flink.statefun.sdk.io
org.apache.flink.statefun.sdk.kafka
org.apache.flink.statefun.sdk.kinesis
org.apache.flink.statefun.sdk.kinesis.ingress

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

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

Modifier and Type	Method and Description
java.util.Map<IngressType,SourceProvider>	StatefulFunctionsUniverse.sources()

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

Modifier and Type	Method and Description
void	StatefulFunctionsUniverse.bindSourceProvider(IngressType type, SourceProvider provider)

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

Fields in org.apache.flink.statefun.flink.harness.io declared as IngressType

Modifier and Type	Field and Description
static IngressType	HarnessConstants.SUPPLYING_INGRESS_TYPE

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

Modifier and Type	Method and Description
IngressType	SupplyingIngressSpec.type()

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

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

Modifier and Type	Method and Description
IngressType	SourceFunctionSpec.type()

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

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

Modifier and Type	Method and Description
void	FlinkIoModule.Binder.bindSourceProvider(IngressType type, SourceProvider provider)

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

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

Modifier and Type	Method and Description
IngressType	IngressSpec.type() Returns the type of the ingress.

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

Fields in org.apache.flink.statefun.sdk.kafka declared as IngressType

Modifier and Type	Field and Description
static IngressType	Constants.KAFKA_INGRESS_TYPE

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

Modifier and Type	Method and Description
IngressType	KafkaIngressSpec.type()

Uses of IngressType in org.apache.flink.statefun.sdk.kinesis

Fields in org.apache.flink.statefun.sdk.kinesis declared as IngressType

Modifier and Type	Field and Description
static IngressType	KinesisIOTypes.UNIVERSAL_INGRESS_TYPE

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

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

Modifier and Type	Method and Description
IngressType	KinesisIngressSpec.type()