Package org.apache.flink.runtime.blob
Interface TaskExecutorBlobService
-
- All Superinterfaces:
AutoCloseable
,BlobService
,Closeable
- All Known Implementing Classes:
BlobCacheService
public interface TaskExecutorBlobService extends BlobService
BlobService
that gives access to aJobPermanentBlobService
and allows to set the target blob server address.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description JobPermanentBlobService
getPermanentBlobService()
Returns a BLOB service for accessing permanent BLOBs.void
setBlobServerAddress(InetSocketAddress blobServerAddress)
Sets the blob server address.-
Methods inherited from interface org.apache.flink.runtime.blob.BlobService
getPort, getTransientBlobService
-
-
-
-
Method Detail
-
getPermanentBlobService
JobPermanentBlobService getPermanentBlobService()
Description copied from interface:BlobService
Returns a BLOB service for accessing permanent BLOBs.- Specified by:
getPermanentBlobService
in interfaceBlobService
- Returns:
- BLOB service
-
setBlobServerAddress
void setBlobServerAddress(InetSocketAddress blobServerAddress)
Sets the blob server address.- Parameters:
blobServerAddress
- blob server address
-
-