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

Class KinesisIngressBuilderApiExtension

java.lang.Object

org.apache.flink.statefun.sdk.kinesis.ingress.KinesisIngressBuilderApiExtension

public final class KinesisIngressBuilderApiExtension
extends java.lang.Object

Method Summary

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

withDeserializer

public static <T> void withDeserializer(KinesisIngressBuilder<T> kinesisIngressBuilder,
                                        KinesisIngressDeserializer<T> deserializer)