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
All Methods Instance Methods Default Methods 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, 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 interfaceBlobTransferManager<T>
- Parameters:
storeName
-version
-partition
-- Returns:
- the type of the object returned from the underlying blob client to indicate the upload status
-
-