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

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

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

Modifier and Type	Method	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, com.hazelcast.function.FunctionEx<T,String> keyFn, com.hazelcast.function.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(com.hazelcast.function.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(com.hazelcast.jet.retry.RetryStrategy retryStrategy)	Specifies how the source should behave when reading data from the stream fails.