Modifier and Type | Method and Description |
---|---|
<X,QP extends MessageQueryParameter<X>> |
HandlerRequest.getQueryParameter(Class<QP> parameterClass)
Returns the value of the
MessageQueryParameter for the given class. |
Modifier and Type | Method and Description |
---|---|
Collection<MessageQueryParameter<?>> |
RescalingTriggerMessageParameters.getQueryParameters() |
Modifier and Type | Method and Description |
---|---|
static <X,P extends MessageQueryParameter<X>,R extends RequestBody,M extends MessageParameters> |
HandlerRequestUtils.getQueryParameter(HandlerRequest<R,M> request,
Class<P> queryParameterClass)
Returns the value of a query parameter, or
null if the query parameter is not set. |
static <X,P extends MessageQueryParameter<X>,R extends RequestBody,M extends MessageParameters> |
HandlerRequestUtils.getQueryParameter(HandlerRequest<R,M> request,
Class<P> queryParameterClass,
X defaultValue) |
Modifier and Type | Class and Description |
---|---|
class |
AccumulatorsIncludeSerializedValueQueryParameter
Query parameter for job's accumulator handler
JobAccumulatorsHandler . |
class |
RescalingParallelismQueryParameter
Parallelism for the rescaling of jobs specified as a
MessageQueryParameter . |
class |
TerminationModeQueryParameter
Termination mode query parameter.
|
Modifier and Type | Method and Description |
---|---|
Collection<MessageQueryParameter<?>> |
JobAccumulatorsMessageParameters.getQueryParameters() |
Collection<MessageQueryParameter<?>> |
JobMessageParameters.getQueryParameters() |
Collection<MessageQueryParameter<?>> |
JobVertexMessageParameters.getQueryParameters() |
Collection<MessageQueryParameter<?>> |
JobCancellationMessageParameters.getQueryParameters() |
abstract Collection<MessageQueryParameter<?>> |
MessageParameters.getQueryParameters()
Returns the collection of
MessageQueryParameter that the request supports. |
Collection<MessageQueryParameter<?>> |
EmptyMessageParameters.getQueryParameters() |
Modifier and Type | Method and Description |
---|---|
Collection<MessageQueryParameter<?>> |
FileMessageParameters.getQueryParameters() |
Modifier and Type | Method and Description |
---|---|
Collection<MessageQueryParameter<?>> |
ClusterDataSetDeleteTriggerMessageParameters.getQueryParameters() |
Collection<MessageQueryParameter<?>> |
ClusterDataSetDeleteStatusMessageParameters.getQueryParameters() |
Modifier and Type | Class and Description |
---|---|
class |
UpperLimitExceptionParameter
Specifies the upper limit of exceptions to return for JobExceptionsHandler.
|
Modifier and Type | Method and Description |
---|---|
Collection<MessageQueryParameter<?>> |
JobExceptionsMessageParameters.getQueryParameters() |
Modifier and Type | Method and Description |
---|---|
Collection<MessageQueryParameter<?>> |
ClientCoordinationMessageParameters.getQueryParameters() |
Modifier and Type | Class and Description |
---|---|
class |
AbstractAggregatedMetricsParameters<M extends MessageQueryParameter<?>>
Base
MessageParameters class for aggregating metrics. |
Modifier and Type | Class and Description |
---|---|
class |
JobsFilterQueryParameter
MessageQueryParameter for selecting jobs when aggregating metrics. |
class |
MetricsAggregationParameter
TODO: add javadoc.
|
class |
MetricsFilterParameter
MessageQueryParameter for filtering metrics provided by MetricStore . |
class |
SubtasksFilterQueryParameter
MessageQueryParameter for selecting subtasks when aggregating metrics. |
class |
TaskManagersFilterQueryParameter
MessageQueryParameter for selecting task managers when aggregating metrics. |
Modifier and Type | Method and Description |
---|---|
Collection<MessageQueryParameter<?>> |
SubtaskMetricsMessageParameters.getQueryParameters() |
Collection<MessageQueryParameter<?>> |
JobMetricsMessageParameters.getQueryParameters() |
Collection<MessageQueryParameter<?>> |
AbstractAggregatedMetricsParameters.getQueryParameters() |
Collection<MessageQueryParameter<?>> |
JobManagerMetricsMessageParameters.getQueryParameters() |
Collection<MessageQueryParameter<?>> |
JobVertexMetricsMessageParameters.getQueryParameters() |
Collection<MessageQueryParameter<?>> |
TaskManagerMetricsMessageParameters.getQueryParameters() |
Modifier and Type | Method and Description |
---|---|
Collection<MessageQueryParameter<?>> |
SavepointStatusMessageParameters.getQueryParameters() |
Collection<MessageQueryParameter<?>> |
SavepointDisposalStatusMessageParameters.getQueryParameters() |
Collection<MessageQueryParameter<?>> |
SavepointTriggerMessageParameters.getQueryParameters() |
Modifier and Type | Method and Description |
---|---|
Collection<MessageQueryParameter<?>> |
TaskManagerMessageParameters.getQueryParameters() |
Modifier and Type | Class and Description |
---|---|
class |
AllowNonRestoredStateQueryParameter
Query parameter that specifies whether non restored state is allowed if the savepoint contains
state for an operator that is not part of the job.
|
class |
EntryClassQueryParameter
Query parameter specifying the name of the entry point class.
|
class |
ParallelismQueryParameter
Query parameter specifying the parallelism of the job.
|
class |
ProgramArgQueryParameter
Query parameter specifying one or more arguments for the program.
|
class |
ProgramArgsQueryParameter
Deprecated.
please, use
JarRequestBody.FIELD_NAME_PROGRAM_ARGUMENTS_LIST |
class |
SavepointPathQueryParameter
Query parameter that specifies the savepoint to restore from.
|
class |
StringQueryParameter
Abstract super class for
String query parameters. |
Modifier and Type | Method and Description |
---|---|
Collection<MessageQueryParameter<?>> |
JarDeleteMessageParameters.getQueryParameters() |
Collection<MessageQueryParameter<?>> |
JarRunMessageParameters.getQueryParameters() |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.