org.apache.flink.api.common.externalresource

Interface ExternalResourceDriver

@PublicEvolving
public interface ExternalResourceDriver

Driver which takes the responsibility to manage and provide the information of external resource.

Drivers that should be instantiated via a ExternalResourceDriverFactory.

TaskExecutor will retrieve the ExternalResourceInfo set of the external resource from the drivers.

Method Summary

Modifier and Type	Method and Description
Set<? extends ExternalResourceInfo>	retrieveResourceInfo(long amount) Retrieve the information of the external resources according to the amount.

Method Detail

retrieveResourceInfo

Set<? extends ExternalResourceInfo> retrieveResourceInfo(long amount)
                                                  throws Exception

Retrieve the information of the external resources according to the amount.

Parameters:

amount - of the required external resources

Returns:

information set of the required external resources

Throws:

Exception - if there is something wrong during retrieving