com.hazelcast.jet.kinesis

Class KinesisSinks.Builder<T>

java.lang.Object

com.hazelcast.jet.kinesis.KinesisSinks.Builder<T>

Type Parameters:

T - Type of items ingested by this sink

Enclosing class:

KinesisSinks

public static final class KinesisSinks.Builder<T>
extends Object

Fluent builder for constructing the Kinesis sink and setting its configuration parameters.

Method Summary

Modifier and Type	Method and Description
Sink<T>	build() Construct the sink based on the options provided so far.
KinesisSinks.Builder<T>	withCredentials(String accessKey, String secretKey) Specifies the AWS credentials to use for authentication purposes.
KinesisSinks.Builder<T>	withEndpoint(String endpoint) Specifies the AWS Kinesis endpoint (URL of the entry point for the AWS web service) to connect to.
KinesisSinks.Builder<T>	withExecutorServiceSupplier(SupplierEx<ExecutorService> executorSupplier) Specifies an executor service supplier that will be used by the AwsConfig to construct an AWS async client.
KinesisSinks.Builder<T>	withRegion(String region) Specifies the AWS Region (collection of AWS resources in a geographic area) to connect to.
KinesisSinks.Builder<T>	withRetryStrategy(RetryStrategy retryStrategy) Specifies how the source should behave when reading data from the stream fails.

Methods inherited from class java.lang.Object

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

Method Detail

withEndpoint

@Nonnull
public KinesisSinks.Builder<T> withEndpoint(@Nullable
                                                     String endpoint)

Specifies the AWS Kinesis endpoint (URL of the entry point for the AWS web service) to connect to. The general syntax of these endpoint URLs is "protocol://service-code.region-code.amazonaws.com", so for example, for Kinesis, for the us-west-2 region, we could have "https://dynamodb.us-west-2.amazonaws.com". For local testing, it might be "http://localhost:4566".

If not specified (or specified as null), the default endpoint for the specified region will be used.

withRegion

@Nonnull
public KinesisSinks.Builder<T> withRegion(@Nullable
                                                   String region)

Specifies the AWS Region (collection of AWS resources in a geographic area) to connect to. Region names are of form "us-west-1", "eu-central-1" and so on.

If not specified (or specified as null), the default region set via external means will be used (either from your local .aws/config file or the AWS_REGION environment variable). If no such default is set, then "us-east-1" will be used.

withCredentials

@Nonnull
public KinesisSinks.Builder<T> withCredentials(@Nullable
                                                        String accessKey,
                                                        @Nullable
                                                        String secretKey)

Specifies the AWS credentials to use for authentication purposes.

If not specified (or specified as null), then keys specified via external means will be used. This can mean the local .aws/credentials file or the AWS_ACCESS_KEY_ID and AWS_SECRET_ACCESS_KEY environmental variables.

Either both keys must be set to non-null values or neither.

withRetryStrategy

@Nonnull
public KinesisSinks.Builder<T> withRetryStrategy(@Nonnull
                                                          RetryStrategy retryStrategy)

Specifies how the source should behave when reading data from the stream fails. The default behavior retries the read operation indefinitely, but after an exponentially increasing delay, it starts with 100 milliseconds and doubles on each subsequent failure. A successful read resets it. The delay is capped at 3 seconds.

withExecutorServiceSupplier

@Nonnull
public KinesisSinks.Builder<T> withExecutorServiceSupplier(@Nonnull
                                                                    SupplierEx<ExecutorService> executorSupplier)

Specifies an executor service supplier that will be used by the AwsConfig to construct an AWS async client.

Since:

5.2

build

@Nonnull
public Sink<T> build()

Construct the sink based on the options provided so far.