org.apache.flink.runtime.jobmaster.slotpool

Interface DeclareResourceRequirementServiceConnectionManager

All Superinterfaces:

ServiceConnectionManager<DeclareResourceRequirementServiceConnectionManager.DeclareResourceRequirementsService>

All Known Implementing Classes:

NoOpDeclareResourceRequirementServiceConnectionManager

public interface DeclareResourceRequirementServiceConnectionManager
extends ServiceConnectionManager<DeclareResourceRequirementServiceConnectionManager.DeclareResourceRequirementsService>

ServiceConnectionManager for declaring resource requirements.

In practice the backing service will be the ResourceManager.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	DeclareResourceRequirementServiceConnectionManager.DeclareResourceRequirementsService Service that accepts resource requirements.

Method Summary

Modifier and Type	Method and Description
void	declareResourceRequirements(ResourceRequirements resourceRequirements) Declares the given resource requirements at the connected service.

Methods inherited from interface org.apache.flink.runtime.jobmaster.ServiceConnectionManager

close, connect, disconnect

Method Detail

declareResourceRequirements

void declareResourceRequirements(ResourceRequirements resourceRequirements)

Declares the given resource requirements at the connected service. If no connection is established, then this call will be ignored.

Parameters:

resourceRequirements - resourceRequirements to declare at the connected service