Class DefaultMetadataService
java.lang.Object
com.here.platform.data.client.service.metadata.DefaultMetadataService
- All Implemented Interfaces:
MetadataService
-
Constructor Summary
ConstructorsConstructorDescriptionDefaultMetadataService(HttpHandler httpHandler, ClientExecutionContext clientExecutionContext) -
Method Summary
Modifier and TypeMethodDescriptioncom.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)
-
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:
getChangesin interfaceMetadataService
-
getChangesParts
public scala.concurrent.Future<com.here.platform.data.client.scaladsl.QueryParts> getChangesParts(HRN hrn, String layerId, int parts, InternalSettings settings) - Specified by:
getChangesPartsin interfaceMetadataService
-
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:
getCompatibleVersionsin interfaceMetadataService
-
getLatestVersion
public scala.concurrent.Future<scala.Option<Object>> getLatestVersion(HRN hrn, InternalSettings settings, scala.Option<Object> startVersion) - Specified by:
getLatestVersionin interfaceMetadataService
-
getLayerVersions
public scala.concurrent.Future<LayerVersions> getLayerVersions(HRN hrn, InternalSettings settings, long version) - Specified by:
getLayerVersionsin interfaceMetadataService
-
getMinimumVersion
public scala.concurrent.Future<scala.Option<Object>> getMinimumVersion(HRN hrn, InternalSettings settings) - Specified by:
getMinimumVersionin interfaceMetadataService
-
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:
getPartitionsin interfaceMetadataService
-
getPartitionsParts
public scala.concurrent.Future<com.here.platform.data.client.scaladsl.QueryParts> getPartitionsParts(HRN hrn, String layerId, int parts, InternalSettings settings) - Specified by:
getPartitionsPartsin interfaceMetadataService
-
getVersions
public scala.concurrent.Future<scala.collection.immutable.Seq<VersionInfo>> getVersions(HRN hrn, InternalSettings settings, long startVersion, long endVersion) - Specified by:
getVersionsin interfaceMetadataService
-
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:
getVolatileChangesin interfaceMetadataService
-
getVolatileChangesNext
public scala.concurrent.Future<PartitionSinglePage> getVolatileChangesNext(HRN hrn, InternalSettings settings, String nextUrl) - Specified by:
getVolatileChangesNextin interfaceMetadataService
-
setMinimumVersion
public scala.concurrent.Future<org.apache.pekko.Done> setMinimumVersion(HRN hrn, long minVersion, InternalSettings settings) - Specified by:
setMinimumVersionin interfaceMetadataService
-