Package com.here.platform.data.client.service.metadata

Class DefaultMetadataService

java.lang.Object

com.here.platform.data.client.service.metadata.DefaultMetadataService

All Implemented Interfaces:

MetadataService

public class DefaultMetadataService
extends Object
implements MetadataService

Constructor Summary

Constructors

Constructor	Description
DefaultMetadataService(HttpHandler httpHandler, ClientExecutionContext clientExecutionContext)

Method Summary

Modifier and Type	Method	Description
com.github.plokhotnyuk.jsoniter_scala.core.JsonValueCodec<com.here.platform.data.client.scaladsl.ReferencePartition>	codec()
scala.concurrent.Future<org.apache.pekko.stream.scaladsl.Source<com.here.platform.data.client.scaladsl.Partition,org.apache.pekko.NotUsed>>	getChanges(HRN hrn, InternalSettings settings, long startVersion, long endVersion, String layer, VersionedLayerContext context, scala.collection.immutable.Set<AdditionalField> additionalFields, scala.Option<String> partId)
scala.concurrent.Future<com.here.platform.data.client.scaladsl.QueryParts>	getChangesParts(HRN hrn, String layerId, int parts, InternalSettings settings)
scala.concurrent.Future<org.apache.pekko.stream.scaladsl.Source<CompatibleVersion,org.apache.pekko.NotUsed>>	getCompatibleVersions(HRN hrn, InternalSettings settings, scala.collection.immutable.Set<CatalogVersion> dependencies)
scala.concurrent.Future<scala.Option<Object>>	getLatestVersion(HRN hrn, InternalSettings settings, scala.Option<Object> startVersion)
scala.concurrent.Future<LayerVersions>	getLayerVersions(HRN hrn, InternalSettings settings, long version)
scala.concurrent.Future<scala.Option<Object>>	getMinimumVersion(HRN hrn, InternalSettings settings)
scala.concurrent.Future<org.apache.pekko.stream.scaladsl.Source<com.here.platform.data.client.scaladsl.Partition,org.apache.pekko.NotUsed>>	getPartitions(HRN hrn, InternalSettings settings, long version, String layer, VersionedLayerContext context, scala.collection.immutable.Set<AdditionalField> additionalFields, scala.Option<String> partId)
scala.concurrent.Future<com.here.platform.data.client.scaladsl.QueryParts>	getPartitionsParts(HRN hrn, String layerId, int parts, InternalSettings settings)
scala.concurrent.Future<scala.collection.immutable.Seq<VersionInfo>>	getVersions(HRN hrn, InternalSettings settings, long startVersion, long endVersion)
scala.concurrent.Future<org.apache.pekko.stream.scaladsl.Source<com.here.platform.data.client.scaladsl.Partition,org.apache.pekko.NotUsed>>	getVolatileChanges(HRN hrn, InternalSettings settings, long sinceTime, String layer, scala.collection.immutable.Set<AdditionalField> additionalFields)
scala.concurrent.Future<PartitionSinglePage>	getVolatileChangesNext(HRN hrn, InternalSettings settings, String nextUrl)
scala.concurrent.Future<org.apache.pekko.Done>	setMinimumVersion(HRN hrn, long minVersion, InternalSettings settings)

Methods inherited from class java.lang.Object

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

Constructor Details

DefaultMetadataService

public DefaultMetadataService(HttpHandler httpHandler,
 ClientExecutionContext clientExecutionContext)

Method Details

codec

public com.github.plokhotnyuk.jsoniter_scala.core.JsonValueCodec<com.here.platform.data.client.scaladsl.ReferencePartition> codec()

getChanges

public scala.concurrent.Future<org.apache.pekko.stream.scaladsl.Source<com.here.platform.data.client.scaladsl.Partition,org.apache.pekko.NotUsed>> getChanges(HRN hrn,
 InternalSettings settings,
 long startVersion,
 long endVersion,
 String layer,
 VersionedLayerContext context,
 scala.collection.immutable.Set<AdditionalField> additionalFields,
 scala.Option<String> partId)

Specified by:

getChanges in interface MetadataService

getChangesParts

public scala.concurrent.Future<com.here.platform.data.client.scaladsl.QueryParts> getChangesParts(HRN hrn,
 String layerId,
 int parts,
 InternalSettings settings)

Specified by:

getChangesParts in interface MetadataService

getCompatibleVersions

public scala.concurrent.Future<org.apache.pekko.stream.scaladsl.Source<CompatibleVersion,org.apache.pekko.NotUsed>> getCompatibleVersions(HRN hrn,
 InternalSettings settings,
 scala.collection.immutable.Set<CatalogVersion> dependencies)

Specified by:

getCompatibleVersions in interface MetadataService

getLatestVersion

public scala.concurrent.Future<scala.Option<Object>> getLatestVersion(HRN hrn,
 InternalSettings settings,
 scala.Option<Object> startVersion)

Specified by:

getLatestVersion in interface MetadataService

getLayerVersions

public scala.concurrent.Future<LayerVersions> getLayerVersions(HRN hrn,
 InternalSettings settings,
 long version)

Specified by:

getLayerVersions in interface MetadataService

getMinimumVersion

public scala.concurrent.Future<scala.Option<Object>> getMinimumVersion(HRN hrn,
 InternalSettings settings)

Specified by:

getMinimumVersion in interface MetadataService

getPartitions

public scala.concurrent.Future<org.apache.pekko.stream.scaladsl.Source<com.here.platform.data.client.scaladsl.Partition,org.apache.pekko.NotUsed>> getPartitions(HRN hrn,
 InternalSettings settings,
 long version,
 String layer,
 VersionedLayerContext context,
 scala.collection.immutable.Set<AdditionalField> additionalFields,
 scala.Option<String> partId)

Specified by:

getPartitions in interface MetadataService

getPartitionsParts

public scala.concurrent.Future<com.here.platform.data.client.scaladsl.QueryParts> getPartitionsParts(HRN hrn,
 String layerId,
 int parts,
 InternalSettings settings)

Specified by:

getPartitionsParts in interface MetadataService

getVersions

public scala.concurrent.Future<scala.collection.immutable.Seq<VersionInfo>> getVersions(HRN hrn,
 InternalSettings settings,
 long startVersion,
 long endVersion)

Specified by:

getVersions in interface MetadataService

getVolatileChanges

public scala.concurrent.Future<org.apache.pekko.stream.scaladsl.Source<com.here.platform.data.client.scaladsl.Partition,org.apache.pekko.NotUsed>> getVolatileChanges(HRN hrn,
 InternalSettings settings,
 long sinceTime,
 String layer,
 scala.collection.immutable.Set<AdditionalField> additionalFields)

Specified by:

getVolatileChanges in interface MetadataService

getVolatileChangesNext

public scala.concurrent.Future<PartitionSinglePage> getVolatileChangesNext(HRN hrn,
 InternalSettings settings,
 String nextUrl)

Specified by:

getVolatileChangesNext in interface MetadataService

setMinimumVersion

public scala.concurrent.Future<org.apache.pekko.Done> setMinimumVersion(HRN hrn,
 long minVersion,
 InternalSettings settings)

Specified by:

setMinimumVersion in interface MetadataService