org.apache.beam.sdk.io.jdbc

Interface JdbcIO.RetryStrategy

All Superinterfaces:

java.io.Serializable

All Known Implementing Classes:

JdbcIO.DefaultRetryStrategy

Enclosing class:

JdbcIO

Functional Interface:

This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.

@FunctionalInterface
public static interface JdbcIO.RetryStrategy
extends java.io.Serializable

An interface used to control if we retry the statements when a SQLException occurs. If apply(SQLException) returns true, JdbcIO.Write tries to replay the statements.

Method Summary

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

Method Detail

apply

boolean apply(java.sql.SQLException sqlException)