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

Interface MetadataService

All Known Implementing Classes:

DefaultMetadataService

public interface MetadataService

Method Summary

Modifier and Type	Method	Description
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 internalSettings)

Method Details

getChanges

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)

getChangesParts

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

getCompatibleVersions

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)

getLatestVersion

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

getLayerVersions

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

getMinimumVersion

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

getPartitions

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)

getPartitionsParts

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

getVersions

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

getVolatileChanges

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)

getVolatileChangesNext

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

setMinimumVersion

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