Uses of Interface
com.hazelcast.jet.retry.RetryStrategy
Package
Description
Contains connectors for change data capture events from MySQL
databases.
Contains connectors for change data capture events from PostgreSQL
databases.
Contains a generic Kafka Connect source provides ability to plug any Kafka
Connect source for data ingestion to Jet pipelines.
Amazon Kinesis Data Streams producer/consumer support for Hazelcast Jet.
Contains sources and sinks for MongoDB.
Interfaces and utility classes for defining and tracking various types of
retry behaviour.
-
Uses of RetryStrategy in com.hazelcast.jet.cdc.mysql
Modifier and TypeMethodDescriptionMySqlCdcSources.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
Modifier and TypeMethodDescriptionPostgresCdcSources.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
Modifier and TypeMethodDescriptionstatic <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
Modifier and TypeMethodDescriptionKinesisSinks.Builder.withRetryStrategy
(RetryStrategy retryStrategy) Specifies how the source should behave when reading data from the stream fails.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
Modifier and TypeFieldDescriptionstatic final RetryStrategy
MongoSinkBuilder.DEFAULT_COMMIT_RETRY_STRATEGY
Default retry strategy used by the processors.Modifier and TypeMethodDescriptionMongoSinkBuilder.commitRetryStrategy
(RetryStrategy commitRetryStrategy) Sets the retry strategy in case of commit failure. -
Uses of RetryStrategy in com.hazelcast.jet.retry
Modifier and TypeMethodDescriptionRetryStrategies.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.