|
29 | 29 | import org.springframework.data.mapping.context.MappingContext; |
30 | 30 | import org.springframework.data.projection.ProjectionFactory; |
31 | 31 | import org.springframework.data.repository.core.RepositoryMetadata; |
32 | | -import org.springframework.data.repository.query.Parameters; |
33 | | -import org.springframework.data.repository.query.ParametersSource; |
34 | 32 | import org.springframework.data.repository.query.QueryMethod; |
35 | 33 | import org.springframework.data.util.TypeInformation; |
36 | 34 | import org.springframework.lang.Nullable; |
@@ -72,7 +70,7 @@ public class CassandraQueryMethod extends QueryMethod { |
72 | 70 | public CassandraQueryMethod(Method method, RepositoryMetadata repositoryMetadata, ProjectionFactory projectionFactory, |
73 | 71 | MappingContext<? extends CassandraPersistentEntity<?>, ? extends CassandraPersistentProperty> mappingContext) { |
74 | 72 |
|
75 | | - super(method, repositoryMetadata, projectionFactory); |
| 73 | + super(method, repositoryMetadata, projectionFactory, CassandraParameters::new); |
76 | 74 |
|
77 | 75 | Assert.notNull(mappingContext, "MappingContext must not be null"); |
78 | 76 |
|
@@ -129,11 +127,6 @@ public CassandraParameters getParameters() { |
129 | 127 | return (CassandraParameters) super.getParameters(); |
130 | 128 | } |
131 | 129 |
|
132 | | - @Override |
133 | | - protected Parameters<?, ?> createParameters(ParametersSource parametersSource) { |
134 | | - return new CassandraParameters(parametersSource); |
135 | | - } |
136 | | - |
137 | 130 | /** |
138 | 131 | * Returns whether the method has an annotated query. |
139 | 132 | */ |
|
0 commit comments