Package com.here.platform.data.client.utils.rsql

Class VersionedLayerQueryProcessor

java.lang.Object

com.here.platform.data.client.utils.rsql.VersionedLayerQueryProcessor

All Implemented Interfaces:

QueryProcessor

public class VersionedLayerQueryProcessor
extends Object
implements QueryProcessor

Wrapper around QueryApi that processes RSQL queries and returns the corresponding list of partitions.

Constructor Summary

Constructors

Constructor	Description
VersionedLayerQueryProcessor(com.here.platform.data.client.scaladsl.QueryApi queryApi, Layer layer, long latestVersion)

Method Summary

Modifier and Type	Method	Description
static VersionedLayerQueryProcessor	apply(com.here.platform.data.client.scaladsl.QueryApi queryApi, Layer layer, long version)
void	checkVersion(long version)
scala.collection.IterableOnce<com.here.platform.data.client.scaladsl.Partition>	find(String query)
ParallelizableResult	getParallelizableResult(String query, int parallelization)
static boolean	hasPartitionIdInQuery(String query)
static boolean	hasVersionInQuery(String query)
ParsedQuery	toParsedQuery(String query)

Methods inherited from class java.lang.Object

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

Constructor Details

VersionedLayerQueryProcessor

public VersionedLayerQueryProcessor(com.here.platform.data.client.scaladsl.QueryApi queryApi,
 Layer layer,
 long latestVersion)

Method Details

apply

public static VersionedLayerQueryProcessor apply(com.here.platform.data.client.scaladsl.QueryApi queryApi,
 Layer layer,
 long version)

hasVersionInQuery

public static boolean hasVersionInQuery(String query)

hasPartitionIdInQuery

public static boolean hasPartitionIdInQuery(String query)

find

public scala.collection.IterableOnce<com.here.platform.data.client.scaladsl.Partition> find(String query)

Specified by:

find in interface QueryProcessor

toParsedQuery

public ParsedQuery toParsedQuery(String query)

getParallelizableResult

public ParallelizableResult getParallelizableResult(String query,
 int parallelization)

checkVersion

public void checkVersion(long version)