Uses of Class
com.hazelcast.jet.kinesis.KinesisSinks.Builder
Package
Description
Amazon Kinesis Data Streams producer/consumer support for Hazelcast Jet.
-
Uses of KinesisSinks.Builder in com.hazelcast.jet.kinesis
Modifier and TypeMethodDescriptionstatic KinesisSinks.Builder<Map.Entry<String,
byte[]>> Convenience method for a specific type of sink, one that ingests items of typeMap.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.withCredentials
(String accessKey, String secretKey) Specifies the AWS credentials to use for authentication purposes.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.withExecutorServiceSupplier
(SupplierEx<ExecutorService> executorSupplier) Specifies an executor service supplier that will be used by theAwsConfig
to construct an AWS async client.KinesisSinks.Builder.withRegion
(String region) Specifies the AWS Region (collection of AWS resources in a geographic area) to connect to.KinesisSinks.Builder.withRetryStrategy
(RetryStrategy retryStrategy) Specifies how the source should behave when reading data from the stream fails.