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	Description
static KinesisSources.Builder	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	KinesisSources.Builder.withCredentials(String accessKey, String secretKey)	Specifies the AWS credentials to use for authentication purposes.
KinesisSources.Builder	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	KinesisSources.Builder.withInitialShardIteratorRule(String shardIdRegExp, String shardIteratorType, String parameter)	Specifies how initial reads of the shards should be done (see shardIteratorType for available options).
KinesisSources.Builder	KinesisSources.Builder.withRegion(String region)	Specifies the AWS Region (collection of AWS resources in a geographic area) to connect to.
KinesisSources.Builder	KinesisSources.Builder.withRetryStrategy(RetryStrategy retryStrategy)	Specifies how the source should behave when reading data from the stream fails.