Package com.linkedin.venice.blobtransfer
Class DaVinciBlobFinder
- java.lang.Object
-
- com.linkedin.venice.blobtransfer.DaVinciBlobFinder
-
- All Implemented Interfaces:
BlobFinder
,java.lang.AutoCloseable
public class DaVinciBlobFinder extends java.lang.Object implements BlobFinder
DvcBlobFinder discovers live DaVinci peer nodes to facilitate blob transfers necessary for bootstrapping the database
-
-
Constructor Summary
Constructors Constructor Description DaVinciBlobFinder(AbstractAvroStoreClient storeClient)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
close()
BlobPeersDiscoveryResponse
discoverBlobPeers(java.lang.String storeName, int version, int partition)
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
-
DaVinciBlobFinder
public DaVinciBlobFinder(AbstractAvroStoreClient storeClient)
-
-
Method Detail
-
discoverBlobPeers
public BlobPeersDiscoveryResponse discoverBlobPeers(java.lang.String storeName, int version, int partition)
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() throws java.io.IOException
- Specified by:
close
in interfacejava.lang.AutoCloseable
- Throws:
java.io.IOException
-
-