org.springframework.data.aerospike.repository.query

Class ReactiveQueryEngine

java.lang.Object

org.springframework.data.aerospike.repository.query.ReactiveQueryEngine

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable

public class ReactiveQueryEngine
extends java.lang.Object
implements java.io.Closeable

Author:

luke 09-03-2019 00:18

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ReactiveQueryEngine.Meta

Constructor Summary

Constructors

Constructor and Description
ReactiveQueryEngine(java.util.Collection<com.aerospike.client.Host> hosts, com.aerospike.client.policy.ClientPolicy clientPolicy)

Method Summary

Modifier and Type	Method and Description
protected java.lang.String	buildFilterFunction(com.aerospike.helper.query.Qualifier[] qualifiers)
protected java.util.List<com.aerospike.client.query.PredExp>	buildPredExp(com.aerospike.helper.query.Qualifier[] qualifiers)
void	close() closes the QueryEngine, clearing the cached information are closing the AerospikeClient.
reactor.core.publisher.Mono<java.lang.Void>	createIndex(java.lang.String namespace, java.lang.String setName, java.lang.String indexName, java.lang.String binName, com.aerospike.client.query.IndexType indexType)
com.aerospike.client.query.Statement	createStatement(java.lang.String namespace, java.lang.String set, com.aerospike.client.query.Filter filter)
reactor.core.publisher.Mono<java.lang.Boolean>	delete(com.aerospike.client.Key key)
reactor.core.publisher.Mono<java.lang.Void>	deleteIndex(java.lang.String namespace, java.lang.String setName, java.lang.String indexName)
<T> com.aerospike.client.listener.DeleteListener	deleteListener(reactor.core.publisher.MonoSink<T> sink, T document)
reactor.core.publisher.Mono<java.lang.Boolean>	exists(com.aerospike.client.Key key)
<T> com.aerospike.client.listener.ExistsListener	existsListener(reactor.core.publisher.MonoSink<java.lang.Boolean> sink, T documents)
<T> reactor.core.publisher.Flux<T>	get(java.util.function.BiFunction<com.aerospike.client.Key,com.aerospike.client.Record,T> successFunction, com.aerospike.client.policy.BatchPolicy policy, com.aerospike.client.Key... keys)
<T> reactor.core.publisher.Mono<T>	get(java.util.function.BiFunction<com.aerospike.client.Key,com.aerospike.client.Record,T> successFunction, com.aerospike.client.policy.BatchPolicy policy, com.aerospike.client.Key key)
reactor.core.publisher.Mono<com.aerospike.client.query.KeyRecord>	get(com.aerospike.client.Key key, java.lang.String... binsName)
<T> reactor.core.publisher.Mono<T>	getAndTouch(java.util.function.BiFunction<com.aerospike.client.Key,com.aerospike.client.Record,T> succeFunction, com.aerospike.client.policy.WritePolicy writePolicy, com.aerospike.client.Key key)
reactor.core.publisher.Flux<com.aerospike.client.query.KeyRecord>	getHeader(com.aerospike.client.Key... keys)
java.util.Optional<com.aerospike.helper.model.Index>	getIndex(com.aerospike.helper.query.cache.IndexKey key) Gets a specific index from the index cache by Bin name
com.aerospike.helper.model.Module	getModule(java.lang.String moduleName) Gets a specific Module from the cache by name
com.aerospike.helper.model.Namespace	getNamespace(java.lang.String namespace) Get as specific Namespace from the cache
reactor.core.publisher.Mono<java.lang.Boolean>	indexExists(java.lang.String namespace, java.lang.String indexName)
protected boolean	isIndexedBin(com.aerospike.client.query.Statement stmt, com.aerospike.helper.query.Qualifier qualifier)
<T> reactor.core.publisher.Mono<T>	operate(java.util.function.BiFunction<com.aerospike.client.Key,com.aerospike.client.Record,T> successFunction, com.aerospike.client.policy.WritePolicy writePolicy, com.aerospike.client.Key key, com.aerospike.client.Operation... operations)
<T> reactor.core.publisher.Mono<T>	put(T document, com.aerospike.client.policy.WritePolicy writePolicy, com.aerospike.client.Key key, com.aerospike.client.Bin... bins)
<T> reactor.core.publisher.Flux<T>	query(java.util.function.BiFunction<com.aerospike.client.Key,com.aerospike.client.Record,T> successFunction, com.aerospike.client.policy.QueryPolicy queryPolicy, com.aerospike.client.query.Statement statement)
reactor.core.publisher.Flux<com.aerospike.client.query.KeyRecord>	query(com.aerospike.client.query.Statement statement)
<T> com.aerospike.client.listener.RecordListener	recordListener(reactor.core.publisher.MonoSink<T> sink, java.util.function.BiFunction<com.aerospike.client.Key,com.aerospike.client.Record,T> successFunction)
<T> com.aerospike.client.listener.RecordSequenceListener	recordSequenceListener(reactor.core.publisher.FluxSink<T> sink, java.util.function.BiFunction<com.aerospike.client.Key,com.aerospike.client.Record,T> successFunction)
void	refreshCluster() refreshes the cached Cluster information
void	refreshIndexes() refreshes the Index cache from the Cluster
void	refreshModules() refreshes the Module cache from the cluster.
void	refreshNamespaceData(com.aerospike.client.cluster.Node node, com.aerospike.helper.model.Namespace namespace)
void	refreshNamespaces() refreshes the cached Namespace information
reactor.core.publisher.Flux<com.aerospike.client.query.KeyRecord>	select(java.lang.String namespace, java.lang.String set, com.aerospike.client.query.Filter filter, com.aerospike.helper.query.Qualifier... qualifiers) Select records filtered by a Filter and Qualifiers
<T> com.aerospike.client.listener.WriteListener	writeListener(reactor.core.publisher.MonoSink<T> sink, T document)
java.util.function.Function<reactor.core.publisher.MonoSink<?>,com.aerospike.client.listener.WriteListener>	writeListenerFunction()

Methods inherited from class java.lang.Object

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

Constructor Detail

ReactiveQueryEngine

public ReactiveQueryEngine(java.util.Collection<com.aerospike.client.Host> hosts,
                           com.aerospike.client.policy.ClientPolicy clientPolicy)

Method Detail

createIndex

public reactor.core.publisher.Mono<java.lang.Void> createIndex(java.lang.String namespace,
                                                               java.lang.String setName,
                                                               java.lang.String indexName,
                                                               java.lang.String binName,
                                                               com.aerospike.client.query.IndexType indexType)

deleteIndex

public reactor.core.publisher.Mono<java.lang.Void> deleteIndex(java.lang.String namespace,
                                                               java.lang.String setName,
                                                               java.lang.String indexName)

indexExists

public reactor.core.publisher.Mono<java.lang.Boolean> indexExists(java.lang.String namespace,
                                                                  java.lang.String indexName)

put

public <T> reactor.core.publisher.Mono<T> put(T document,
                                              com.aerospike.client.policy.WritePolicy writePolicy,
                                              com.aerospike.client.Key key,
                                              com.aerospike.client.Bin... bins)

delete

public reactor.core.publisher.Mono<java.lang.Boolean> delete(com.aerospike.client.Key key)

exists

public reactor.core.publisher.Mono<java.lang.Boolean> exists(com.aerospike.client.Key key)

query

public <T> reactor.core.publisher.Flux<T> query(java.util.function.BiFunction<com.aerospike.client.Key,com.aerospike.client.Record,T> successFunction,
                                                com.aerospike.client.policy.QueryPolicy queryPolicy,
                                                com.aerospike.client.query.Statement statement)

get

public <T> reactor.core.publisher.Flux<T> get(java.util.function.BiFunction<com.aerospike.client.Key,com.aerospike.client.Record,T> successFunction,
                                              com.aerospike.client.policy.BatchPolicy policy,
                                              com.aerospike.client.Key... keys)

get

public <T> reactor.core.publisher.Mono<T> get(java.util.function.BiFunction<com.aerospike.client.Key,com.aerospike.client.Record,T> successFunction,
                                              com.aerospike.client.policy.BatchPolicy policy,
                                              com.aerospike.client.Key key)

operate

public <T> reactor.core.publisher.Mono<T> operate(java.util.function.BiFunction<com.aerospike.client.Key,com.aerospike.client.Record,T> successFunction,
                                                  com.aerospike.client.policy.WritePolicy writePolicy,
                                                  com.aerospike.client.Key key,
                                                  com.aerospike.client.Operation... operations)

getAndTouch

public <T> reactor.core.publisher.Mono<T> getAndTouch(java.util.function.BiFunction<com.aerospike.client.Key,com.aerospike.client.Record,T> succeFunction,
                                                      com.aerospike.client.policy.WritePolicy writePolicy,
                                                      com.aerospike.client.Key key)

select

public reactor.core.publisher.Flux<com.aerospike.client.query.KeyRecord> select(java.lang.String namespace,
                                                                                java.lang.String set,
                                                                                com.aerospike.client.query.Filter filter,
                                                                                com.aerospike.helper.query.Qualifier... qualifiers)

Select records filtered by a Filter and Qualifiers

Parameters:

namespace - Namespace to storing the data

set - Set storing the data

filter - Aerospike Filter to be used

qualifiers - Zero or more Qualifiers for the update query

Returns:

A KeyRecordIterator to iterate over the results

createStatement

public com.aerospike.client.query.Statement createStatement(java.lang.String namespace,
                                                            java.lang.String set,
                                                            com.aerospike.client.query.Filter filter)

query

public reactor.core.publisher.Flux<com.aerospike.client.query.KeyRecord> query(com.aerospike.client.query.Statement statement)

getHeader

public reactor.core.publisher.Flux<com.aerospike.client.query.KeyRecord> getHeader(com.aerospike.client.Key... keys)

get

public reactor.core.publisher.Mono<com.aerospike.client.query.KeyRecord> get(com.aerospike.client.Key key,
                                                                             java.lang.String... binsName)

isIndexedBin

protected boolean isIndexedBin(com.aerospike.client.query.Statement stmt,
                               com.aerospike.helper.query.Qualifier qualifier)

buildPredExp

protected java.util.List<com.aerospike.client.query.PredExp> buildPredExp(com.aerospike.helper.query.Qualifier[] qualifiers)
                                                                   throws com.aerospike.helper.query.PredExpException

Throws:

com.aerospike.helper.query.PredExpException

buildFilterFunction

protected java.lang.String buildFilterFunction(com.aerospike.helper.query.Qualifier[] qualifiers)

refreshCluster

public void refreshCluster()

refreshes the cached Cluster information

refreshNamespaces

public void refreshNamespaces()

refreshes the cached Namespace information

refreshNamespaceData

public void refreshNamespaceData(com.aerospike.client.cluster.Node node,
                                 com.aerospike.helper.model.Namespace namespace)

getNamespace

public com.aerospike.helper.model.Namespace getNamespace(java.lang.String namespace)

Get as specific Namespace from the cache

Parameters:

namespace - Namespace name

Returns:

The Namespace model object

refreshIndexes

public void refreshIndexes()

refreshes the Index cache from the Cluster

getIndex

public java.util.Optional<com.aerospike.helper.model.Index> getIndex(com.aerospike.helper.query.cache.IndexKey key)

Gets a specific index from the index cache by Bin name

Parameters:

key - The key = namespace:set:bin built from the indexed Bin

Returns:

An Index model object

refreshModules

public void refreshModules()

refreshes the Module cache from the cluster. The Module cache contains a list of register UDF modules.

getModule

public com.aerospike.helper.model.Module getModule(java.lang.String moduleName)

Gets a specific Module from the cache by name

Parameters:

moduleName - The name of the module

Returns:

A Module model object

close

public void close()
           throws java.io.IOException

closes the QueryEngine, clearing the cached information are closing the AerospikeClient. Once the QueryEngine is closed, it cannot be used, nor can the AerospikeClient.

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Throws:

java.io.IOException

writeListenerFunction

public java.util.function.Function<reactor.core.publisher.MonoSink<?>,com.aerospike.client.listener.WriteListener> writeListenerFunction()

writeListener

public <T> com.aerospike.client.listener.WriteListener writeListener(reactor.core.publisher.MonoSink<T> sink,
                                                                     T document)

existsListener

public <T> com.aerospike.client.listener.ExistsListener existsListener(reactor.core.publisher.MonoSink<java.lang.Boolean> sink,
                                                                       T documents)

deleteListener

public <T> com.aerospike.client.listener.DeleteListener deleteListener(reactor.core.publisher.MonoSink<T> sink,
                                                                       T document)

recordListener

public <T> com.aerospike.client.listener.RecordListener recordListener(reactor.core.publisher.MonoSink<T> sink,
                                                                       java.util.function.BiFunction<com.aerospike.client.Key,com.aerospike.client.Record,T> successFunction)

recordSequenceListener

public <T> com.aerospike.client.listener.RecordSequenceListener recordSequenceListener(reactor.core.publisher.FluxSink<T> sink,
                                                                                       java.util.function.BiFunction<com.aerospike.client.Key,com.aerospike.client.Record,T> successFunction)