Modifier and Type | Field and Description |
---|---|
static ResourceSpec |
ResourceSpec.DEFAULT |
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 or merge the resource consumed by state backend.
|
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 or merge the resource consumed by state backend.
|
void |
Operator.setResources(ResourceSpec minResources,
ResourceSpec preferredResources)
Sets the minimum and preferred resources for this contract instance.
|
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 |
---|---|
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 |
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 |
---|---|
ResourceSpec |
StreamTransformation.getMinResources()
Gets the minimum resource of this stream transformation.
|
ResourceSpec |
StreamTransformation.getPreferredResources()
Gets the preferred resource of this stream transformation.
|
Modifier and Type | Method and Description |
---|---|
void |
StreamTransformation.setResources(ResourceSpec minResources,
ResourceSpec preferredResources)
Sets the minimum and preferred resources for this stream transformation.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.