org.apache.flink.table.planner.plan.utils

Class LookupJoinUtil.RetryLookupOptions

java.lang.Object

org.apache.flink.table.planner.plan.utils.LookupJoinUtil.RetryLookupOptions

Enclosing class:

LookupJoinUtil

public static class LookupJoinUtil.RetryLookupOptions
extends Object

RetryOptions includes retry lookup related options.

Field Summary

Fields

Modifier and Type	Field and Description
static String	FIELD_NAME_RETRY_FIXED_DELAY
static String	FIELD_NAME_RETRY_MAX_ATTEMPTS
static String	FIELD_NAME_RETRY_PREDICATE
static String	FIELD_NAME_RETRY_STRATEGY

Constructor Summary

Constructors

Constructor and Description
RetryLookupOptions(String retryPredicate, LookupJoinHintOptions.RetryStrategy retryStrategy, Long retryFixedDelay, Integer retryMaxAttempts)

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object o)
static LookupJoinUtil.RetryLookupOptions	fromJoinHint(org.apache.calcite.rel.hint.RelHint lookupJoinHint)
int	hashCode()
org.apache.flink.table.runtime.operators.join.lookup.ResultRetryStrategy	toRetryStrategy() Convert this LookupJoinUtil.RetryLookupOptions to ResultRetryStrategy in the best effort manner.
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Detail

FIELD_NAME_RETRY_PREDICATE

public static final String FIELD_NAME_RETRY_PREDICATE

See Also:

Constant Field Values

FIELD_NAME_RETRY_STRATEGY

public static final String FIELD_NAME_RETRY_STRATEGY

See Also:

Constant Field Values

FIELD_NAME_RETRY_FIXED_DELAY

public static final String FIELD_NAME_RETRY_FIXED_DELAY

See Also:

Constant Field Values

FIELD_NAME_RETRY_MAX_ATTEMPTS

public static final String FIELD_NAME_RETRY_MAX_ATTEMPTS

See Also:

Constant Field Values

Constructor Detail

RetryLookupOptions

public RetryLookupOptions(String retryPredicate,
                          LookupJoinHintOptions.RetryStrategy retryStrategy,
                          Long retryFixedDelay,
                          Integer retryMaxAttempts)

Method Detail

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object

fromJoinHint

@Nullable
public static LookupJoinUtil.RetryLookupOptions fromJoinHint(@Nullable
                                                                       org.apache.calcite.rel.hint.RelHint lookupJoinHint)

toRetryStrategy

public org.apache.flink.table.runtime.operators.join.lookup.ResultRetryStrategy toRetryStrategy()

Convert this LookupJoinUtil.RetryLookupOptions to ResultRetryStrategy in the best effort manner. If invalid LookupJoinHintOptions.RETRY_PREDICATE or LookupJoinHintOptions.RETRY_STRATEGY is given, then ResultRetryStrategy.NO_RETRY_STRATEGY will return.