Package org.apache.beam.sdk.io.solr

Class SolrIO.RetryConfiguration

java.lang.Object

org.apache.beam.sdk.io.solr.SolrIO.RetryConfiguration

All Implemented Interfaces:

java.io.Serializable

Enclosing class:

SolrIO

public abstract static class SolrIO.RetryConfiguration
extends java.lang.Object
implements java.io.Serializable

A POJO encapsulating a configuration for retry behavior when issuing requests to Solr. A retry will be attempted until the maxAttempts or maxDuration is exceeded, whichever comes first, for any of the following exceptions:

• IOException
• SolrServerException
• SolrException where the SolrException.ErrorCode is one of:
  • SolrException.ErrorCode.CONFLICT
  • SolrException.ErrorCode.SERVER_ERROR
  • SolrException.ErrorCode.SERVICE_UNAVAILABLE
  • SolrException.ErrorCode.INVALID_STATE
  • SolrException.ErrorCode.UNKNOWN

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
RetryConfiguration()

Method Summary

Modifier and Type	Method	Description
static SolrIO.RetryConfiguration	create(int maxAttempts, org.joda.time.Duration maxDuration)

Methods inherited from class java.lang.Object

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

Constructor Detail

RetryConfiguration

public RetryConfiguration()

Method Detail

create

public static SolrIO.RetryConfiguration create(int maxAttempts,
                                               org.joda.time.Duration maxDuration)