Package com.linkedin.davinci.blobtransfer

Class BlobTransferUtil

java.lang.Object

com.linkedin.davinci.blobtransfer.BlobTransferUtil

public class BlobTransferUtil
extends Object

Constructor Summary

Constructors

Constructor	Description
BlobTransferUtil()

Method Summary

Modifier and Type	Method	Description
static BlobTransferManager<Void>	getP2PBlobTransferManagerForDVCAndStart(int p2pTransferServerPort, int p2pTransferClientPort, String baseDir, ClientConfig clientConfig, StorageMetadataService storageMetadataService, ReadOnlyStoreRepository readOnlyStoreRepository, StorageEngineRepository storageEngineRepository, int maxConcurrentSnapshotUser, int snapshotRetentionTimeInMin, int blobTransferMaxTimeoutInMin, AggVersionedBlobTransferStats aggVersionedBlobTransferStats, BlobTransferUtils.BlobTransferTableFormat transferSnapshotTableFormat)
static BlobTransferManager<Void>	getP2PBlobTransferManagerForDVCAndStart(int p2pTransferPort, String baseDir, ClientConfig clientConfig, StorageMetadataService storageMetadataService, ReadOnlyStoreRepository readOnlyStoreRepository, StorageEngineRepository storageEngineRepository, int maxConcurrentSnapshotUser, int snapshotRetentionTimeInMin, int blobTransferMaxTimeoutInMin, AggVersionedBlobTransferStats aggVersionedBlobTransferStats, BlobTransferUtils.BlobTransferTableFormat transferSnapshotTableFormat)	Get a P2P blob transfer manager for DaVinci Client and start it.
static BlobTransferManager<Void>	getP2PBlobTransferManagerForServerAndStart(int p2pTransferServerPort, int p2pTransferClientPort, String baseDir, CompletableFuture<HelixCustomizedViewOfflinePushRepository> customizedViewFuture, StorageMetadataService storageMetadataService, ReadOnlyStoreRepository readOnlyStoreRepository, StorageEngineRepository storageEngineRepository, int maxConcurrentSnapshotUser, int snapshotRetentionTimeInMin, int blobTransferMaxTimeoutInMin, AggVersionedBlobTransferStats aggVersionedBlobTransferStats, BlobTransferUtils.BlobTransferTableFormat transferSnapshotTableFormat)	Get a P2P blob transfer manager for Server and start it.

Methods inherited from class java.lang.Object

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

Constructor Details

BlobTransferUtil

public BlobTransferUtil()

Method Details

getP2PBlobTransferManagerForDVCAndStart

public static BlobTransferManager<Void> getP2PBlobTransferManagerForDVCAndStart(int p2pTransferPort,
 String baseDir,
 ClientConfig clientConfig,
 StorageMetadataService storageMetadataService,
 ReadOnlyStoreRepository readOnlyStoreRepository,
 StorageEngineRepository storageEngineRepository,
 int maxConcurrentSnapshotUser,
 int snapshotRetentionTimeInMin,
 int blobTransferMaxTimeoutInMin,
 AggVersionedBlobTransferStats aggVersionedBlobTransferStats,
 BlobTransferUtils.BlobTransferTableFormat transferSnapshotTableFormat)

Get a P2P blob transfer manager for DaVinci Client and start it.

Parameters:

p2pTransferPort - , the port used by the P2P transfer server and client

baseDir - , the base directory of the underlying storage

clientConfig - , the client config to start up a transport client

storageMetadataService - , the storage metadata service

Returns:

the blob transfer manager

Throws:

Exception

getP2PBlobTransferManagerForDVCAndStart

public static BlobTransferManager<Void> getP2PBlobTransferManagerForDVCAndStart(int p2pTransferServerPort,
 int p2pTransferClientPort,
 String baseDir,
 ClientConfig clientConfig,
 StorageMetadataService storageMetadataService,
 ReadOnlyStoreRepository readOnlyStoreRepository,
 StorageEngineRepository storageEngineRepository,
 int maxConcurrentSnapshotUser,
 int snapshotRetentionTimeInMin,
 int blobTransferMaxTimeoutInMin,
 AggVersionedBlobTransferStats aggVersionedBlobTransferStats,
 BlobTransferUtils.BlobTransferTableFormat transferSnapshotTableFormat)

getP2PBlobTransferManagerForServerAndStart

public static BlobTransferManager<Void> getP2PBlobTransferManagerForServerAndStart(int p2pTransferServerPort,
 int p2pTransferClientPort,
 String baseDir,
 CompletableFuture<HelixCustomizedViewOfflinePushRepository> customizedViewFuture,
 StorageMetadataService storageMetadataService,
 ReadOnlyStoreRepository readOnlyStoreRepository,
 StorageEngineRepository storageEngineRepository,
 int maxConcurrentSnapshotUser,
 int snapshotRetentionTimeInMin,
 int blobTransferMaxTimeoutInMin,
 AggVersionedBlobTransferStats aggVersionedBlobTransferStats,
 BlobTransferUtils.BlobTransferTableFormat transferSnapshotTableFormat)

Get a P2P blob transfer manager for Server and start it.

Parameters:

p2pTransferServerPort - the port used by the P2P transfer server

p2pTransferClientPort - the port used by the P2P transfer client

baseDir - the base directory of the underlying storage

customizedViewFuture - the future of the customized view repository

Returns:

the blob transfer manager