Class BlobFsUtils

java.lang.Object
com.here.platform.data.client.hdfs.utils.BlobFsUtils

public class BlobFsUtils extends Object
  • Constructor Details

    • BlobFsUtils

      public BlobFsUtils()
  • Method Details

    • buildBlobFsUri

      public static URI buildBlobFsUri(URI incomingUri)
    • extractHrn

      public static HRN extractHrn(URI incomingUri)
    • pathToBlobDir

      public static String pathToBlobDir(org.apache.hadoop.fs.Path path)
    • pathToBlobObjectId

      public static String pathToBlobObjectId(org.apache.hadoop.fs.Path path)
    • splitPathToNames

      public static scala.collection.immutable.Seq<String> splitPathToNames(org.apache.hadoop.fs.Path path)
    • sanitiseObjectId

      public static String sanitiseObjectId(String objectId)
    • blobListObjectToFullPath

      public static org.apache.hadoop.fs.Path blobListObjectToFullPath(org.apache.hadoop.fs.Path path, String blobObject)
    • getLayerIdAuthorityHrn

      public static String getLayerIdAuthorityHrn(HRN hrn)
    • getCatalogHrnFromAuthorityHrn

      public static HRN getCatalogHrnFromAuthorityHrn(HRN hrn)
    • unsupported

      public static scala.runtime.Nothing$ unsupported(LayerTypeName layerTypeName, String methodName)
    • 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)