Uses of Class
org.apache.flink.statefun.sdk.kinesis.ingress.KinesisIngressBuilder

Packages that use KinesisIngressBuilder

Package	Description
org.apache.flink.statefun.sdk.kinesis.ingress

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

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

Modifier and Type	Method and Description
static <T> KinesisIngressBuilder<T>	KinesisIngressBuilder.forIdentifier(IngressIdentifier<T> id)
KinesisIngressBuilder<T>	KinesisIngressBuilder.withAwsCredentials(AwsCredentials awsCredentials) The AWS credentials to use.
KinesisIngressBuilder<T>	KinesisIngressBuilder.withAwsRegion(AwsRegion awsRegion) The AWS region to connect to.
KinesisIngressBuilder<T>	KinesisIngressBuilder.withAwsRegion(java.lang.String regionName) The AWS region to connect to, specified by the AWS region's unique id.
KinesisIngressBuilder<T>	KinesisIngressBuilder.withClientConfigurationProperty(java.lang.String key, java.lang.String value) Deprecated. Please use withProperty(String, String) instead.
KinesisIngressBuilder<T>	KinesisIngressBuilder.withDeserializer(java.lang.Class<? extends KinesisIngressDeserializer<T>> deserializerClass)
KinesisIngressBuilder<T>	KinesisIngressBuilder.withProperties(java.util.Properties properties)
KinesisIngressBuilder<T>	KinesisIngressBuilder.withProperty(java.lang.String key, java.lang.String value)
KinesisIngressBuilder<T>	KinesisIngressBuilder.withStartupPosition(KinesisIngressStartupPosition startupPosition) Configures the position that the ingress should start consuming from.
KinesisIngressBuilder<T>	KinesisIngressBuilder.withStream(java.lang.String stream)
KinesisIngressBuilder<T>	KinesisIngressBuilder.withStreams(java.util.List<java.lang.String> streams)

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

Modifier and Type	Method and Description
static <T> void	KinesisIngressBuilderApiExtension.withDeserializer(KinesisIngressBuilder<T> kinesisIngressBuilder, KinesisIngressDeserializer<T> deserializer)