[ignite-3] branch main updated (42d717ed93 -> 22efe81f33)
This is an automated email from the ASF dual-hosted git repository. sk0x50 pushed a change to branch main in repository https://gitbox.apache.org/repos/asf/ignite-3.git from 42d717ed93 IGNITE-18670: Sql. It is possible to reference aliases in GROUP BY clause. (#2545) add 22efe81f33 IGNITE-20354 Reduce code duplication in commit cleanup (#2557) No new revisions were added by this update. Summary of changes: .../table/distributed/StorageUpdateHandler.java| 106 +++-- .../table/distributed/raft/PartitionListener.java | 59 ++-- .../replicator/PartitionReplicaListener.java | 52 ++ .../table/distributed/replicator/PendingRows.java | 99 +++ .../internal/table/distributed/IndexBaseTest.java | 12 ++- .../table/distributed/IndexCleanupTest.java| 13 ++- .../distributed/StorageUpdateHandlerTest.java | 2 + 7 files changed, 229 insertions(+), 114 deletions(-) create mode 100644 modules/table/src/main/java/org/apache/ignite/internal/table/distributed/replicator/PendingRows.java
[ignite-3] branch main updated: IGNITE-19791 Sql. Introduce SqlRowHandler that supports binary tuple rows (#2512)
This is an automated email from the ASF dual-hosted git repository.
ppa pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
The following commit(s) were added to refs/heads/main by this push:
new 6df2cc270a IGNITE-19791 Sql. Introduce SqlRowHandler that supports
binary tuple rows (#2512)
6df2cc270a is described below
commit 6df2cc270ab8c870b547303b90fb60ee109ac04e
Author: Pavel Pereslegin
AuthorDate: Thu Sep 7 15:23:40 2023 +0300
IGNITE-19791 Sql. Introduce SqlRowHandler that supports binary tuple rows
(#2512)
---
.../internal/sql/engine/ItSqlOperatorsTest.java| 7 +-
.../ignite/internal/schema/row/InternalTuple.java | 16 +
.../internal/sql/engine/SqlQueryProcessor.java | 4 +-
.../internal/sql/engine/exec/RowHandler.java | 24 ++
.../internal/sql/engine/exec/SqlRowHandler.java| 411 +
.../sql/engine/exec/TableRowConverterImpl.java | 48 ++-
.../sql/engine/exec/exp/ExpressionFactoryImpl.java | 13 +-
.../sql/engine/exec/exp/agg/Accumulators.java | 65 +++-
.../internal/sql/engine/exec/rel/ModifyNode.java | 23 +-
.../sql/engine/exec/row/RowSchemaTypes.java| 24 ++
.../ignite/internal/sql/engine/util/TypeUtils.java | 2 +-
.../sql/engine/exec/ExecutionServiceImplTest.java | 1 +
.../exec/IdentityDistributionFunctionSelfTest.java | 18 +-
.../sql/engine/exec/RuntimeSortedIndexTest.java| 1 +
.../sql/engine/exec/rel/AbstractExecutionTest.java | 8 +-
.../engine/exec/rel/MergeJoinExecutionTest.java| 2 +-
.../engine/exec/rel/ScannableTableSelfTest.java| 2 +-
.../sql/engine/exec/row/SqlRowHandlerTest.java | 254 +
.../sql/engine/framework}/ArrayRowHandler.java | 22 +-
.../sql/engine/framework/TestBuilders.java | 1 -
.../internal/sql/engine/framework/TestNode.java| 1 -
.../sql/engine/util/HashFunctionsTest.java | 2 +-
.../internal/sql/engine/util/SqlTestUtils.java | 3 +-
23 files changed, 874 insertions(+), 78 deletions(-)
diff --git
a/modules/runner/src/integrationTest/java/org/apache/ignite/internal/sql/engine/ItSqlOperatorsTest.java
b/modules/runner/src/integrationTest/java/org/apache/ignite/internal/sql/engine/ItSqlOperatorsTest.java
index 3c5f6b0596..b4b03f8c6c 100644
---
a/modules/runner/src/integrationTest/java/org/apache/ignite/internal/sql/engine/ItSqlOperatorsTest.java
+++
b/modules/runner/src/integrationTest/java/org/apache/ignite/internal/sql/engine/ItSqlOperatorsTest.java
@@ -17,7 +17,6 @@
package org.apache.ignite.internal.sql.engine;
-import java.math.BigDecimal;
import java.time.LocalDate;
import java.time.LocalDateTime;
import java.time.Period;
@@ -193,13 +192,15 @@ public class ItSqlOperatorsTest extends
ClusterPerClassIntegrationTest {
assertExpression("COT(1)").returns(1.0d / Math.tan(1)).check();
assertExpression("DEGREES(1)").returns(Math.toDegrees(1)).check();
assertExpression("RADIANS(1)").returns(Math.toRadians(1)).check();
-assertExpression("ROUND(1.7)").returns(BigDecimal.valueOf(2)).check();
+// TODO https://issues.apache.org/jira/browse/IGNITE-20311
+//
assertExpression("ROUND(1.7)").returns(BigDecimal.valueOf(2)).check();
assertExpression("SIGN(-5)").returns(-1).check();
assertExpression("SIN(1)").returns(Math.sin(1)).check();
assertExpression("SINH(1)").returns(Math.sinh(1)).check();
assertExpression("TAN(1)").returns(Math.tan(1)).check();
assertExpression("TANH(1)").returns(Math.tanh(1)).check();
-
assertExpression("TRUNCATE(1.7)").returns(BigDecimal.valueOf(1)).check();
+// TODO https://issues.apache.org/jira/browse/IGNITE-20311
+//
assertExpression("TRUNCATE(1.7)").returns(BigDecimal.valueOf(1)).check();
assertExpression("PI").returns(Math.PI).check();
}
diff --git
a/modules/schema/src/main/java/org/apache/ignite/internal/schema/row/InternalTuple.java
b/modules/schema/src/main/java/org/apache/ignite/internal/schema/row/InternalTuple.java
index 642f5ccdd2..c3e242e7bc 100644
---
a/modules/schema/src/main/java/org/apache/ignite/internal/schema/row/InternalTuple.java
+++
b/modules/schema/src/main/java/org/apache/ignite/internal/schema/row/InternalTuple.java
@@ -46,6 +46,22 @@ public interface InternalTuple {
*/
boolean hasNullValue(int col);
+/**
+ * Reads value for specified column.
+ *
+ * @param col Column index.
+ * @return Column value.
+ */
+boolean booleanValue(int col);
+
+/**
+ * Reads value for specified column.
+ *
+ * @param col Column index.
+ * @return Column value.
+ */
+Boolean booleanValueBoxed(int col);
+
/**
* Reads value for specified column.
*
diff --git
a/modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/SqlQueryProcessor.java
b/modules/sql-engine/src/main/java/org/apache/ignite/internal
[ignite-3] branch catalog-feature updated (49b281def2 -> d6bb0cdaef)
This is an automated email from the ASF dual-hosted git repository. tkalkirill pushed a change to branch catalog-feature in repository https://gitbox.apache.org/repos/asf/ignite-3.git from 49b281def2 Merge branch 'ai-main' into catalog-feature add d6bb0cdaef CATALOG-FEATURE-FIX-TESTS-2023-09-07 Fix from Orlov (#2561) No new revisions were added by this update. Summary of changes: .../ItIgniteDistributionZoneManagerNodeRestartTest.java | 2 ++ .../apache/ignite/internal/tx/impl/TxManagerImpl.java| 16 .../org/apache/ignite/internal/tx/TxManagerTest.java | 3 +++ 3 files changed, 13 insertions(+), 8 deletions(-)
[ignite-3] branch main updated: IGNITE-17578 Transactions: async cleanup processing on tx commit (#2529)
This is an automated email from the ASF dual-hosted git repository.
sanpwc pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
The following commit(s) were added to refs/heads/main by this push:
new 33e83aa9f5 IGNITE-17578 Transactions: async cleanup processing on tx
commit (#2529)
33e83aa9f5 is described below
commit 33e83aa9f5b1a0fd50e6679129d526772d74b985
Author: Denis Chudov
AuthorDate: Thu Sep 7 18:19:22 2023 +0300
IGNITE-17578 Transactions: async cleanup processing on tx commit (#2529)
---
...ItTxDistributedTestThreeNodesThreeReplicas.java | 8 +++
...butedTestThreeNodesThreeReplicasCollocated.java | 8 +++
.../replicator/PartitionReplicaListener.java | 27 +++---
.../apache/ignite/distributed/ItTxTestCluster.java | 8 +++
4 files changed, 38 insertions(+), 13 deletions(-)
diff --git
a/modules/table/src/integrationTest/java/org/apache/ignite/distributed/ItTxDistributedTestThreeNodesThreeReplicas.java
b/modules/table/src/integrationTest/java/org/apache/ignite/distributed/ItTxDistributedTestThreeNodesThreeReplicas.java
index 71dbcb273a..966ae8cacb 100644
---
a/modules/table/src/integrationTest/java/org/apache/ignite/distributed/ItTxDistributedTestThreeNodesThreeReplicas.java
+++
b/modules/table/src/integrationTest/java/org/apache/ignite/distributed/ItTxDistributedTestThreeNodesThreeReplicas.java
@@ -22,6 +22,7 @@ import static org.junit.jupiter.api.Assertions.assertTrue;
import java.util.concurrent.TimeUnit;
import org.apache.ignite.internal.testframework.IgniteTestUtils;
import org.junit.jupiter.api.AfterEach;
+import org.junit.jupiter.api.Disabled;
import org.junit.jupiter.api.TestInfo;
/**
@@ -49,6 +50,13 @@ public class ItTxDistributedTestThreeNodesThreeReplicas
extends ItTxDistributedT
return 3;
}
+/** {@inheritDoc} */
+@Disabled("https://issues.apache.org/jira/browse/IGNITE-20116";)
+@Override
+public void testBalance() throws InterruptedException {
+super.testBalance();
+}
+
@Override
@AfterEach
public void after() throws Exception {
diff --git
a/modules/table/src/integrationTest/java/org/apache/ignite/distributed/ItTxDistributedTestThreeNodesThreeReplicasCollocated.java
b/modules/table/src/integrationTest/java/org/apache/ignite/distributed/ItTxDistributedTestThreeNodesThreeReplicasCollocated.java
index 79a6080e6b..e128acac09 100644
---
a/modules/table/src/integrationTest/java/org/apache/ignite/distributed/ItTxDistributedTestThreeNodesThreeReplicasCollocated.java
+++
b/modules/table/src/integrationTest/java/org/apache/ignite/distributed/ItTxDistributedTestThreeNodesThreeReplicasCollocated.java
@@ -25,6 +25,7 @@ import java.util.UUID;
import org.apache.ignite.internal.tx.TxState;
import org.apache.ignite.internal.tx.impl.ReadWriteTransactionImpl;
import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Disabled;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.TestInfo;
@@ -46,6 +47,13 @@ public class
ItTxDistributedTestThreeNodesThreeReplicasCollocated extends ItTxDi
return false;
}
+/** {@inheritDoc} */
+@Disabled("https://issues.apache.org/jira/browse/IGNITE-20116";)
+@Override
+public void testBalance() throws InterruptedException {
+super.testBalance();
+}
+
/** {@inheritDoc} */
@BeforeEach
@Override public void before() throws Exception {
diff --git
a/modules/table/src/main/java/org/apache/ignite/internal/table/distributed/replicator/PartitionReplicaListener.java
b/modules/table/src/main/java/org/apache/ignite/internal/table/distributed/replicator/PartitionReplicaListener.java
index ee9f8de59a..9d5c3faab0 100644
---
a/modules/table/src/main/java/org/apache/ignite/internal/table/distributed/replicator/PartitionReplicaListener.java
+++
b/modules/table/src/main/java/org/apache/ignite/internal/table/distributed/replicator/PartitionReplicaListener.java
@@ -69,6 +69,8 @@ import
org.apache.ignite.internal.catalog.descriptors.CatalogIndexDescriptor;
import org.apache.ignite.internal.catalog.descriptors.CatalogTableDescriptor;
import org.apache.ignite.internal.hlc.HybridClock;
import org.apache.ignite.internal.hlc.HybridTimestamp;
+import org.apache.ignite.internal.logger.IgniteLogger;
+import org.apache.ignite.internal.logger.Loggers;
import org.apache.ignite.internal.raft.Command;
import org.apache.ignite.internal.raft.Peer;
import org.apache.ignite.internal.raft.service.RaftGroupService;
@@ -158,6 +160,9 @@ import org.jetbrains.annotations.Nullable;
/** Partition replication listener. */
public class PartitionReplicaListener implements ReplicaListener {
+/** Logger. */
+private static final IgniteLogger LOG =
Loggers.forClass(PartitionReplicaListener.class);
+
/** Factory to create RAFT command messages. */
private static final TableMessagesFactory MSG_FACTORY = new
TableMessagesFactory();
@@ -
[ignite-extensions] branch ignite-18302 updated (f984c2c1 -> 26b5a035)
This is an automated email from the ASF dual-hosted git repository. anovikov pushed a change to branch ignite-18302 in repository https://gitbox.apache.org/repos/asf/ignite-extensions.git from f984c2c1 IGNITE-18302 Fixed javadoc. add 26b5a035 IGNITE-18302 Fixed license header. No new revisions were added by this update. Summary of changes: .../apache/ignite/spring/sessions/IgniteSession.java| 17 + 1 file changed, 17 insertions(+)
