org.apache.beam.sdk.io.jdbc

Class JdbcIO.DefaultRetryStrategy

java.lang.Object

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

All Implemented Interfaces:

java.io.Serializable, JdbcIO.RetryStrategy

Enclosing class:

JdbcIO

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

This is the default Predicate we use to detect DeadLock. It basically test if the SQLException.getSQLState() equals 40001. 40001 is the SQL State used by most of database to identify deadlock.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
DefaultRetryStrategy()

Method Summary

Modifier and Type	Method and Description
boolean	apply(java.sql.SQLException e)

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultRetryStrategy

public DefaultRetryStrategy()

Method Detail

apply

public boolean apply(java.sql.SQLException e)

Specified by:

apply in interface JdbcIO.RetryStrategy