Package com.linkedin.venice.blobtransfer
Class ServerBlobFinder
- java.lang.Object
-
- com.linkedin.venice.blobtransfer.ServerBlobFinder
-
- All Implemented Interfaces:
BlobFinder
,java.lang.AutoCloseable
public class ServerBlobFinder extends java.lang.Object implements BlobFinder
-
-
Constructor Summary
Constructors Constructor Description ServerBlobFinder(java.util.concurrent.CompletableFuture<HelixCustomizedViewOfflinePushRepository> customizedViewRepository)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
close()
BlobPeersDiscoveryResponse
discoverBlobPeers(java.lang.String storeName, int version, int partitionId)
This method will look through the partitions for the store and version provided until it finds the partition requested, it will then return the URL of the instances that are ready to serve in the partition.
-
-
-
Constructor Detail
-
ServerBlobFinder
public ServerBlobFinder(java.util.concurrent.CompletableFuture<HelixCustomizedViewOfflinePushRepository> customizedViewRepository)
-
-
Method Detail
-
discoverBlobPeers
public BlobPeersDiscoveryResponse discoverBlobPeers(java.lang.String storeName, int version, int partitionId)
Description copied from interface:BlobFinder
This method will look through the partitions for the store and version provided until it finds the partition requested, it will then return the URL of the instances that are ready to serve in the partition.- Specified by:
discoverBlobPeers
in interfaceBlobFinder
-
close
public void close()
- Specified by:
close
in interfacejava.lang.AutoCloseable
-
-