Package | Description |
---|---|
org.apache.flink.statefun.sdk.kinesis.auth | |
org.apache.flink.statefun.sdk.kinesis.egress | |
org.apache.flink.statefun.sdk.kinesis.ingress |
Modifier and Type | Class and Description |
---|---|
static class |
AwsRegion.CustomEndpointAwsRegion |
static class |
AwsRegion.DefaultAwsRegion |
static class |
AwsRegion.SpecificIdAwsRegion |
Modifier and Type | Method and Description |
---|---|
static AwsRegion |
AwsRegion.fromDefaultProviderChain()
Consults AWS's default provider chain to determine the AWS region.
|
static AwsRegion |
AwsRegion.ofCustomEndpoint(java.lang.String serviceEndpoint,
java.lang.String regionId)
Connects to an AWS region through a non-standard AWS service endpoint.
|
static AwsRegion |
AwsRegion.ofId(java.lang.String id)
Specifies an AWS region using the region's unique id.
|
Modifier and Type | Method and Description |
---|---|
AwsRegion |
KinesisEgressSpec.awsRegion() |
Modifier and Type | Method and Description |
---|---|
KinesisEgressBuilder<T> |
KinesisEgressBuilder.withAwsRegion(AwsRegion awsRegion)
The AWS region to connect to.
|
Modifier and Type | Method and Description |
---|---|
AwsRegion |
KinesisIngressSpec.awsRegion() |
Modifier and Type | Method and Description |
---|---|
KinesisIngressBuilder<T> |
KinesisIngressBuilder.withAwsRegion(AwsRegion awsRegion)
The AWS region to connect to.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.