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.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.
|
Modifier and Type | Method and 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).
|
Modifier and Type | Method and 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.
|
Modifier and Type | Method and Description |
---|---|
KinesisSources.Builder<T> |
KinesisSources.Builder.withRetryStrategy(RetryStrategy retryStrategy)
Specifies how the source should behave when reading data from
the stream fails.
|
KinesisSinks.Builder<T> |
KinesisSinks.Builder.withRetryStrategy(RetryStrategy retryStrategy)
Specifies how the source should behave when reading data from
the stream fails.
|
Modifier and Type | Field and Description |
---|---|
static RetryStrategy |
MongoSinkBuilder.DEFAULT_COMMIT_RETRY_STRATEGY
Default retry strategy used by the processors.
|
Modifier and Type | Method and Description |
---|---|
MongoSinkBuilder<T> |
MongoSinkBuilder.commitRetryStrategy(RetryStrategy commitRetryStrategy)
Sets the retry strategy in case of commit failure.
|
Modifier and Type | Method and 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.
|
Copyright © 2023 Hazelcast, Inc.. All rights reserved.