Package com.here.platform.data.client.hdfs.streams

Class MultiPartManager

java.lang.Object

com.here.platform.data.client.hdfs.streams.MultiPartManager

public class MultiPartManager
extends Object

Constructor Summary

Constructors

Constructor	Description
MultiPartManager(String layerId, String objectId, int partUploadParallelism, com.here.platform.data.client.engine.scaladsl.WriteEngine writeEngine, scala.concurrent.ExecutionContext executionContext)

Method Summary

Modifier and Type	Method	Description
scala.concurrent.Future<org.apache.pekko.Done>	complete()
void	uploadBlockAsync(BlobFsDataBlock block)

Methods inherited from class java.lang.Object

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

Constructor Details

MultiPartManager

public MultiPartManager(String layerId,
 String objectId,
 int partUploadParallelism,
 com.here.platform.data.client.engine.scaladsl.WriteEngine writeEngine,
 scala.concurrent.ExecutionContext executionContext)

Method Details

complete

public scala.concurrent.Future<org.apache.pekko.Done> complete()

uploadBlockAsync

public void uploadBlockAsync(BlobFsDataBlock block)