Package org.springframework.data.cassandra.repository.query

Class ReactiveCassandraQueryMethod

java.lang.Object

org.springframework.data.repository.query.QueryMethod

org.springframework.data.cassandra.repository.query.CassandraQueryMethod

org.springframework.data.cassandra.repository.query.ReactiveCassandraQueryMethod

public class ReactiveCassandraQueryMethod
extends CassandraQueryMethod

Reactive specific implementation of CassandraQueryMethod.

Since:

2.0

Author:

Mark Paluch

Constructor Summary

Constructors

Constructor	Description
ReactiveCassandraQueryMethod(Method method, org.springframework.data.repository.core.RepositoryMetadata metadata, org.springframework.data.projection.ProjectionFactory projectionFactory, org.springframework.data.mapping.context.MappingContext<? extends CassandraPersistentEntity<?>,? extends CassandraPersistentProperty> mappingContext)	Create a new ReactiveCassandraQueryMethod from the given Method.

Method Summary

Modifier and Type	Method	Description
boolean	hasReactiveWrapperParameter()	Check if the given QueryMethod receives a reactive parameter wrapper as one of its parameters.
boolean	isCollectionQuery()
boolean	isStreamQuery()

Methods inherited from class org.springframework.data.cassandra.repository.query.CassandraQueryMethod

createParameters, getAnnotatedQuery, getDomainClass, getEntityInformation, getParameters, getRequiredAnnotatedConsistencyLevel, getRequiredAnnotatedQuery, getReturnType, hasAnnotatedQuery, hasConsistencyLevel, isResultSetQuery, verify

Methods inherited from class org.springframework.data.repository.query.QueryMethod

createParameters, getName, getNamedQueryName, getResultProcessor, getReturnedObjectType, isModifyingQuery, isPageQuery, isQueryForEntity, isScrollQuery, isSliceQuery, toString

Methods inherited from class java.lang.Object

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

Constructor Details

ReactiveCassandraQueryMethod

public ReactiveCassandraQueryMethod(Method method,
 org.springframework.data.repository.core.RepositoryMetadata metadata,
 org.springframework.data.projection.ProjectionFactory projectionFactory,
 org.springframework.data.mapping.context.MappingContext<? extends CassandraPersistentEntity<?>,? extends CassandraPersistentProperty> mappingContext)

Create a new ReactiveCassandraQueryMethod from the given Method.

Parameters:

method - must not be null.

metadata - must not be null.

projectionFactory - must not be null.

mappingContext - must not be null.

Method Details

isCollectionQuery

public boolean isCollectionQuery()

Overrides:

isCollectionQuery in class org.springframework.data.repository.query.QueryMethod

isStreamQuery

public boolean isStreamQuery()

Overrides:

isStreamQuery in class org.springframework.data.repository.query.QueryMethod

hasReactiveWrapperParameter

public boolean hasReactiveWrapperParameter()

Check if the given QueryMethod receives a reactive parameter wrapper as one of its parameters.

Returns: