Uses of Class
com.hazelcast.jet.kinesis.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 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 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<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. 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.