Package com.here.platform.data.client.converters.protobuf.schema

Class SchemaDownloader

java.lang.Object
com.here.platform.data.client.converters.protobuf.schema.SchemaDownloader
public class SchemaDownloader extends Object

  • Constructor Summary

    Constructors
    Constructor
    Description
    SchemaDownloader()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    static InputStream
    download(HRN catalogHrn, String layerId, Settings settings, org.apache.pekko.actor.ActorSystem actorSystem, org.apache.pekko.stream.Materializer materializer, scala.concurrent.ExecutionContext executionContext)
    Given a catalogHrn and layerId, download the relevant schema as a compressed input stream (zip)
    static InputStream
    download(com.here.platform.data.client.scaladsl.internal.ArtifactApi artifactApi, HRN artifactHrn, String zipFileName, org.apache.pekko.stream.Materializer materializer, scala.concurrent.ExecutionContext executionContext)
    Download the zip file using artifact service (/artifact/{artifactHrn}/{zipFileName}) An InputStream containing the contents of the zip is returned
    static scala.Tuple2<HRN,String>
    getLayerDSSchema(com.here.platform.data.client.scaladsl.internal.ArtifactApi artifactApi, LayerSchema layerSchema)
    The ds schema is specifically the schema HRN contained in the "ds" variant of the schema record in the OLP artifact repository.
    static LayerSchema
    getLayerSchema(com.here.platform.data.client.scaladsl.QueryApi queryApi, String layerId, scala.concurrent.ExecutionContext executionContext)
     

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • SchemaDownloader

      public SchemaDownloader()

  • Method Details

    • download

      public static InputStream download(HRN catalogHrn, String layerId, Settings settings, org.apache.pekko.actor.ActorSystem actorSystem, org.apache.pekko.stream.Materializer materializer, scala.concurrent.ExecutionContext executionContext)
      Given a catalogHrn and layerId, download the relevant schema as a compressed input stream (zip)

      Returns:
      directory where the schema has been extracted to

    • download

      public static InputStream download(com.here.platform.data.client.scaladsl.internal.ArtifactApi artifactApi, HRN artifactHrn, String zipFileName, org.apache.pekko.stream.Materializer materializer, scala.concurrent.ExecutionContext executionContext)
      Download the zip file using artifact service (/artifact/{artifactHrn}/{zipFileName}) An InputStream containing the contents of the zip is returned

    • getLayerSchema

      public static LayerSchema getLayerSchema(com.here.platform.data.client.scaladsl.QueryApi queryApi, String layerId, scala.concurrent.ExecutionContext executionContext)

    • getLayerDSSchema

      public static scala.Tuple2<HRN,String> getLayerDSSchema(com.here.platform.data.client.scaladsl.internal.ArtifactApi artifactApi, LayerSchema layerSchema)
      The ds schema is specifically the schema HRN contained in the "ds" variant of the schema record in the OLP artifact repository.