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

Packages that use RetryStrategy

Package	Description
com.hazelcast.jet.cdc.mysql	Contains connectors for change data capture events from MySQL databases.
com.hazelcast.jet.cdc.postgres	Contains connectors for change data capture events from PostgreSQL databases.
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.cdc.mysql

Methods in com.hazelcast.jet.cdc.mysql with parameters of type RetryStrategy

Modifier and Type	Method	Description
MySqlCdcSources.Builder	MySqlCdcSources.Builder.setReconnectBehavior(RetryStrategy retryStrategy)	Specifies how the source should behave when it detects that the backing database has been shut down (read class javadoc for details and special cases).

Uses of RetryStrategy in com.hazelcast.jet.cdc.postgres

Methods in com.hazelcast.jet.cdc.postgres with parameters of type RetryStrategy

Modifier and Type	Method	Description
PostgresCdcSources.Builder	PostgresCdcSources.Builder.setReconnectBehavior(RetryStrategy retryStrategy)	Specifies how the connector should behave when it detects that the backing database has been shut dow.

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.