Package com.linkedin.venice.blobtransfer

Class BlobTransferUtil

java.lang.Object

com.linkedin.venice.blobtransfer.BlobTransferUtil

public class BlobTransferUtil
extends java.lang.Object

Constructor Summary

Constructors

Constructor	Description
BlobTransferUtil()

Method Summary

Modifier and Type	Method	Description
static BlobTransferManager<java.lang.Void>	getP2PBlobTransferManagerAndStart(int p2pTransferServerPort, int p2pTransferClientPort, java.lang.String baseDir, ClientConfig clientConfig)
static BlobTransferManager<java.lang.Void>	getP2PBlobTransferManagerAndStart(int p2pTransferPort, java.lang.String baseDir, ClientConfig clientConfig)	Get a P2P blob transfer manager and start it.

Methods inherited from class java.lang.Object

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

Constructor Detail

BlobTransferUtil

public BlobTransferUtil()

Method Detail

getP2PBlobTransferManagerAndStart

public static BlobTransferManager<java.lang.Void> getP2PBlobTransferManagerAndStart(int p2pTransferPort,
                                                                                    java.lang.String baseDir,
                                                                                    ClientConfig clientConfig)

Get a P2P blob transfer manager and start it.

Parameters:

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

baseDir - , the base directory of the underlying storage

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

Returns:

Throws:

java.lang.Exception

getP2PBlobTransferManagerAndStart

public static BlobTransferManager<java.lang.Void> getP2PBlobTransferManagerAndStart(int p2pTransferServerPort,
                                                                                    int p2pTransferClientPort,
                                                                                    java.lang.String baseDir,
                                                                                    ClientConfig clientConfig)