Package org.apache.beam.sdk.io.jdbc

Class JdbcIO.DefaultRetryStrategy

java.lang.Object

org.apache.beam.sdk.io.jdbc.JdbcIO.DefaultRetryStrategy

All Implemented Interfaces:

Serializable, JdbcIO.RetryStrategy

Enclosing class:

JdbcIO

public static class JdbcIO.DefaultRetryStrategy
extends Object
implements JdbcIO.RetryStrategy

This is the default Predicate we use to detect DeadLock. It basically test if the SQLException.getSQLState() equals 40001 or 40P01. 40001 is the SQL State used by most of databases to identify deadlock, and 40P01 is specific to PostgreSQL (see PostgreSQL documentation).

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
DefaultRetryStrategy()

Method Summary

Modifier and Type	Method	Description
boolean	apply(SQLException e)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

DefaultRetryStrategy

public DefaultRetryStrategy()

Method Details

apply

public boolean apply(SQLException e)

Specified by:

apply in interface JdbcIO.RetryStrategy