Package | Description |
---|---|
org.apache.lens.server.api.query | |
org.apache.lens.server.api.retry | |
org.apache.lens.server.query.constraint |
Modifier and Type | Method and Description |
---|---|
BackOffRetryHandler<QueryContext> |
QueryContext.getDriverRetryPolicy() |
BackOffRetryHandler<QueryContext> |
QueryContext.getRetryPolicy() |
BackOffRetryHandler<QueryContext> |
QueryContext.getServerRetryPolicy() |
Modifier and Type | Method and Description |
---|---|
void |
QueryContext.setDriverRetryPolicy(BackOffRetryHandler<QueryContext> driverRetryPolicy) |
void |
QueryContext.setServerRetryPolicy(BackOffRetryHandler<QueryContext> serverRetryPolicy) |
void |
QueryContext.updateDriverStatus(BackOffRetryHandler statusUpdateRetryHandler)
Update status from selected driver
|
Modifier and Type | Class and Description |
---|---|
class |
FibonacciExponentialBackOffRetryHandler<FC extends FailureContext>
A exponential backoff retry handler.
|
class |
ImmediateRetryHandler<FC extends FailureContext> |
class |
NoRetryHandler<FC extends FailureContext> |
Modifier and Type | Method and Description |
---|---|
static <FC extends FailureContext> |
OperationRetryHandlerFactory.createExponentialBackOffHandler(int numRetries,
long maxDelay,
long waitMillis)
Create exponential backoff handler
|
BackOffRetryHandler<FC> |
RetryPolicyDecider.decidePolicy(String errorMessage) |
BackOffRetryHandler<FC> |
DefaultRetryPolicyDecider.decidePolicy(String errorMessage) |
BackOffRetryHandler<FC> |
ChainedRetryPolicyDecider.decidePolicy(String errorMessage) |
Modifier and Type | Method and Description |
---|---|
BackOffRetryHandler<QueryContext> |
RetryPolicyToConstraingAdapter.getConstraint() |
Constructor and Description |
---|
RetryPolicyToConstraingAdapter(BackOffRetryHandler<QueryContext> constraint) |
Copyright © 2014–2018 Apache Software Foundation. All rights reserved.