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

Class BlobFsService

java.lang.Object
com.here.platform.data.client.hdfs.BlobFsService
public class BlobFsService extends Object

  • Constructor Summary

    Constructors
    Constructor
    Description
    BlobFsService(HRN catalogHrn, String layerId, com.here.platform.data.client.engine.scaladsl.ReadEngine readEngine, com.here.platform.data.client.engine.scaladsl.WriteEngine writeEngine, com.here.platform.data.client.scaladsl.AdminApi adminApi, DataClientHdfsContext context)
     
    BlobFsService(HRN catalogHrn, String layerId, DataClientHdfsContext context)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    org.apache.hadoop.fs.FSDataOutputStream
    append(org.apache.hadoop.fs.Path path)
     
    org.apache.hadoop.fs.FSDataOutputStream
    create(org.apache.hadoop.fs.Path path, boolean overwrite, org.apache.hadoop.conf.Configuration hadoopConfig)
     
    static com.here.platform.data.client.scaladsl.AdminApi
    defaultAdminApi(org.apache.pekko.actor.ActorSystem actorSystem)
     
    static com.here.platform.data.client.engine.scaladsl.ReadEngine
    defaultReadEngine(HRN catalogHrn, org.apache.pekko.actor.ActorSystem actorSystem)
     
    static com.here.platform.data.client.engine.scaladsl.WriteEngine
    defaultWriteEngine(HRN catalogHrn, org.apache.pekko.actor.ActorSystem actorSystem)
     
    boolean
    delete(org.apache.hadoop.fs.Path path, boolean recursive)
     
    BlobFsLayer
    fsLayer()
     
    org.apache.hadoop.fs.FileStatus
    getFileStatus(org.apache.hadoop.fs.Path path)
     
    org.apache.hadoop.fs.Path
    getWorkingDirectory(URI uri)
     
    org.apache.hadoop.fs.FileStatus[]
    listStatus(org.apache.hadoop.fs.Path path)
     
    boolean
    mkdirs(org.apache.hadoop.fs.Path path)
     
    org.apache.hadoop.fs.FSDataInputStream
    open(org.apache.hadoop.fs.Path path)
     
    boolean
    rename(org.apache.hadoop.fs.Path src, org.apache.hadoop.fs.Path dst)
     
    void
    setWorkingDirectory(org.apache.hadoop.fs.Path path)
     

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • BlobFsService

      public BlobFsService(HRN catalogHrn, String layerId, com.here.platform.data.client.engine.scaladsl.ReadEngine readEngine, com.here.platform.data.client.engine.scaladsl.WriteEngine writeEngine, com.here.platform.data.client.scaladsl.AdminApi adminApi, DataClientHdfsContext context)

    • BlobFsService

      public BlobFsService(HRN catalogHrn, String layerId, DataClientHdfsContext context)

  • Method Details

    • defaultReadEngine

      public static com.here.platform.data.client.engine.scaladsl.ReadEngine defaultReadEngine(HRN catalogHrn, org.apache.pekko.actor.ActorSystem actorSystem)

    • defaultWriteEngine

      public static com.here.platform.data.client.engine.scaladsl.WriteEngine defaultWriteEngine(HRN catalogHrn, org.apache.pekko.actor.ActorSystem actorSystem)

    • defaultAdminApi

      public static com.here.platform.data.client.scaladsl.AdminApi defaultAdminApi(org.apache.pekko.actor.ActorSystem actorSystem)

    • fsLayer

      public BlobFsLayer fsLayer()

    • open

      public org.apache.hadoop.fs.FSDataInputStream open(org.apache.hadoop.fs.Path path)

    • create

      public org.apache.hadoop.fs.FSDataOutputStream create(org.apache.hadoop.fs.Path path, boolean overwrite, org.apache.hadoop.conf.Configuration hadoopConfig)

    • rename

      public boolean rename(org.apache.hadoop.fs.Path src, org.apache.hadoop.fs.Path dst)

    • delete

      public boolean delete(org.apache.hadoop.fs.Path path, boolean recursive)

    • mkdirs

      public boolean mkdirs(org.apache.hadoop.fs.Path path)

    • getFileStatus

      public org.apache.hadoop.fs.FileStatus getFileStatus(org.apache.hadoop.fs.Path path)

    • listStatus

      public org.apache.hadoop.fs.FileStatus[] listStatus(org.apache.hadoop.fs.Path path)

    • setWorkingDirectory

      public void setWorkingDirectory(org.apache.hadoop.fs.Path path)

    • getWorkingDirectory

      public org.apache.hadoop.fs.Path getWorkingDirectory(URI uri)

    • append

      public org.apache.hadoop.fs.FSDataOutputStream append(org.apache.hadoop.fs.Path path)