Package com.linkedin.davinci.blobtransfer

Interface P2PBlobTransferManager<T>

All Superinterfaces:

java.lang.AutoCloseable, BlobTransferManager<T>

All Known Implementing Classes:

NettyP2PBlobTransferManager

public interface P2PBlobTransferManager<T>
extends BlobTransferManager<T>

Peer-to-Peer (P2P) Blob Transfer Manager. For P2P, the manager acts as both a client and the server to transfer blobs between nodes.

Method Summary

Modifier and Type	Method	Description
default java.util.concurrent.CompletionStage<T>	put(java.lang.String storeName, int version, int partition)	For P2P blob transfer, only GET should be implemented and there's no need to implement PUT method by default.

Methods inherited from interface com.linkedin.davinci.blobtransfer.BlobTransferManager

close, get, getAggVersionedBlobTransferStats, start

Method Detail

put

default java.util.concurrent.CompletionStage<T> put(java.lang.String storeName,
                                                    int version,
                                                    int partition)

For P2P blob transfer, only GET should be implemented and there's no need to implement PUT method by default. It's subject to change depending on the use cases to use P2P blob transfer.

Specified by:

put in interface BlobTransferManager<T>

Parameters:

storeName -

version -

partition -

Returns:

the type of the object returned from the underlying blob client to indicate the upload status