Package com.linkedin.venice.blobtransfer

Class DaVinciBlobFinder

java.lang.Object

com.linkedin.venice.blobtransfer.DaVinciBlobFinder

All Implemented Interfaces:

BlobFinder, AutoCloseable

public class DaVinciBlobFinder
extends 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

Modifier and Type	Method	Description
void	close()
BlobPeersDiscoveryResponse	discoverBlobPeers(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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

DaVinciBlobFinder

public DaVinciBlobFinder(AbstractAvroStoreClient storeClient)

Method Details

discoverBlobPeers

public BlobPeersDiscoveryResponse discoverBlobPeers(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 interface BlobFinder

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Throws:

IOException