org.apache.flink.statefun.flink.io.kinesis.binders.ingress.v1

Class RoutableKinesisIngressSpec.Builder

java.lang.Object

org.apache.flink.statefun.flink.io.kinesis.binders.ingress.v1.RoutableKinesisIngressSpec.Builder

Enclosing class:

RoutableKinesisIngressSpec

public static class RoutableKinesisIngressSpec.Builder
extends java.lang.Object

Method Summary

Modifier and Type	Method and Description
RoutableKinesisIngressSpec	build()
RoutableKinesisIngressSpec.Builder	withAwsCredentials(AwsCredentials awsCredentials)
RoutableKinesisIngressSpec.Builder	withAwsRegion(AwsRegion awsRegion)
RoutableKinesisIngressSpec.Builder	withProperties(java.util.Properties properties)
RoutableKinesisIngressSpec.Builder	withStartupPosition(KinesisIngressStartupPosition startupPosition)
RoutableKinesisIngressSpec.Builder	withStreamRoutings(java.util.Map<java.lang.String,RoutingConfig> streamRoutings)

Methods inherited from class java.lang.Object

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

Method Detail

withAwsRegion

public RoutableKinesisIngressSpec.Builder withAwsRegion(AwsRegion awsRegion)

withAwsCredentials

public RoutableKinesisIngressSpec.Builder withAwsCredentials(AwsCredentials awsCredentials)

withStartupPosition

public RoutableKinesisIngressSpec.Builder withStartupPosition(KinesisIngressStartupPosition startupPosition)

withStreamRoutings

public RoutableKinesisIngressSpec.Builder withStreamRoutings(java.util.Map<java.lang.String,RoutingConfig> streamRoutings)

withProperties

public RoutableKinesisIngressSpec.Builder withProperties(java.util.Properties properties)

build

public RoutableKinesisIngressSpec build()