public class BlobCacheService extends Object implements BlobService
Constructor and Description |
---|
BlobCacheService(InetSocketAddress serverAddress,
Configuration blobClientConfig,
BlobView blobView)
Instantiates a new BLOB cache.
|
BlobCacheService(PermanentBlobCache permanentBlobCache,
TransientBlobCache transientBlobCache)
Instantiates a new BLOB cache.
|
Modifier and Type | Method and Description |
---|---|
void |
close() |
PermanentBlobCache |
getPermanentBlobService()
Returns a BLOB service for accessing permanent BLOBs.
|
int |
getPort()
Returns the port of the BLOB server that this BLOB service is working with.
|
TransientBlobCache |
getTransientBlobService()
Returns a BLOB service for accessing transient BLOBs.
|
public BlobCacheService(InetSocketAddress serverAddress, Configuration blobClientConfig, BlobView blobView) throws IOException
serverAddress
- address of the BlobServer
to use for fetching files fromblobClientConfig
- global configurationblobView
- (distributed) blob store file system to retrieve files from firstIOException
- thrown if the (local or distributed) file storage cannot be created or is not usablepublic BlobCacheService(PermanentBlobCache permanentBlobCache, TransientBlobCache transientBlobCache)
permanentBlobCache
- BLOB cache to use for permanent BLOBstransientBlobCache
- BLOB cache to use for transient BLOBspublic PermanentBlobCache getPermanentBlobService()
BlobService
getPermanentBlobService
in interface BlobService
public TransientBlobCache getTransientBlobService()
BlobService
getTransientBlobService
in interface BlobService
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
IOException
public int getPort()
BlobService
getPort
in interface BlobService
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.