Package org.apache.flink.runtime.blob
Interface BlobService
-
- All Superinterfaces:
AutoCloseable,Closeable
- All Known Subinterfaces:
TaskExecutorBlobService
- All Known Implementing Classes:
BlobCacheService,BlobServer
public interface BlobService extends Closeable
A simple store and retrieve binary large objects (BLOBs).
-
-
Method Summary
All Methods Instance Methods Abstract Methods Default Methods Modifier and Type Method Description default InetAddressgetAddress()Returns the network address of the BLOB server that this BLOB service is working with.PermanentBlobServicegetPermanentBlobService()Returns a BLOB service for accessing permanent BLOBs.intgetPort()Returns the port of the BLOB server that this BLOB service is working with.TransientBlobServicegetTransientBlobService()Returns a BLOB service for accessing transient BLOBs.
-
-
-
Method Detail
-
getPermanentBlobService
PermanentBlobService getPermanentBlobService()
Returns a BLOB service for accessing permanent BLOBs.- Returns:
- BLOB service
-
getTransientBlobService
TransientBlobService getTransientBlobService()
Returns a BLOB service for accessing transient BLOBs.- Returns:
- BLOB service
-
getPort
int getPort()
Returns the port of the BLOB server that this BLOB service is working with.- Returns:
- the port of the blob server.
-
getAddress
default InetAddress getAddress()
Returns the network address of the BLOB server that this BLOB service is working with. This default implementation returns the loopback address.- Returns:
- the InetAddress of the BLOB server.
-
-