Index

B C K M T W
All Classes and Interfaces|All Packages|Constant Field Values

B

BATCH_SIZE_METRIC - Static variable in class com.hazelcast.jet.kinesis.KinesisSinks

One of the metrics exposed by the sink used to monitor the current sending batch size.

build() - Method in class com.hazelcast.jet.kinesis.KinesisSinks.Builder

Construct the sink based on the options provided so far.

build() - Method in class com.hazelcast.jet.kinesis.KinesisSources.Builder

Constructs the source based on the options provided so far.

C

com.hazelcast.jet.kinesis - package com.hazelcast.jet.kinesis

Amazon Kinesis Data Streams producer/consumer support for Hazelcast Jet.

K

kinesis(String) - Static method in class com.hazelcast.jet.kinesis.KinesisSinks

Convenience method for a specific type of sink, one that ingests items of type Map.Entry<String, byte[]> and assumes that the entries key is the partition key and the entries value is the record data blob.

kinesis(String) - Static method in class com.hazelcast.jet.kinesis.KinesisSources

Initiates the building of a streaming source that consumes a Kinesis data stream and emits Map.Entry<String, byte[]> items.

kinesis(String, FunctionEx<T, String>, FunctionEx<T, byte[]>) - Static method in class com.hazelcast.jet.kinesis.KinesisSinks

Initiates the building of a sink that publishes messages into Amazon Kinesis Data Streams (KDS).

KinesisSinks - Class in com.hazelcast.jet.kinesis

Contains factory methods for creating Amazon Kinesis Data Streams (KDS) sinks.

KinesisSinks.Builder<T> - Class in com.hazelcast.jet.kinesis

Fluent builder for constructing the Kinesis sink and setting its configuration parameters.

KinesisSources - Class in com.hazelcast.jet.kinesis

Contains factory methods for creating Amazon Kinesis Data Streams (KDS) sources.

KinesisSources.Builder<T> - Class in com.hazelcast.jet.kinesis

Fluent builder for constructing the Kinesis source and setting its configuration parameters.

M

MAX_RECORD_SIZE - Static variable in class com.hazelcast.jet.kinesis.KinesisSinks

The length of a record's data blob (byte array length), plus the record's key size (no.

MAXIMUM_KEY_LENGTH - Static variable in class com.hazelcast.jet.kinesis.KinesisSinks

Kinesis partition keys are Unicode strings, with a maximum length limit of 256 characters for each key.

MILLIS_BEHIND_LATEST_METRIC - Static variable in class com.hazelcast.jet.kinesis.KinesisSources

Name of the metric exposed by the source, used to monitor if reading a specific shard is delayed or not.

T

THROTTLING_SLEEP_METRIC - Static variable in class com.hazelcast.jet.kinesis.KinesisSinks

One of the metrics exposed by the sink used to monitor the current sleep delay between consecutive sends (in milliseconds).

W

withCredentials(String, String) - Method in class com.hazelcast.jet.kinesis.KinesisSinks.Builder

Specifies the AWS credentials to use for authentication purposes.

withCredentials(String, String) - Method in class com.hazelcast.jet.kinesis.KinesisSources.Builder

Specifies the AWS credentials to use for authentication purposes.

withEndpoint(String) - Method in class com.hazelcast.jet.kinesis.KinesisSinks.Builder

Specifies the AWS Kinesis endpoint (URL of the entry point for the AWS web service) to connect to.

withEndpoint(String) - Method in class com.hazelcast.jet.kinesis.KinesisSources.Builder

Specifies the AWS Kinesis endpoint (URL of the entry point for the AWS web service) to connect to.

withExecutorServiceSupplier(SupplierEx<ExecutorService>) - Method in class com.hazelcast.jet.kinesis.KinesisSinks.Builder

Specifies an executor service supplier that will be used by the AwsConfig to construct an AWS async client.

withExecutorServiceSupplier(SupplierEx<ExecutorService>) - Method in class com.hazelcast.jet.kinesis.KinesisSources.Builder

Specifies an executor service supplier that will be used by the AwsConfig to construct an AWS async client.

withInitialShardIteratorRule(String, String, String) - Method in class com.hazelcast.jet.kinesis.KinesisSources.Builder

Specifies how initial reads of the shards should be done (see shardIteratorType for available options).

withProjectionFn(BiFunctionEx<Record, Shard, T_NEW>) - Method in class com.hazelcast.jet.kinesis.KinesisSources.Builder

Specifies projection function, that will map input Record and Shard from which this record was read into user-defined type.

withRegion(String) - Method in class com.hazelcast.jet.kinesis.KinesisSinks.Builder

Specifies the AWS Region (collection of AWS resources in a geographic area) to connect to.

withRegion(String) - Method in class com.hazelcast.jet.kinesis.KinesisSources.Builder

Specifies the AWS Region (collection of AWS resources in a geographic area) to connect to.

withRetryStrategy(RetryStrategy) - Method in class com.hazelcast.jet.kinesis.KinesisSinks.Builder

Specifies how the source should behave when reading data from the stream fails.

withRetryStrategy(RetryStrategy) - Method in class com.hazelcast.jet.kinesis.KinesisSources.Builder

Specifies how the source should behave when reading data from the stream fails.

B C K M T W
All Classes and Interfaces|All Packages|Constant Field Values