Modifier and Type | Field and Description |
---|---|
static ResourceSpec |
ResourceSpec.DEFAULT
The default ResourceSpec used for operators and transformation functions.
|
static ResourceSpec |
ResourceSpec.UNKNOWN
A ResourceSpec that indicates an unknown set of resources.
|
static ResourceSpec |
ResourceSpec.ZERO
A ResourceSpec that indicates zero amount of resources.
|
Modifier and Type | Method and Description |
---|---|
ResourceSpec |
ResourceSpec.Builder.build() |
ResourceSpec |
Operator.getMinResources()
Gets the minimum resources for this operator.
|
ResourceSpec |
Operator.getPreferredResources()
Gets the preferred resources for this contract instance.
|
ResourceSpec |
ResourceSpec.merge(ResourceSpec other)
Used by system internally to merge the other resources of chained operators when generating
the job graph.
|
ResourceSpec |
ResourceSpec.subtract(ResourceSpec other)
Subtracts another resource spec from this one.
|
Modifier and Type | Method and Description |
---|---|
boolean |
ResourceSpec.lessThanOrEqual(ResourceSpec other)
Checks the current resource less than or equal with the other resource by comparing all the
fields in the resource.
|
ResourceSpec |
ResourceSpec.merge(ResourceSpec other)
Used by system internally to merge the other resources of chained operators when generating
the job graph.
|
void |
Operator.setResources(ResourceSpec minResources,
ResourceSpec preferredResources)
Sets the minimum and preferred resources for this contract instance.
|
ResourceSpec |
ResourceSpec.subtract(ResourceSpec other)
Subtracts another resource spec from this one.
|
Modifier and Type | Method and Description |
---|---|
static void |
OperatorValidationUtils.validateMinAndPreferredResources(ResourceSpec minResources,
ResourceSpec preferredResources) |
static void |
OperatorValidationUtils.validateResources(ResourceSpec resources) |
Modifier and Type | Method and Description |
---|---|
ResourceSpec |
Transformation.getMinResources()
Gets the minimum resource of this stream transformation.
|
ResourceSpec |
Transformation.getPreferredResources()
Gets the preferred resource of this stream transformation.
|
Modifier and Type | Method and Description |
---|---|
void |
Transformation.setResources(ResourceSpec minResources,
ResourceSpec preferredResources)
Sets the minimum and preferred resources for this stream transformation.
|
Modifier and Type | Field and Description |
---|---|
protected ResourceSpec |
Operator.minResources |
protected ResourceSpec |
Operator.preferredResources |
Modifier and Type | Method and Description |
---|---|
ResourceSpec |
DeltaIteration.getMinResources()
Gets the minimum resources from this iteration.
|
ResourceSpec |
DataSink.getMinResources()
Returns the minimum resources of this data sink.
|
ResourceSpec |
Operator.getMinResources()
Returns the minimum resource of this operator.
|
ResourceSpec |
DeltaIteration.getPreferredResources()
Gets the preferred resources from this iteration.
|
ResourceSpec |
DataSink.getPreferredResources()
Returns the preferred resources of this data sink.
|
ResourceSpec |
Operator.getPreferredResources()
Returns the preferred resource of this operator.
|
Modifier and Type | Method and Description |
---|---|
ResourceSpec |
PlanNode.getMinResources() |
ResourceSpec |
PlanNode.getPreferredResources() |
Modifier and Type | Method and Description |
---|---|
static ResourceProfile |
ResourceProfile.fromResourceSpec(ResourceSpec resourceSpec,
MemorySize networkMemory) |
Modifier and Type | Method and Description |
---|---|
ResourceSpec |
JobVertex.getMinResources()
Gets the minimum resource for the task.
|
ResourceSpec |
JobVertex.getPreferredResources()
Gets the preferred resource for the task.
|
Modifier and Type | Method and Description |
---|---|
void |
JobVertex.setResources(ResourceSpec minResources,
ResourceSpec preferredResources)
Sets the minimum and preferred resources for the task.
|
Modifier and Type | Method and Description |
---|---|
ResourceSpec |
SlotSharingGroup.getResourceSpec() |
Modifier and Type | Method and Description |
---|---|
void |
SlotSharingGroup.addVertexToGroup(JobVertexID id,
ResourceSpec resource) |
void |
SlotSharingGroup.removeVertexFromGroup(JobVertexID id,
ResourceSpec resource) |
Modifier and Type | Method and Description |
---|---|
ResourceSpec |
DataStream.getMinResources()
Gets the minimum resources for this operator.
|
ResourceSpec |
DataStream.getPreferredResources()
Gets the preferred resources for this operator.
|
Modifier and Type | Method and Description |
---|---|
ResourceSpec |
StreamNode.getMinResources() |
ResourceSpec |
StreamNode.getPreferredResources() |
Modifier and Type | Method and Description |
---|---|
Tuple2<StreamNode,StreamNode> |
StreamGraph.createIterationSourceAndSink(int loopId,
int sourceId,
int sinkId,
long timeout,
int parallelism,
int maxParallelism,
ResourceSpec minResources,
ResourceSpec preferredResources) |
void |
StreamGraph.setResources(int vertexID,
ResourceSpec minResources,
ResourceSpec preferredResources) |
void |
StreamNode.setResources(ResourceSpec minResources,
ResourceSpec preferredResources) |
Modifier and Type | Method and Description |
---|---|
void |
SinkTransformation.setResources(ResourceSpec minResources,
ResourceSpec preferredResources) |
Modifier and Type | Method and Description |
---|---|
ResourceSpec |
TableOperatorWrapperGenerator.getMinResources() |
ResourceSpec |
TableOperatorWrapperGenerator.getPreferredResources() |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.