You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by am...@apache.org on 2021/06/29 08:02:48 UTC
[ignite-3] branch ignite-14951 updated (b774e5b -> e5b505b)
This is an automated email from the ASF dual-hosted git repository.
amashenkov pushed a change to branch ignite-14951
in repository https://gitbox.apache.org/repos/asf/ignite-3.git.
from b774e5b Styles.
add 7d42f95 IGNITE-14853 Stabilize flaky tests in jraft module - Fixes #176.
add 0f8846f IGNITE-14799 Added prefix queries to MetaStorageManager. Fixes #159
add 972672f IGNITE-14835 Calcite SQL engine. Move execution related code to Ignite 3.0 (#182)
add 2ef376c IGNITE-14890 Using SLF4J log format. Fixes #175
add 4c93ea1 IGNITE-14993 - Choose available port out of a range
add 262022f IGNITE-14994 - Topology snapshot print out
add 5b81332 IGNITE-14995 - Updated NOTICE
add adfc9d4 IGNITE-14996 - Added examples for Table and KeyValueBinaryView
add 9230f61 IGNITE-14996 - Updated examples structure
add 7140111 IGNITE-15005 - Binary distribution README
add e57bc8d IGNITE-14571 - Release procedure documentation
add 3fdeaf4 IGNITE-14957 Introduced the NetworkAddress class. Fixes #185
add 062550c IGNITE-14996 - Modules order fix.
add 62f4e65 IGNITE-15014 Explicit annotation processor dependency in api module. (#186)
add 8c7912d IGNITE-15016 Remove integration tests execution if maven.test.skip is set (#187)
add f5efe45 IGNITE-14745 Implemented Storage API for partitions and 2 basic implementations - CHM and RocksDB. (#169)
add b874180 IGNITE-14408 Implement the Vault Service on top of RocksDB (#174)
add 41ee54f IGNITE-15021 Apache Rat plugin does not check full text license (#189)
add e5b505b Merge branch 'main' into ignite-14951
No new revisions were added by this update.
Summary of changes:
NOTICE | 5 +
RELEASE.md | 71 +
assembly/NOTICE | 0
assembly/README | 0
assembly/README.md | 52 +
assembly/assembly.xml | 27 +-
examples/README.md | 21 +
examples/config/ignite-config.json | 13 +
.../vault/pom.xml => examples/pom-standalone.xml | 30 +-
{modules/vault => examples}/pom.xml | 18 +-
.../example/table/KeyValueBinaryViewExample.java | 113 +
.../apache/ignite/example/table/TableExample.java | 109 +
.../internal/affinity/AffinityManagerTest.java | 3 +-
.../affinity/RendezvousAffinityFunctionTest.java | 20 +-
modules/api/pom.xml | 7 +
.../org/apache/ignite/app/IgnitionManager.java | 1 +
.../java/com/facebook/presto/bytecode/Access.java | 12 +-
.../bytecode/AddFakeLineNumberClassVisitor.java | 12 +-
.../presto/bytecode/AnnotationDefinition.java | 12 +-
.../com/facebook/presto/bytecode/ArrayOpCode.java | 12 +-
.../presto/bytecode/ByteCodeTooLargeException.java | 12 +-
.../facebook/presto/bytecode/BytecodeBlock.java | 26 +-
.../com/facebook/presto/bytecode/BytecodeNode.java | 12 +-
.../facebook/presto/bytecode/BytecodeUtils.java | 12 +-
.../facebook/presto/bytecode/BytecodeVisitor.java | 12 +-
.../facebook/presto/bytecode/ClassDefinition.java | 12 +-
.../facebook/presto/bytecode/ClassGenerator.java | 12 +-
.../java/com/facebook/presto/bytecode/Comment.java | 14 +-
.../presto/bytecode/CompilationException.java | 12 +-
.../presto/bytecode/DumpBytecodeVisitor.java | 24 +-
.../presto/bytecode/DynamicClassLoader.java | 12 +-
.../facebook/presto/bytecode/FieldDefinition.java | 12 +-
.../facebook/presto/bytecode/MethodDefinition.java | 11 +-
.../presto/bytecode/MethodGenerationContext.java | 16 +-
.../java/com/facebook/presto/bytecode/OpCode.java | 14 +-
.../com/facebook/presto/bytecode/Parameter.java | 12 +-
.../presto/bytecode/ParameterizedType.java | 12 +-
.../java/com/facebook/presto/bytecode/Scope.java | 13 +-
.../facebook/presto/bytecode/SmartClassWriter.java | 11 +-
.../com/facebook/presto/bytecode/Variable.java | 13 +-
.../presto/bytecode/control/CaseStatement.java | 14 +-
.../presto/bytecode/control/DoWhileLoop.java | 14 +-
.../presto/bytecode/control/FlowControl.java | 12 +-
.../facebook/presto/bytecode/control/ForLoop.java | 14 +-
.../presto/bytecode/control/IfStatement.java | 14 +-
.../presto/bytecode/control/SwitchStatement.java | 23 +-
.../facebook/presto/bytecode/control/TryCatch.java | 13 +-
.../presto/bytecode/control/WhileLoop.java | 13 +-
.../facebook/presto/bytecode/debug/DebugNode.java | 12 +-
.../presto/bytecode/debug/LineNumberNode.java | 14 +-
.../presto/bytecode/debug/LocalVariableNode.java | 14 +-
.../bytecode/expression/AndBytecodeExpression.java | 14 +-
.../expression/ArithmeticBytecodeExpression.java | 14 +-
.../expression/ArrayLengthBytecodeExpression.java | 14 +-
.../bytecode/expression/BytecodeExpression.java | 24 +-
.../bytecode/expression/BytecodeExpressions.java | 20 +-
.../expression/CastBytecodeExpression.java | 14 +-
.../expression/ComparisonBytecodeExpression.java | 14 +-
.../expression/ConstantBytecodeExpression.java | 14 +-
.../expression/GetElementBytecodeExpression.java | 14 +-
.../expression/GetFieldBytecodeExpression.java | 18 +-
.../expression/InlineIfBytecodeExpression.java | 14 +-
.../expression/InstanceOfBytecodeExpression.java | 14 +-
.../expression/InvokeBytecodeExpression.java | 20 +-
.../InvokeDynamicBytecodeExpression.java | 20 +-
.../expression/NegateBytecodeExpression.java | 14 +-
.../expression/NewArrayBytecodeExpression.java | 18 +-
.../expression/NewInstanceBytecodeExpression.java | 18 +-
.../bytecode/expression/NotBytecodeExpression.java | 14 +-
.../bytecode/expression/OrBytecodeExpression.java | 14 +-
.../bytecode/expression/PopBytecodeExpression.java | 13 +-
.../expression/ReturnBytecodeExpression.java | 13 +-
.../SetArrayElementBytecodeExpression.java | 13 +-
.../expression/SetFieldBytecodeExpression.java | 17 +-
.../presto/bytecode/instruction/Constant.java | 14 +-
.../bytecode/instruction/FieldInstruction.java | 18 +-
.../bytecode/instruction/InstructionNode.java | 12 +-
.../bytecode/instruction/InvokeInstruction.java | 24 +-
.../bytecode/instruction/JumpInstruction.java | 14 +-
.../presto/bytecode/instruction/LabelNode.java | 14 +-
.../bytecode/instruction/TypeInstruction.java | 13 +-
.../bytecode/instruction/VariableInstruction.java | 13 +-
.../presto/bytecode/TestBytecodeUtils.java | 11 +-
.../presto/bytecode/TestClassGenerator.java | 11 +-
.../expression/BytecodeExpressionAssertions.java | 22 +-
.../TestArithmeticBytecodeExpression.java | 11 +-
.../expression/TestArrayBytecodeExpressions.java | 17 +-
.../expression/TestCastBytecodeExpression.java | 11 +-
.../TestComparisonBytecodeExpression.java | 11 +-
.../expression/TestConstantBytecodeExpression.java | 11 +-
.../expression/TestGetFieldBytecodeExpression.java | 11 +-
.../expression/TestInlineIfBytecodeExpression.java | 11 +-
.../expression/TestInvokeBytecodeExpression.java | 11 +-
.../TestInvokeDynamicBytecodeExpression.java | 11 +-
.../expression/TestLogicalBytecodeExpression.java | 11 +-
.../TestNewInstanceBytecodeExpression.java | 11 +-
.../expression/TestPopBytecodeExpression.java | 11 +-
.../expression/TestSetFieldBytecodeExpression.java | 17 +-
.../TestSetVariableBytecodeExpression.java | 15 +-
.../internal/processors/query/calcite/Stubs.java | 6 -
.../query/calcite/exec/AbstractIndexScan.java | 107 +
.../query/calcite/exec/ArrayRowHandler.java | 77 +
.../calcite/exec/ExecutionCancelledException.java} | 17 +-
.../query/calcite/exec/ExecutionContext.java | 292 +++
.../query/calcite/exec/PlannerHelper.java | 229 ++
.../query/calcite/exec/QueryTaskExecutor.java | 47 +
.../query/calcite/exec/QueryTaskExecutorImpl.java | 95 +
.../processors/query/calcite/exec/RowHandler.java | 73 +
.../query/calcite/exec/RuntimeHashIndex.java | 113 +
.../query/calcite/exec/RuntimeIndex.java} | 13 +-
.../query/calcite/exec/RuntimeTreeIndex.java | 196 ++
.../query/calcite/exec/TableFunctionScan.java | 48 +
.../processors/query/calcite/exec/TreeIndex.java} | 20 +-
.../query/calcite/exec/exp/CallImplementor.java | 42 +
.../query/calcite/exec/exp/ConverterUtils.java | 460 ++++
.../query/calcite/exec/exp/ExpressionFactory.java | 125 +
.../calcite/exec/exp/ExpressionFactoryImpl.java | 509 ++++
.../calcite/exec/exp/IgniteBuiltInMethod.java | 45 +
.../query/calcite/exec/exp/IgniteSqlFunctions.java | 154 ++
.../calcite/exec/exp/ImplementableFunction.java} | 40 +-
.../query/calcite/exec/exp/NotNullImplementor.java | 43 +
.../exec/exp/ReflectiveCallNotNullImplementor.java | 82 +
.../query/calcite/exec/exp/RexImpTable.java | 2574 ++++++++++++++++++++
.../query/calcite/exec/exp/RexToLixTranslator.java | 1312 ++++++++++
.../processors/query/calcite/exec/exp/Scalar.java} | 19 +-
.../{Stubs.java => exec/exp/agg/Accumulator.java} | 32 +-
.../calcite/exec/exp/agg/AccumulatorWrapper.java} | 26 +-
.../query/calcite/exec/exp/agg/Accumulators.java | 1068 ++++++++
.../calcite/exec/exp/agg/AccumulatorsFactory.java | 330 +++
.../query/calcite/exec/exp/agg/AggregateType.java} | 21 +-
.../query/calcite/exec/exp/agg/GroupKey.java | 101 +
.../query/calcite/exec/rel/AbstractNode.java | 202 ++
.../query/calcite/exec/rel/AbstractSetOpNode.java | 367 +++
.../exec/rel/CorrelatedNestedLoopJoinNode.java | 479 ++++
.../query/calcite/exec/rel/Downstream.java} | 41 +-
.../query/calcite/exec/rel/FilterNode.java | 145 ++
.../query/calcite/exec/rel/HashAggregateNode.java | 372 +++
.../query/calcite/exec/rel/IndexSpoolNode.java | 205 ++
.../query/calcite/exec/rel/IntersectNode.java | 118 +
.../query/calcite/exec/rel/LimitNode.java | 132 +
.../query/calcite/exec/rel/Mailbox.java} | 31 +-
.../query/calcite/exec/rel/MergeJoinNode.java | 1134 +++++++++
.../query/calcite/exec/rel/MinusNode.java | 102 +
.../query/calcite/exec/rel/NestedLoopJoinNode.java | 812 ++++++
.../processors/query/calcite/exec/rel/Node.java | 81 +
.../query/calcite/exec/rel/ProjectNode.java | 84 +
.../query/calcite/exec/rel/RootNode.java | 283 +++
.../query/calcite/exec/rel/ScanNode.java | 130 +
.../query/calcite/exec/rel/SingleNode.java} | 28 +-
.../query/calcite/exec/rel/SortAggregateNode.java | 316 +++
.../query/calcite/exec/rel/SortNode.java | 148 ++
.../query/calcite/exec/rel/TableSpoolNode.java | 160 ++
.../query/calcite/exec/rel/UnionAllNode.java | 97 +
.../calcite/metadata/FragmentDescription.java | 75 +
.../calcite/metadata/cost/IgniteCostFactory.java | 4 +-
.../calcite/prepare/ddl/ColumnDefinition.java | 2 +-
.../processors/query/calcite/util/Commons.java | 27 +-
.../query/calcite/util/FilteringIterator.java | 79 +
.../query/calcite/util/IgniteMethod.java | 25 +
.../processors/query/calcite/util/RexUtils.java | 8 +-
.../calcite/util/StripedThreadPoolExecutor.java | 226 ++
.../query/calcite/util/TransformingIterator.java} | 39 +-
.../processors/query/calcite/util/TypeUtils.java | 111 +
.../query/calcite/exec/RuntimeTreeIndexTest.java | 199 ++
.../calcite/exec/rel/AbstractExecutionTest.java | 226 ++
.../exec/rel/AbstractSetOpExecutionTest.java | 166 ++
.../query/calcite/exec/rel/BaseAggregateTest.java | 552 +++++
.../query/calcite/exec/rel/ExecutionTest.java | 667 +++++
.../exec/rel/HashAggregateExecutionTest.java | 135 +
.../rel/HashAggregateSingleGroupExecutionTest.java | 497 ++++
.../exec/rel/HashIndexSpoolExecutionTest.java | 167 ++
.../calcite/exec/rel/IntersectExecutionTest.java | 83 +
.../calcite/exec/rel/MergeJoinExecutionTest.java | 378 +++
.../query/calcite/exec/rel/MinusExecutionTest.java | 83 +
.../exec/rel/NestedLoopJoinExecutionTest.java | 363 +++
.../exec/rel/SortAggregateExecutionTest.java | 141 ++
.../calcite/exec/rel/TableSpoolExecutionTest.java | 152 ++
.../exec/rel/TreeIndexSpoolExecutionTest.java | 194 ++
modules/core/pom.xml | 6 +
.../apache/ignite/internal/util/ArrayUtils.java | 2 +
.../org/apache/ignite/internal/util/ByteUtils.java | 5 +-
.../apache/ignite/internal/util/IgniteUtils.java | 167 +-
.../java/org/apache/ignite/lang/ByteArray.java | 40 +-
.../java/org/apache/ignite/lang/IgniteLogger.java | 179 +-
.../apache/ignite/lang/LoggerMessageHelper.java | 443 ++++
.../internal/testframework/IgniteTestUtils.java | 71 +
.../tostring/IgniteToStringBuilderSelfTest.java | 4 +-
.../internal/util/IgniteIntListSelfTest.java | 159 ++
.../ignite/internal/util/IgniteUtilsTest.java | 58 +
.../org/apache/ignite/lang/LoggerHelperTest.java | 299 +++
.../client/ITMetaStorageServiceTest.java | 19 +-
.../internal/metastorage/MetaStorageManager.java | 210 +-
modules/network-api/pom.xml | 6 +
.../ignite/network/ClusterLocalConfiguration.java | 6 +-
.../org/apache/ignite/network/ClusterNode.java | 47 +-
.../apache/ignite/network/MessagingService.java | 14 +-
.../org/apache/ignite/network/NetworkAddress.java | 118 +
.../ignite/network/NetworkMessageHandler.java | 5 +-
.../org/apache/ignite/network/TopologyService.java | 2 +-
.../apache/ignite/network/NetworkAddressTest.java | 80 +
.../network/scalecube/ITNodeRestartsTest.java | 23 +-
.../scalecube/ITScaleCubeNetworkMessagingTest.java | 23 +-
.../internal/network/netty/ConnectionManager.java | 4 +-
.../ignite/internal/network/netty/NettyServer.java | 21 +-
.../scalecube/ScaleCubeClusterServiceFactory.java | 24 +-
.../ScaleCubeDirectMarshallerTransport.java | 9 +-
.../scalecube/ScaleCubeMessagingService.java | 53 +-
.../scalecube/ScaleCubeTopologyService.java | 25 +-
.../java/org/apache/ignite/raft/client/Peer.java | 29 +-
.../client/service/impl/RaftGroupServiceImpl.java | 1 +
.../raft/client/service/RaftGroupServiceTest.java | 124 +-
.../ignite/raft/jraft/core/ITCliServiceTest.java | 59 +-
.../apache/ignite/raft/jraft/core/ITNodeTest.java | 309 ++-
.../raft/server/ITJRaftCounterServerTest.java | 49 +-
.../raft/server/ITSimpleCounterServerTest.java | 11 +-
.../ignite/raft/server/RaftServerAbstractTest.java | 3 +-
.../internal/raft/server/impl/JRaftServerImpl.java | 55 +-
.../internal/raft/server/impl/RaftServerImpl.java | 24 +-
.../org/apache/ignite/raft/jraft/JRaftUtils.java | 17 +-
.../apache/ignite/raft/jraft/RaftGroupService.java | 37 +-
.../apache/ignite/raft/jraft/core/NodeImpl.java | 11 +-
.../apache/ignite/raft/jraft/entity/PeerId.java | 7 +-
.../ignite/raft/jraft/error/RemotingException.java | 1 -
.../apache/ignite/raft/jraft/rpc/RpcClient.java | 52 +-
.../apache/ignite/raft/jraft/rpc/RpcContext.java | 5 +-
.../ignite/raft/jraft/rpc/RpcRequestClosure.java | 1 +
.../ignite/raft/jraft/rpc/RpcRequestProcessor.java | 1 +
.../raft/jraft/rpc/RpcResponseClosureAdapter.java | 4 -
.../raft/jraft/rpc/impl/AbstractClientService.java | 47 +-
.../raft/jraft/rpc/impl/IgniteRpcClient.java | 99 +-
.../raft/jraft/rpc/impl/IgniteRpcServer.java | 13 +-
.../rpc/impl/client/ActionRequestProcessor.java | 35 +-
.../rpc/impl/client/GetLeaderRequestProcessor.java | 10 +-
.../rpc/impl/client/SnapshotRequestProcessor.java | 18 +-
.../impl/core/AppendEntriesRequestProcessor.java | 6 +-
.../ignite/raft/jraft/util/internal/ThrowUtil.java | 60 +-
.../apache/ignite/raft/jraft/core/TestCluster.java | 107 +-
.../raft/jraft/rpc/AbstractClientServiceTest.java | 66 +-
.../ignite/raft/jraft/rpc/AbstractRpcTest.java | 91 +-
.../ignite/raft/jraft/rpc/IgniteRpcTest.java | 14 +-
.../ignite/raft/jraft/rpc/TestIgniteRpcServer.java | 17 +-
.../snapshot/local/LocalSnapshotReaderTest.java | 9 +-
.../ignite/raft/jraft/test/MockAsyncContext.java | 9 +-
.../runner/app/DynamicTableCreationTest.java | 18 +-
.../ignite/internal/runner/app/IgnitionTest.java | 24 +-
.../internal/runner/app/TableCreationTest.java | 16 +-
.../org/apache/ignite/internal/app/IgniteImpl.java | 20 +-
.../apache/ignite/internal/app/IgnitionImpl.java | 60 +-
.../storage/DistributedConfigurationStorage.java | 5 +-
.../storage/LocalConfigurationStorage.java | 6 +-
.../ignite/internal/app/IgnitionCleaner.java} | 17 +-
.../marshaller/asm/AsmSerializerGenerator.java | 8 +-
modules/storage-api/pom.xml | 70 +
.../apache/ignite/internal/storage/DataRow.java} | 21 +-
.../ignite/internal/storage/InvokeClosure.java} | 29 +-
.../ignite/internal/storage/OperationType.java} | 23 +-
.../apache/ignite/internal/storage/SearchRow.java} | 21 +-
.../apache/ignite/internal/storage/Storage.java | 70 +
.../ignite/internal/storage/StorageException.java} | 30 +-
.../storage/basic/ConcurrentHashMapStorage.java | 140 ++
.../internal/storage/basic/SimpleDataRow.java | 59 +
.../storage/basic/SimpleReadInvokeClosure.java | 57 +
.../storage/basic/SimpleRemoveInvokeClosure.java} | 34 +-
.../storage/basic/SimpleWriteInvokeClosure.java} | 38 +-
.../internal/storage/AbstractStorageTest.java | 205 ++
.../basic/ConcurrentHashMapStorageTest.java} | 20 +-
modules/storage-rocksdb/pom.xml | 67 +
.../internal/storage/rocksdb/RocksDbStorage.java | 255 ++
.../storage/rocksdb/RocksDbStorageTest.java | 53 +
modules/table/pom.xml | 6 +
.../ignite/distributed/ITDistributedTableTest.java | 26 +-
.../ignite/internal/table/TableManagerTest.java | 131 +-
modules/vault/pom.xml | 11 +
.../PersistencePropertiesVaultServiceTest.java | 122 +
.../persistence/PersistentVaultServiceTest.java | 69 +
.../vault/{common/Entry.java => VaultEntry.java} | 42 +-
.../apache/ignite/internal/vault/VaultManager.java | 109 +-
.../internal/vault/{service => }/VaultService.java | 15 +-
.../internal/vault/impl/VaultServiceImpl.java | 103 -
.../vault/inmemory/InMemoryVaultService.java | 119 +
.../vault/persistence/PersistentVaultService.java | 207 ++
.../vault/persistence/RocksIteratorAdapter.java | 100 +
.../internal/vault/CompletableFutureMatcher.java | 69 +
.../ignite/internal/vault/VaultManagerTest.java | 73 +
.../ignite/internal/vault/VaultServiceTest.java | 290 +++
.../vault/impl/VaultBaseContractsTest.java | 221 --
.../vault/inmemory/InMemoryVaultServiceTest.java} | 20 +-
parent/pom.xml | 46 +-
pom.xml | 3 +
289 files changed, 24382 insertions(+), 2338 deletions(-)
create mode 100644 NOTICE
create mode 100644 RELEASE.md
delete mode 100644 assembly/NOTICE
delete mode 100644 assembly/README
create mode 100644 assembly/README.md
create mode 100644 examples/README.md
create mode 100644 examples/config/ignite-config.json
copy modules/vault/pom.xml => examples/pom-standalone.xml (66%)
copy {modules/vault => examples}/pom.xml (73%)
create mode 100644 examples/src/main/java/org/apache/ignite/example/table/KeyValueBinaryViewExample.java
create mode 100644 examples/src/main/java/org/apache/ignite/example/table/TableExample.java
create mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/AbstractIndexScan.java
create mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/ArrayRowHandler.java
copy modules/{network-api/src/main/java/org/apache/ignite/network/NetworkMessageHandler.java => calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/ExecutionCancelledException.java} (69%)
create mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/ExecutionContext.java
create mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/PlannerHelper.java
create mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/QueryTaskExecutor.java
create mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/QueryTaskExecutorImpl.java
create mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/RowHandler.java
create mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/RuntimeHashIndex.java
copy modules/{network-api/src/main/java/org/apache/ignite/network/NetworkMessageHandler.java => calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/RuntimeIndex.java} (71%)
create mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/RuntimeTreeIndex.java
create mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/TableFunctionScan.java
copy modules/{network-api/src/main/java/org/apache/ignite/network/NetworkMessageHandler.java => calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/TreeIndex.java} (67%)
create mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/exp/CallImplementor.java
create mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/exp/ConverterUtils.java
create mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/exp/ExpressionFactory.java
create mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/exp/ExpressionFactoryImpl.java
create mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/exp/IgniteBuiltInMethod.java
create mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/exp/IgniteSqlFunctions.java
copy modules/{raft/src/main/java/org/apache/ignite/raft/jraft/rpc/RpcContext.java => calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/exp/ImplementableFunction.java} (51%)
create mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/exp/NotNullImplementor.java
create mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/exp/ReflectiveCallNotNullImplementor.java
create mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/exp/RexImpTable.java
create mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/exp/RexToLixTranslator.java
copy modules/{network-api/src/main/java/org/apache/ignite/network/NetworkMessageHandler.java => calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/exp/Scalar.java} (69%)
copy modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/{Stubs.java => exec/exp/agg/Accumulator.java} (61%)
copy modules/{network-api/src/main/java/org/apache/ignite/network/NetworkMessageHandler.java => calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/exp/agg/AccumulatorWrapper.java} (69%)
create mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/exp/agg/Accumulators.java
create mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/exp/agg/AccumulatorsFactory.java
copy modules/{network-api/src/main/java/org/apache/ignite/network/NetworkMessageHandler.java => calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/exp/agg/AggregateType.java} (69%)
create mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/exp/agg/GroupKey.java
create mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/AbstractNode.java
create mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/AbstractSetOpNode.java
create mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/CorrelatedNestedLoopJoinNode.java
copy modules/{runner/src/main/java/org/apache/ignite/internal/app/IgniteImpl.java => calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/Downstream.java} (54%)
create mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/FilterNode.java
create mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/HashAggregateNode.java
create mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/IndexSpoolNode.java
create mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/IntersectNode.java
create mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/LimitNode.java
copy modules/{network-api/src/main/java/org/apache/ignite/network/NetworkMessageHandler.java => calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/Mailbox.java} (65%)
create mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/MergeJoinNode.java
create mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/MinusNode.java
create mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/NestedLoopJoinNode.java
create mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/Node.java
create mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/ProjectNode.java
create mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/RootNode.java
create mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/ScanNode.java
copy modules/{network-api/src/main/java/org/apache/ignite/network/NetworkMessageHandler.java => calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/SingleNode.java} (62%)
create mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/SortAggregateNode.java
create mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/SortNode.java
create mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/TableSpoolNode.java
create mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/UnionAllNode.java
create mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/metadata/FragmentDescription.java
create mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/util/FilteringIterator.java
create mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/util/StripedThreadPoolExecutor.java
copy modules/{runner/src/main/java/org/apache/ignite/internal/app/IgniteImpl.java => calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/util/TransformingIterator.java} (54%)
create mode 100644 modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/exec/RuntimeTreeIndexTest.java
create mode 100644 modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/AbstractExecutionTest.java
create mode 100644 modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/AbstractSetOpExecutionTest.java
create mode 100644 modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/BaseAggregateTest.java
create mode 100644 modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/ExecutionTest.java
create mode 100644 modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/HashAggregateExecutionTest.java
create mode 100644 modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/HashAggregateSingleGroupExecutionTest.java
create mode 100644 modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/HashIndexSpoolExecutionTest.java
create mode 100644 modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/IntersectExecutionTest.java
create mode 100644 modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/MergeJoinExecutionTest.java
create mode 100644 modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/MinusExecutionTest.java
create mode 100644 modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/NestedLoopJoinExecutionTest.java
create mode 100644 modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/SortAggregateExecutionTest.java
create mode 100644 modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/TableSpoolExecutionTest.java
create mode 100644 modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/TreeIndexSpoolExecutionTest.java
create mode 100644 modules/core/src/main/java/org/apache/ignite/lang/LoggerMessageHelper.java
create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/util/IgniteIntListSelfTest.java
create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/util/IgniteUtilsTest.java
create mode 100644 modules/core/src/test/java/org/apache/ignite/lang/LoggerHelperTest.java
create mode 100644 modules/network-api/src/main/java/org/apache/ignite/network/NetworkAddress.java
create mode 100644 modules/network-api/src/test/java/org/apache/ignite/network/NetworkAddressTest.java
copy modules/{network-api/src/main/java/org/apache/ignite/network/NetworkMessageHandler.java => runner/src/test/java/org/apache/ignite/internal/app/IgnitionCleaner.java} (70%)
create mode 100644 modules/storage-api/pom.xml
copy modules/{network-api/src/main/java/org/apache/ignite/network/NetworkMessageHandler.java => storage-api/src/main/java/org/apache/ignite/internal/storage/DataRow.java} (63%)
copy modules/{network-api/src/main/java/org/apache/ignite/network/NetworkMessageHandler.java => storage-api/src/main/java/org/apache/ignite/internal/storage/InvokeClosure.java} (55%)
copy modules/{network-api/src/main/java/org/apache/ignite/network/NetworkMessageHandler.java => storage-api/src/main/java/org/apache/ignite/internal/storage/OperationType.java} (69%)
copy modules/{network-api/src/main/java/org/apache/ignite/network/NetworkMessageHandler.java => storage-api/src/main/java/org/apache/ignite/internal/storage/SearchRow.java} (65%)
create mode 100644 modules/storage-api/src/main/java/org/apache/ignite/internal/storage/Storage.java
copy modules/{network-api/src/main/java/org/apache/ignite/network/NetworkMessageHandler.java => storage-api/src/main/java/org/apache/ignite/internal/storage/StorageException.java} (59%)
create mode 100644 modules/storage-api/src/main/java/org/apache/ignite/internal/storage/basic/ConcurrentHashMapStorage.java
create mode 100644 modules/storage-api/src/main/java/org/apache/ignite/internal/storage/basic/SimpleDataRow.java
create mode 100644 modules/storage-api/src/main/java/org/apache/ignite/internal/storage/basic/SimpleReadInvokeClosure.java
copy modules/{runner/src/main/java/org/apache/ignite/internal/app/IgniteImpl.java => storage-api/src/main/java/org/apache/ignite/internal/storage/basic/SimpleRemoveInvokeClosure.java} (57%)
copy modules/{runner/src/main/java/org/apache/ignite/internal/app/IgniteImpl.java => storage-api/src/main/java/org/apache/ignite/internal/storage/basic/SimpleWriteInvokeClosure.java} (50%)
create mode 100644 modules/storage-api/src/test/java/org/apache/ignite/internal/storage/AbstractStorageTest.java
copy modules/{network-api/src/main/java/org/apache/ignite/network/NetworkMessageHandler.java => storage-api/src/test/java/org/apache/ignite/internal/storage/basic/ConcurrentHashMapStorageTest.java} (67%)
create mode 100644 modules/storage-rocksdb/pom.xml
create mode 100644 modules/storage-rocksdb/src/main/java/org/apache/ignite/internal/storage/rocksdb/RocksDbStorage.java
create mode 100644 modules/storage-rocksdb/src/test/java/org/apache/ignite/internal/storage/rocksdb/RocksDbStorageTest.java
create mode 100644 modules/vault/src/integrationTest/java/org/apache/ignite/internal/vault/persistence/PersistencePropertiesVaultServiceTest.java
create mode 100644 modules/vault/src/integrationTest/java/org/apache/ignite/internal/vault/persistence/PersistentVaultServiceTest.java
rename modules/vault/src/main/java/org/apache/ignite/internal/vault/{common/Entry.java => VaultEntry.java} (62%)
rename modules/vault/src/main/java/org/apache/ignite/internal/vault/{service => }/VaultService.java (87%)
delete mode 100644 modules/vault/src/main/java/org/apache/ignite/internal/vault/impl/VaultServiceImpl.java
create mode 100644 modules/vault/src/main/java/org/apache/ignite/internal/vault/inmemory/InMemoryVaultService.java
create mode 100644 modules/vault/src/main/java/org/apache/ignite/internal/vault/persistence/PersistentVaultService.java
create mode 100644 modules/vault/src/main/java/org/apache/ignite/internal/vault/persistence/RocksIteratorAdapter.java
create mode 100644 modules/vault/src/test/java/org/apache/ignite/internal/vault/CompletableFutureMatcher.java
create mode 100644 modules/vault/src/test/java/org/apache/ignite/internal/vault/VaultManagerTest.java
create mode 100644 modules/vault/src/test/java/org/apache/ignite/internal/vault/VaultServiceTest.java
delete mode 100644 modules/vault/src/test/java/org/apache/ignite/internal/vault/impl/VaultBaseContractsTest.java
copy modules/{network-api/src/main/java/org/apache/ignite/network/NetworkMessageHandler.java => vault/src/test/java/org/apache/ignite/internal/vault/inmemory/InMemoryVaultServiceTest.java} (66%)