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)
Deprecated.
Please use
withProperty(String, String) instead. |
KinesisEgressBuilder<T> |
KinesisEgressBuilder.withMaxOutstandingRecords(int maxOutstandingRecords)
The maximum number of buffered outstanding records, before backpressure is applied by the
egress.
|
KinesisEgressBuilder<T> |
KinesisEgressBuilder.withProperties(java.util.Properties properties) |
KinesisEgressBuilder<T> |
KinesisEgressBuilder.withProperty(java.lang.String key,
java.lang.String value) |
KinesisEgressBuilder<T> |
KinesisEgressBuilder.withSerializer(java.lang.Class<? extends KinesisEgressSerializer<T>> serializerClass) |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.