Package | Description |
---|---|
com.hazelcast.jet.kinesis |
Amazon Kinesis Data Streams producer/consumer support for Hazelcast Jet.
|
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.
|
Copyright © 2023 Hazelcast, Inc.. All rights reserved.