Package | Description |
---|---|
org.apache.flink.table.planner.plan.utils | |
org.apache.flink.table.runtime.operators.join.lookup |
Modifier and Type | Method and Description |
---|---|
ResultRetryStrategy |
LookupJoinUtil.RetryLookupOptions.toRetryStrategy()
Convert this
LookupJoinUtil.RetryLookupOptions to ResultRetryStrategy in the best effort
manner. |
Modifier and Type | Method and Description |
---|---|
static UserDefinedFunction |
LookupJoinUtil.getLookupFunction(org.apache.calcite.plan.RelOptTable temporalTable,
Collection<Integer> lookupKeys,
ClassLoader classLoader,
boolean async,
ResultRetryStrategy retryStrategy)
Gets required lookup function (async or sync) from temporal table , will raise an error if
specified lookup function instance not found.
|
Modifier and Type | Field and Description |
---|---|
static ResultRetryStrategy |
ResultRetryStrategy.NO_RETRY_STRATEGY |
Modifier and Type | Method and Description |
---|---|
static ResultRetryStrategy |
ResultRetryStrategy.fixedDelayRetry(int maxAttempts,
long backoffTimeMillis,
java.util.function.Predicate<Collection<RowData>> resultPredicate)
Create a fixed-delay retry strategy by given params.
|
Constructor and Description |
---|
RetryableAsyncLookupFunctionDelegator(AsyncLookupFunction userLookupFunction,
ResultRetryStrategy retryStrategy) |
RetryableLookupFunctionDelegator(LookupFunction userLookupFunction,
ResultRetryStrategy retryStrategy) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.