Class BlobFsUtils
java.lang.Object
com.here.platform.data.client.hdfs.utils.BlobFsUtils
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionstatic org.apache.hadoop.fs.PathblobListObjectToFullPath(org.apache.hadoop.fs.Path path, String blobObject) static URIbuildBlobFsUri(URI incomingUri) static HRNextractHrn(URI incomingUri) static HRNstatic Stringstatic com.typesafe.config.ConfighadoopToPartUploadParallelismConfig(int partUploadParallelism) static com.typesafe.config.ConfighadoopToPekkoCredentialsConfig(org.apache.hadoop.conf.Configuration hadoopConfiguration) static com.typesafe.config.ConfighadoopToPekkoPartSizeConfig(int partSize) static StringpathToBlobDir(org.apache.hadoop.fs.Path path) static StringpathToBlobObjectId(org.apache.hadoop.fs.Path path) static StringsanitiseObjectId(String objectId) static scala.collection.immutable.Seq<String>splitPathToNames(org.apache.hadoop.fs.Path path) static scala.runtime.Nothing$unsupported(LayerTypeName layerTypeName, String methodName)
-
Constructor Details
-
BlobFsUtils
public BlobFsUtils()
-
-
Method Details
-
buildBlobFsUri
-
extractHrn
-
pathToBlobDir
-
pathToBlobObjectId
-
splitPathToNames
public static scala.collection.immutable.Seq<String> splitPathToNames(org.apache.hadoop.fs.Path path) -
sanitiseObjectId
-
blobListObjectToFullPath
public static org.apache.hadoop.fs.Path blobListObjectToFullPath(org.apache.hadoop.fs.Path path, String blobObject) -
getLayerIdAuthorityHrn
-
getCatalogHrnFromAuthorityHrn
-
unsupported
-
hadoopToPekkoPartSizeConfig
public static com.typesafe.config.Config hadoopToPekkoPartSizeConfig(int partSize) -
hadoopToPartUploadParallelismConfig
public static com.typesafe.config.Config hadoopToPartUploadParallelismConfig(int partUploadParallelism) -
hadoopToPekkoCredentialsConfig
public static com.typesafe.config.Config hadoopToPekkoCredentialsConfig(org.apache.hadoop.conf.Configuration hadoopConfiguration)
-