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

Packages that use KinesisSources.Builder

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

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

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

Modifier and Type	Method and Description
static KinesisSources.Builder<Map.Entry<String,byte[]>>	KinesisSources.kinesis(String stream) Initiates the building of a streaming source that consumes a Kinesis data stream and emits Map.Entry<String, byte[]> items.
KinesisSources.Builder<T>	KinesisSources.Builder.withCredentials(String accessKey, String secretKey) Specifies the AWS credentials to use for authentication purposes.
KinesisSources.Builder<T>	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<T>	KinesisSources.Builder.withExecutorServiceSupplier(SupplierEx<ExecutorService> executorSupplier) Specifies an executor service supplier that will be used by the AwsConfig to construct an AWS async client.
KinesisSources.Builder<T>	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 input Record and Shard from which this record was read into user-defined type.
KinesisSources.Builder<T>	KinesisSources.Builder.withRegion(String region) Specifies the AWS Region (collection of AWS resources in a geographic area) to connect to.
KinesisSources.Builder<T>	KinesisSources.Builder.withRetryStrategy(RetryStrategy retryStrategy) Specifies how the source should behave when reading data from the stream fails.