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

Class DefaultIndexService

java.lang.Object

com.here.platform.data.client.service.index.DefaultIndexService

All Implemented Interfaces:

IndexService

public class DefaultIndexService
extends Object
implements IndexService

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	DefaultIndexService.AdditionPartition
class	DefaultIndexService.AdditionPartition$
class	DefaultIndexService.RemovalPartition
class	DefaultIndexService.RemovalPartition$
static interface	DefaultIndexService.UpdatePartition

Constructor Summary

Constructors

Constructor	Description
DefaultIndexService(HttpHandler httpHandler, CatalogConfiguration catalogConfiguration, ClientExecutionContext clientExecutionContext)

Method Summary

Modifier and Type	Method	Description
scala.concurrent.Future<String>	deleteIndexes(HRN hrn, String layerId, String queryString, InternalSettings settings)
scala.concurrent.Future<DeleteIndexesStatusResponse>	deleteIndexesStatus(HRN hrn, String layerId, String deleteId, InternalSettings settings)
scala.concurrent.Future<com.here.platform.data.client.scaladsl.IndexParts>	getParts(HRN hrn, String layerId, int parts, InternalSettings settings)
scala.concurrent.Future<org.apache.pekko.Done>	index(HRN hrn, String layerId, org.apache.pekko.stream.scaladsl.Source<IndexingPartition,org.apache.pekko.NotUsed> partitions, InternalSettings settings)
scala.concurrent.Future<org.apache.pekko.stream.scaladsl.Source<com.here.platform.data.client.scaladsl.IndexPartition,org.apache.pekko.NotUsed>>	query(HRN hrn, String layerId, scala.Option<String> queryString, InternalSettings settings, scala.Option<String> partId)
scala.concurrent.Future<org.apache.pekko.Done>	updateIndex(HRN hrn, String layerId, org.apache.pekko.stream.scaladsl.Source<IndexingPartition,org.apache.pekko.NotUsed> additions, org.apache.pekko.stream.scaladsl.Source<IndexingPartition,org.apache.pekko.NotUsed> removals, InternalSettings settings)

Methods inherited from class java.lang.Object

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

Constructor Details

DefaultIndexService

public DefaultIndexService(HttpHandler httpHandler,
 CatalogConfiguration catalogConfiguration,
 ClientExecutionContext clientExecutionContext)

Method Details

deleteIndexes

public scala.concurrent.Future<String> deleteIndexes(HRN hrn,
 String layerId,
 String queryString,
 InternalSettings settings)

Specified by:

deleteIndexes in interface IndexService

deleteIndexesStatus

public scala.concurrent.Future<DeleteIndexesStatusResponse> deleteIndexesStatus(HRN hrn,
 String layerId,
 String deleteId,
 InternalSettings settings)

Specified by:

deleteIndexesStatus in interface IndexService

getParts

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

Specified by:

getParts in interface IndexService

index

public scala.concurrent.Future<org.apache.pekko.Done> index(HRN hrn,
 String layerId,
 org.apache.pekko.stream.scaladsl.Source<IndexingPartition,org.apache.pekko.NotUsed> partitions,
 InternalSettings settings)

Specified by:

index in interface IndexService

query

public scala.concurrent.Future<org.apache.pekko.stream.scaladsl.Source<com.here.platform.data.client.scaladsl.IndexPartition,org.apache.pekko.NotUsed>> query(HRN hrn,
 String layerId,
 scala.Option<String> queryString,
 InternalSettings settings,
 scala.Option<String> partId)

Specified by:

query in interface IndexService

updateIndex

public scala.concurrent.Future<org.apache.pekko.Done> updateIndex(HRN hrn,
 String layerId,
 org.apache.pekko.stream.scaladsl.Source<IndexingPartition,org.apache.pekko.NotUsed> additions,
 org.apache.pekko.stream.scaladsl.Source<IndexingPartition,org.apache.pekko.NotUsed> removals,
 InternalSettings settings)

Specified by:

updateIndex in interface IndexService