Uses of Class
com.hazelcast.jet.kinesis.KinesisSinks.Builder

Packages that use KinesisSinks.Builder

Package	Description
com.hazelcast.jet.kinesis	Amazon Kinesis Data Streams producer/consumer support for Hazelcast Jet.

Uses of KinesisSinks.Builder in com.hazelcast.jet.kinesis

Methods in com.hazelcast.jet.kinesis that return KinesisSinks.Builder

Modifier and Type	Method and Description
static KinesisSinks.Builder<Map.Entry<String,byte[]>>	KinesisSinks.kinesis(String stream) Convenience method for a specific type of sink, one that ingests items of type Map.Entry<String, byte[]> and assumes that the entries key is the partition key and the entries value is the record data blob.
static <T> KinesisSinks.Builder<T>	KinesisSinks.kinesis(String stream, FunctionEx<T,String> keyFn, FunctionEx<T,byte[]> valueFn) Initiates the building of a sink that publishes messages into Amazon Kinesis Data Streams (KDS).
KinesisSinks.Builder<T>	KinesisSinks.Builder.withCredentials(String accessKey, String secretKey) Specifies the AWS credentials to use for authentication purposes.
KinesisSinks.Builder<T>	KinesisSinks.Builder.withEndpoint(String endpoint) Specifies the AWS Kinesis endpoint (URL of the entry point for the AWS web service) to connect to.
KinesisSinks.Builder<T>	KinesisSinks.Builder.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>	KinesisSinks.Builder.withRegion(String region) Specifies the AWS Region (collection of AWS resources in a geographic area) to connect to.
KinesisSinks.Builder<T>	KinesisSinks.Builder.withRetryStrategy(RetryStrategy retryStrategy) Specifies how the source should behave when reading data from the stream fails.