Uses of Interface
com.hazelcast.jet.retry.RetryStrategy

Packages that use RetryStrategy

Package	Description
com.hazelcast.jet.kafka.connect	Contains a generic Kafka Connect source provides ability to plug any Kafka Connect source for data ingestion to Jet pipelines.
com.hazelcast.jet.kinesis	Amazon Kinesis Data Streams producer/consumer support for Hazelcast Jet.
com.hazelcast.jet.mongodb	Contains sources and sinks for MongoDB.
com.hazelcast.jet.retry	Interfaces and utility classes for defining and tracking various types of retry behaviour.

Uses of RetryStrategy in com.hazelcast.jet.kafka.connect

Methods in com.hazelcast.jet.kafka.connect with parameters of type RetryStrategy

Modifier and Type	Method	Description
static <T> StreamSource<T>	KafkaConnectSources.connect(Properties properties, FunctionEx<org.apache.kafka.connect.source.SourceRecord,T> projectionFn, RetryStrategy retryStrategy)	A generic Kafka Connect source provides ability to plug any Kafka Connect source for data ingestion to Jet pipelines.

Uses of RetryStrategy in com.hazelcast.jet.kinesis

Methods in com.hazelcast.jet.kinesis with parameters of type RetryStrategy

Modifier and Type	Method	Description
KinesisSinks.Builder<T>	KinesisSinks.Builder.withRetryStrategy(RetryStrategy retryStrategy)	Specifies how the source should behave when reading data from the stream fails.
KinesisSources.Builder<T>	KinesisSources.Builder.withRetryStrategy(RetryStrategy retryStrategy)	Specifies how the source should behave when reading data from the stream fails.

Uses of RetryStrategy in com.hazelcast.jet.mongodb

Fields in com.hazelcast.jet.mongodb declared as RetryStrategy

Modifier and Type	Field	Description
static final RetryStrategy	MongoSinkBuilder.DEFAULT_COMMIT_RETRY_STRATEGY	Default retry strategy used by the processors.

Methods in com.hazelcast.jet.mongodb with parameters of type RetryStrategy

Modifier and Type	Method	Description
MongoSinkBuilder<T>	MongoSinkBuilder.commitRetryStrategy(RetryStrategy commitRetryStrategy)	Sets the retry strategy in case of commit failure.

Uses of RetryStrategy in com.hazelcast.jet.retry

Methods in com.hazelcast.jet.retry that return RetryStrategy

Modifier and Type	Method	Description
RetryStrategy	RetryStrategies.Builder.build()	Constructs the actual strategy based on the properties set previously.
static RetryStrategy	RetryStrategies.indefinitely(long intervalMillis)	Create a strategy which will retry failed actions indefinitely and will wait for a fixed amount of time between any two subsequent attempts.
static RetryStrategy	RetryStrategies.never()	Create a strategy which will not retry a failed action.