This is an automated email from the ASF dual-hosted git repository.
petrov-mg pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ignite-extensions.git
The following commit(s) were added to refs/heads/master by this push:
new 928037d8 IGNITE-28604 Removed lazy flag support for Spring Data
extension (#347)
928037d8 is described below
commit 928037d83527e5e6e43a6b13425469367230456c
Author: Mikhail Petrov <[email protected]>
AuthorDate: Fri Apr 24 14:28:39 2026 +0300
IGNITE-28604 Removed lazy flag support for Spring Data extension (#347)
---
.../repository/config/DynamicQueryConfig.java | 36 -----
.../ignite/springdata/repository/config/Query.java | 19 ---
.../repository/query/IgniteRepositoryQuery.java | 3 +-
parent-internal/pom.xml | 169 ++++++++++-----------
4 files changed, 79 insertions(+), 148 deletions(-)
diff --git
a/modules/spring-data-ext/spring-data/src/main/java/org/apache/ignite/springdata/repository/config/DynamicQueryConfig.java
b/modules/spring-data-ext/spring-data/src/main/java/org/apache/ignite/springdata/repository/config/DynamicQueryConfig.java
index f7e3e225..e1130b46 100644
---
a/modules/spring-data-ext/spring-data/src/main/java/org/apache/ignite/springdata/repository/config/DynamicQueryConfig.java
+++
b/modules/spring-data-ext/spring-data/src/main/java/org/apache/ignite/springdata/repository/config/DynamicQueryConfig.java
@@ -53,9 +53,6 @@ public class DynamicQueryConfig {
/** */
private boolean distributedJoins;
- /** */
- private boolean lazy;
-
/** */
private boolean local;
@@ -79,7 +76,6 @@ public class DynamicQueryConfig {
cfg.timeout = queryConfiguration.timeout();
cfg.enforceJoinOrder = queryConfiguration.enforceJoinOrder();
cfg.distributedJoins = queryConfiguration.distributedJoins();
- cfg.lazy = queryConfiguration.lazy();
cfg.parts = queryConfiguration.parts();
cfg.local = queryConfiguration.local();
cfg.limit = queryConfiguration.limit();
@@ -173,27 +169,6 @@ public class DynamicQueryConfig {
return distributedJoins;
}
- /**
- * Sets lazy query execution flag.
- * <p>
- * By default Ignite attempts to fetch the whole query result set to
memory and send it to the client. For small and
- * medium result sets this provides optimal performance and minimize
duration of internal database locks, thus
- * increasing concurrency.
- * <p>
- * If result set is too big to fit in available memory this could lead to
excessive GC pauses and even
- * OutOfMemoryError. Use this flag as a hint for Ignite to fetch result
set lazily, thus minimizing memory
- * consumption at the cost of moderate performance hit.
- * <p>
- * Defaults to {@code false}, meaning that the whole result set is fetched
to memory eagerly.
- * <p>
- * Only applicable to SqlFieldsQuery
- *
- * @return the boolean
- */
- public boolean lazy() {
- return lazy;
- }
-
/**
* Sets whether this query should be executed on local node only.
*
@@ -303,17 +278,6 @@ public class DynamicQueryConfig {
return this;
}
- /**
- * Sets lazy.
- *
- * @param lazy the lazy
- * @return this for chaining
- */
- public DynamicQueryConfig setLazy(boolean lazy) {
- this.lazy = lazy;
- return this;
- }
-
/**
* Sets local.
*
diff --git
a/modules/spring-data-ext/spring-data/src/main/java/org/apache/ignite/springdata/repository/config/Query.java
b/modules/spring-data-ext/spring-data/src/main/java/org/apache/ignite/springdata/repository/config/Query.java
index bef9dd47..4c1629c9 100644
---
a/modules/spring-data-ext/spring-data/src/main/java/org/apache/ignite/springdata/repository/config/Query.java
+++
b/modules/spring-data-ext/spring-data/src/main/java/org/apache/ignite/springdata/repository/config/Query.java
@@ -106,25 +106,6 @@ public @interface Query {
*/
boolean distributedJoins() default false;
- /**
- * Sets lazy query execution flag.
- * <p>
- * By default Ignite attempts to fetch the whole query result set to
memory and send it to the client. For small and
- * medium result sets this provides optimal performance and minimize
duration of internal database locks, thus
- * increasing concurrency.
- * <p>
- * If result set is too big to fit in available memory this could lead to
excessive GC pauses and even
- * OutOfMemoryError. Use this flag as a hint for Ignite to fetch result
set lazily, thus minimizing memory
- * consumption at the cost of moderate performance hit.
- * <p>
- * Defaults to {@code false}, meaning that the whole result set is fetched
to memory eagerly.
- * <p>
- * Only applicable to SqlFieldsQuery
- *
- * @return {@code True} if flag is set.
- */
- boolean lazy() default false;
-
/**
* Sets whether this query should be executed on local node only.
*
diff --git
a/modules/spring-data-ext/spring-data/src/main/java/org/apache/ignite/springdata/repository/query/IgniteRepositoryQuery.java
b/modules/spring-data-ext/spring-data/src/main/java/org/apache/ignite/springdata/repository/query/IgniteRepositoryQuery.java
index 1fdf9438..0f5735a8 100644
---
a/modules/spring-data-ext/spring-data/src/main/java/org/apache/ignite/springdata/repository/query/IgniteRepositoryQuery.java
+++
b/modules/spring-data-ext/spring-data/src/main/java/org/apache/ignite/springdata/repository/query/IgniteRepositoryQuery.java
@@ -153,7 +153,7 @@ import static
org.apache.ignite.springdata.repository.support.IgniteRepositoryFa
* repo.searchUserByEmailWithQueryTuning("[email protected]", onlyTunning);
*
* DynamicQueryConfig withDynamicQuery = new
DynamicQueryConfig().value("SELECT * from #{#entityName} where
- * country = ?#{[0] and city =
?#{[1]}").setForceFieldsQuery(true).setLazy(true).setCollocated(true);
+ * country = ?#{[0] and city =
?#{[1]}").setForceFieldsQuery(true).setCollocated(true);
* repo.searchUsersByCityWithDynamicQuery("Spain", "Madrid", withDynamicQuery,
new PageRequest(0, 100));
*
* </pre>
@@ -777,7 +777,6 @@ public class IgniteRepositoryQuery implements
RepositoryQuery {
sqlFieldsQry.setCollocated(config.collocated());
sqlFieldsQry.setDistributedJoins(config.distributedJoins());
sqlFieldsQry.setEnforceJoinOrder(config.enforceJoinOrder());
- sqlFieldsQry.setLazy(config.lazy());
sqlFieldsQry.setLocal(config.local());
if (config.parts() != null && config.parts().length > 0)
diff --git a/parent-internal/pom.xml b/parent-internal/pom.xml
index 0685f2c8..6df25613 100644
--- a/parent-internal/pom.xml
+++ b/parent-internal/pom.xml
@@ -132,6 +132,84 @@
</execution>
</executions>
</plugin>
+
+ <plugin>
+ <groupId>org.apache.maven.plugins</groupId>
+ <artifactId>maven-compiler-plugin</artifactId>
+ <!-- Do not bring ignite logic -->
+ <inherited>false</inherited>
+ </plugin>
+ <plugin>
+ <groupId>org.apache.maven.plugins</groupId>
+ <artifactId>maven-surefire-plugin</artifactId>
+ <configuration>
+ <forkCount>1</forkCount>
+ <argLine>
+ --add-opens=java.base/jdk.internal.access=ALL-UNNAMED
+ --add-opens=java.base/jdk.internal.misc=ALL-UNNAMED
+ --add-opens=java.base/jdk.internal.ref=ALL-UNNAMED
+ --add-opens=java.base/jdk.internal.loader=ALL-UNNAMED
+ --add-opens=java.base/sun.nio.ch=ALL-UNNAMED
+
--add-opens=java.management/com.sun.jmx.mbeanserver=ALL-UNNAMED
+
--add-opens=jdk.internal.jvmstat/sun.jvmstat.monitor=ALL-UNNAMED
+
--add-opens=java.base/sun.reflect.generics.reflectiveObjects=ALL-UNNAMED
+
--add-opens=jdk.management/com.sun.management.internal=ALL-UNNAMED
+ --add-opens=java.base/java.io=ALL-UNNAMED
+ --add-opens=java.base/java.net=ALL-UNNAMED
+ --add-opens=java.base/java.nio=ALL-UNNAMED
+ --add-opens=java.base/java.security.cert=ALL-UNNAMED
+ --add-opens=java.base/java.util=ALL-UNNAMED
+ --add-opens=java.base/java.util.concurrent=ALL-UNNAMED
+
--add-opens=java.base/java.util.concurrent.locks=ALL-UNNAMED
+
--add-opens=java.base/java.util.concurrent.atomic=ALL-UNNAMED
+ --add-opens=java.base/java.lang=ALL-UNNAMED
+ --add-opens=java.base/java.lang.invoke=ALL-UNNAMED
+ --add-opens=java.base/java.time=ALL-UNNAMED
+ --add-opens=java.base/sun.security.ssl=ALL-UNNAMED
+ --add-opens=java.base/sun.security.x509=ALL-UNNAMED
+ --add-opens=java.base/sun.net.util=ALL-UNNAMED
+ --add-opens=java.sql/java.sql=ALL-UNNAMED
+ --add-opens=java.base/java.lang.reflect=ALL-UNNAMED
+ --add-opens=java.base/java.text=ALL-UNNAMED
+ --add-opens=java.desktop/java.awt.font=ALL-UNNAMED
+ </argLine>
+ </configuration>
+ </plugin>
+ <plugin>
+ <groupId>io.gatling</groupId>
+ <artifactId>gatling-maven-plugin</artifactId>
+ <configuration>
+ <jvmArgs>
+
<jvmArg>--add-opens=java.base/jdk.internal.access=ALL-UNNAMED</jvmArg>
+
<jvmArg>--add-opens=java.base/jdk.internal.misc=ALL-UNNAMED</jvmArg>
+
<jvmArg>--add-opens=java.base/jdk.internal.ref=ALL-UNNAMED</jvmArg>
+
<jvmArg>--add-opens=java.base/jdk.internal.loader=ALL-UNNAMED</jvmArg>
+
<jvmArg>--add-opens=java.base/sun.nio.ch=ALL-UNNAMED</jvmArg>
+
<jvmArg>--add-opens=java.management/com.sun.jmx.mbeanserver=ALL-UNNAMED</jvmArg>
+
<jvmArg>--add-opens=jdk.internal.jvmstat/sun.jvmstat.monitor=ALL-UNNAMED</jvmArg>
+
<jvmArg>--add-opens=java.base/sun.reflect.generics.reflectiveObjects=ALL-UNNAMED</jvmArg>
+
<jvmArg>--add-opens=jdk.management/com.sun.management.internal=ALL-UNNAMED</jvmArg>
+
<jvmArg>--add-opens=java.base/java.io=ALL-UNNAMED</jvmArg>
+
<jvmArg>--add-opens=java.base/java.net=ALL-UNNAMED</jvmArg>
+
<jvmArg>--add-opens=java.base/java.nio=ALL-UNNAMED</jvmArg>
+
<jvmArg>--add-opens=java.base/java.security.cert=ALL-UNNAMED</jvmArg>
+
<jvmArg>--add-opens=java.base/java.util=ALL-UNNAMED</jvmArg>
+
<jvmArg>--add-opens=java.base/java.util.concurrent=ALL-UNNAMED</jvmArg>
+
<jvmArg>--add-opens=java.base/java.util.concurrent.locks=ALL-UNNAMED</jvmArg>
+
<jvmArg>--add-opens=java.base/java.util.concurrent.atomic=ALL-UNNAMED</jvmArg>
+
<jvmArg>--add-opens=java.base/java.lang=ALL-UNNAMED</jvmArg>
+
<jvmArg>--add-opens=java.base/java.lang.invoke=ALL-UNNAMED</jvmArg>
+
<jvmArg>--add-opens=java.base/java.time=ALL-UNNAMED</jvmArg>
+
<jvmArg>--add-opens=java.base/sun.security.ssl=ALL-UNNAMED</jvmArg>
+
<jvmArg>--add-opens=java.base/sun.security.x509=ALL-UNNAMED</jvmArg>
+
<jvmArg>--add-opens=java.base/sun.net.util=ALL-UNNAMED</jvmArg>
+
<jvmArg>--add-opens=java.sql/java.sql=ALL-UNNAMED</jvmArg>
+
<jvmArg>--add-opens=java.base/java.lang.reflect=ALL-UNNAMED</jvmArg>
+
<jvmArg>--add-opens=java.base/java.text=ALL-UNNAMED</jvmArg>
+
<jvmArg>--add-opens=java.desktop/java.awt.font=ALL-UNNAMED</jvmArg>
+ </jvmArgs>
+ </configuration>
+ </plugin>
</plugins>
</build>
@@ -207,96 +285,5 @@
</plugins>
</build>
</profile>
- <profile>
- <id>java-11+</id>
- <activation>
- <jdk>[11,)</jdk>
- </activation>
- <properties>
- <maven.compiler.source>11</maven.compiler.source>
- <maven.compiler.target>11</maven.compiler.target>
- </properties>
- <build>
- <plugins>
- <plugin>
- <groupId>org.apache.maven.plugins</groupId>
- <artifactId>maven-compiler-plugin</artifactId>
- <!-- Do not bring ignite logic -->
- <inherited>false</inherited>
- </plugin>
- <plugin>
- <groupId>org.apache.maven.plugins</groupId>
- <artifactId>maven-surefire-plugin</artifactId>
- <configuration>
- <forkCount>1</forkCount>
- <argLine>
-
--add-opens=java.base/jdk.internal.access=ALL-UNNAMED
-
--add-opens=java.base/jdk.internal.misc=ALL-UNNAMED
-
--add-opens=java.base/jdk.internal.ref=ALL-UNNAMED
-
--add-opens=java.base/jdk.internal.loader=ALL-UNNAMED
- --add-opens=java.base/sun.nio.ch=ALL-UNNAMED
-
--add-opens=java.management/com.sun.jmx.mbeanserver=ALL-UNNAMED
-
--add-opens=jdk.internal.jvmstat/sun.jvmstat.monitor=ALL-UNNAMED
-
--add-opens=java.base/sun.reflect.generics.reflectiveObjects=ALL-UNNAMED
-
--add-opens=jdk.management/com.sun.management.internal=ALL-UNNAMED
- --add-opens=java.base/java.io=ALL-UNNAMED
- --add-opens=java.base/java.net=ALL-UNNAMED
- --add-opens=java.base/java.nio=ALL-UNNAMED
-
--add-opens=java.base/java.security.cert=ALL-UNNAMED
- --add-opens=java.base/java.util=ALL-UNNAMED
-
--add-opens=java.base/java.util.concurrent=ALL-UNNAMED
-
--add-opens=java.base/java.util.concurrent.locks=ALL-UNNAMED
-
--add-opens=java.base/java.util.concurrent.atomic=ALL-UNNAMED
- --add-opens=java.base/java.lang=ALL-UNNAMED
-
--add-opens=java.base/java.lang.invoke=ALL-UNNAMED
- --add-opens=java.base/java.time=ALL-UNNAMED
-
--add-opens=java.base/sun.security.ssl=ALL-UNNAMED
-
--add-opens=java.base/sun.security.x509=ALL-UNNAMED
- --add-opens=java.base/sun.net.util=ALL-UNNAMED
- --add-opens=java.sql/java.sql=ALL-UNNAMED
-
--add-opens=java.base/java.lang.reflect=ALL-UNNAMED
- --add-opens=java.base/java.text=ALL-UNNAMED
-
--add-opens=java.desktop/java.awt.font=ALL-UNNAMED
- </argLine>
- </configuration>
- </plugin>
- <plugin>
- <groupId>io.gatling</groupId>
- <artifactId>gatling-maven-plugin</artifactId>
- <configuration>
- <jvmArgs>
-
<jvmArg>--add-opens=java.base/jdk.internal.access=ALL-UNNAMED</jvmArg>
-
<jvmArg>--add-opens=java.base/jdk.internal.misc=ALL-UNNAMED</jvmArg>
-
<jvmArg>--add-opens=java.base/jdk.internal.ref=ALL-UNNAMED</jvmArg>
-
<jvmArg>--add-opens=java.base/jdk.internal.loader=ALL-UNNAMED</jvmArg>
-
<jvmArg>--add-opens=java.base/sun.nio.ch=ALL-UNNAMED</jvmArg>
-
<jvmArg>--add-opens=java.management/com.sun.jmx.mbeanserver=ALL-UNNAMED</jvmArg>
-
<jvmArg>--add-opens=jdk.internal.jvmstat/sun.jvmstat.monitor=ALL-UNNAMED</jvmArg>
-
<jvmArg>--add-opens=java.base/sun.reflect.generics.reflectiveObjects=ALL-UNNAMED</jvmArg>
-
<jvmArg>--add-opens=jdk.management/com.sun.management.internal=ALL-UNNAMED</jvmArg>
-
<jvmArg>--add-opens=java.base/java.io=ALL-UNNAMED</jvmArg>
-
<jvmArg>--add-opens=java.base/java.net=ALL-UNNAMED</jvmArg>
-
<jvmArg>--add-opens=java.base/java.nio=ALL-UNNAMED</jvmArg>
-
<jvmArg>--add-opens=java.base/java.security.cert=ALL-UNNAMED</jvmArg>
-
<jvmArg>--add-opens=java.base/java.util=ALL-UNNAMED</jvmArg>
-
<jvmArg>--add-opens=java.base/java.util.concurrent=ALL-UNNAMED</jvmArg>
-
<jvmArg>--add-opens=java.base/java.util.concurrent.locks=ALL-UNNAMED</jvmArg>
-
<jvmArg>--add-opens=java.base/java.util.concurrent.atomic=ALL-UNNAMED</jvmArg>
-
<jvmArg>--add-opens=java.base/java.lang=ALL-UNNAMED</jvmArg>
-
<jvmArg>--add-opens=java.base/java.lang.invoke=ALL-UNNAMED</jvmArg>
-
<jvmArg>--add-opens=java.base/java.time=ALL-UNNAMED</jvmArg>
-
<jvmArg>--add-opens=java.base/sun.security.ssl=ALL-UNNAMED</jvmArg>
-
<jvmArg>--add-opens=java.base/sun.security.x509=ALL-UNNAMED</jvmArg>
-
<jvmArg>--add-opens=java.base/sun.net.util=ALL-UNNAMED</jvmArg>
-
<jvmArg>--add-opens=java.sql/java.sql=ALL-UNNAMED</jvmArg>
-
<jvmArg>--add-opens=java.base/java.lang.reflect=ALL-UNNAMED</jvmArg>
-
<jvmArg>--add-opens=java.base/java.text=ALL-UNNAMED</jvmArg>
-
<jvmArg>--add-opens=java.desktop/java.awt.font=ALL-UNNAMED</jvmArg>
- </jvmArgs>
- </configuration>
- </plugin>
- </plugins>
- </build>
- </profile>
</profiles>
</project>
