Uses of Class
com.hazelcast.jet.kinesis.KinesisSources.Builder
Package
Description
Amazon Kinesis Data Streams producer/consumer support for Hazelcast Jet.
-
Uses of KinesisSources.Builder in com.hazelcast.jet.kinesis
Modifier and TypeMethodDescriptionstatic KinesisSources.Builder<Map.Entry<String,
byte[]>> Initiates the building of a streaming source that consumes a Kinesis data stream and emitsMap.Entry<String, byte[]>
items.KinesisSources.Builder.withCredentials
(String accessKey, String secretKey) Specifies the AWS credentials to use for authentication purposes.KinesisSources.Builder.withEndpoint
(String endpoint) Specifies the AWS Kinesis endpoint (URL of the entry point for the AWS web service) to connect to.KinesisSources.Builder.withExecutorServiceSupplier
(SupplierEx<ExecutorService> executorSupplier) Specifies an executor service supplier that will be used by theAwsConfig
to construct an AWS async client.KinesisSources.Builder.withInitialShardIteratorRule
(String shardIdRegExp, String shardIteratorType, String parameter) Specifies how initial reads of the shards should be done (see shardIteratorType for available options).<T_NEW> KinesisSources.Builder<T_NEW>
KinesisSources.Builder.withProjectionFn
(BiFunctionEx<com.amazonaws.services.kinesis.model.Record, com.amazonaws.services.kinesis.model.Shard, T_NEW> projectionFn) Specifies projection function, that will map inputRecord
andShard
from which this record was read into user-defined type.KinesisSources.Builder.withRegion
(String region) Specifies the AWS Region (collection of AWS resources in a geographic area) to connect to.KinesisSources.Builder.withRetryStrategy
(RetryStrategy retryStrategy) Specifies how the source should behave when reading data from the stream fails.