Package | Description |
---|---|
org.apache.flink.statefun.sdk.kinesis.egress |
Modifier and Type | Method and Description |
---|---|
static <T> KinesisEgressBuilder<T> |
KinesisEgressBuilder.forIdentifier(EgressIdentifier<T> id) |
KinesisEgressBuilder<T> |
KinesisEgressBuilder.withAwsCredentials(AwsCredentials awsCredentials)
The AWS credentials to use.
|
KinesisEgressBuilder<T> |
KinesisEgressBuilder.withAwsRegion(AwsRegion awsRegion)
The AWS region to connect to.
|
KinesisEgressBuilder<T> |
KinesisEgressBuilder.withAwsRegion(java.lang.String regionName)
The AWS region to connect to, specified by the AWS region's unique id.
|
KinesisEgressBuilder<T> |
KinesisEgressBuilder.withClientConfigurationProperty(java.lang.String key,
java.lang.String value)
Sets a AWS client configuration to be used by the egress.
|
KinesisEgressBuilder<T> |
KinesisEgressBuilder.withMaxOutstandingRecords(int maxOutstandingRecords)
The maximum number of buffered outstanding records, before backpressure is applied by the
egress.
|
KinesisEgressBuilder<T> |
KinesisEgressBuilder.withSerializer(java.lang.Class<? extends KinesisEgressSerializer<T>> serializerClass) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.