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

Class GenericKinesisEgressSpec.Builder

java.lang.Object

org.apache.flink.statefun.flink.io.kinesis.binders.egress.v1.GenericKinesisEgressSpec.Builder

Enclosing class:

GenericKinesisEgressSpec

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

Method Summary

Modifier and Type	Method and Description
GenericKinesisEgressSpec	build()
GenericKinesisEgressSpec.Builder	withAwsCredentials(AwsCredentials awsCredentials)
GenericKinesisEgressSpec.Builder	withAwsRegion(AwsRegion awsRegion)
GenericKinesisEgressSpec.Builder	withMaxOutstandingRecords(int maxOutstandingRecords)
GenericKinesisEgressSpec.Builder	withProperties(java.util.Properties properties)

Methods inherited from class java.lang.Object

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

Method Detail

withAwsRegion

public GenericKinesisEgressSpec.Builder withAwsRegion(AwsRegion awsRegion)

withAwsCredentials

public GenericKinesisEgressSpec.Builder withAwsCredentials(AwsCredentials awsCredentials)

withMaxOutstandingRecords

public GenericKinesisEgressSpec.Builder withMaxOutstandingRecords(int maxOutstandingRecords)

withProperties

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

build

public GenericKinesisEgressSpec build()