pl.edu.agh.age.compute.api

Interface QueryProcessor<T>

Type Parameters:

T - type of objects that are queried. It is up to the compute application to know what it will be using.

All Known Implementing Classes:

DefaultQueryProcessor

public interface QueryProcessor<T>

Simple query provider for compute-level.

The query processor operates on cached, not up-to-date data. It is the responsibility of the compute application to prepare the data for cache (through providing a Callable to the schedule(Callable) method. Each instance (separate node) of the compute application can prepare only one object at time (each consecutive returned objects will replace the old one.

Method Summary

Modifier and Type	Method and Description
java.util.stream.Stream<T>	query() Create a stream of objects to query.
void	schedule(java.util.concurrent.Callable<T> callable) Schedule a cache generator.

Method Detail

query

java.util.stream.Stream<T> query()

Create a stream of objects to query.

Returns:

a stream.

schedule

void schedule(java.util.concurrent.Callable<T> callable)

Schedule a cache generator.

Parameters:

callable - callable that creates objects for future queries.