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/07/26 13:40:30 UTC
[ignite-3] branch ignite-13669 updated (f71feea -> ce0f410)
This is an automated email from the ASF dual-hosted git repository.
amashenkov pushed a change to branch ignite-13669
in repository https://gitbox.apache.org/repos/asf/ignite-3.git.
from f71feea Minor.
add c0026f5 IGNITE-15156 Muted ITJRaftCounterServerTest.testFollowerCatchUpFromSnapshot2
add 6740805 IGNITE-15157 Muted ITCliServiceTest.testAddPeerRemovePeer
add 50ea1ed IGNITE-14836 Integrate execution of SELECT queries into Ignite 3.0 (#213)
add 44e162a Revert "IGNITE-14836 Integrate execution of SELECT queries into Ignite 3.0 (#213)"
add 179d24d IGNITE-14982 RocksDB-based persistent key-value storage for meta store (#203)
add b6799b2 IGNITE-14092 Introduce the Node Finder API (#233)
add e46d1fb Revert "IGNITE-14092 Introduce the Node Finder API (#233)" (#237)
add 1df909b IGNITE-15152: Fix javadoc in Api and Core modules. (#226)
add eb31121 IGNITE-14836 Integrate execution of SELECT queries into Ignite 3.0 (#213) (#236)
add 0f0630f IGNITE-14092 Introduce the Node Finder API (#238)
add 268213e IGNITE-15133 Cursors and watches cleanup logic on node left. Fixes #221
add a917f9d IGNITE-14836: fix SQL messages groupType
add b8d0737 IGNITE-14848 replace raft implementation. Fixes #197
add 3ed06d9 IGNITE-15058 Fixed testLockUnlock. Fixes #235
add 151475e IGNITE-15173: Fix javadoc in Calcite module. (#239)
add d13b2e2 IGNITE-15149 Javadoc fixes for configuration-api module. (#240)
add e5d890a IGNITE-15178 Check for clashing message group IDs in AbstractMessagingService (#242)
add 0448b1d IGNITE-14970 Add basic Java thin client
add 3ee5d20 IGNITE-15168 Local dependency purge integrated into build process. (#234)
add af995ac IGNITE-14924 HOCON configuration source and representation implemented. (#228)
add ce0f410 Merge branch 'main' into ignite-13669
No new revisions were added by this update.
Summary of changes:
check-rules/checkstyle-disabled-modules.xml | 4 -
.../org/apache/ignite/app/IgnitionManager.java | 1 +
.../java/org/apache/ignite/app/package-info.java} | 15 +-
.../ClientConnectorConfigurationSchema.java} | 41 +-
.../schemas/clientconnector/package-info.java} | 15 +-
.../schemas/network/package-info.java} | 15 +-
.../configuration/schemas/rest/package-info.java} | 15 +-
.../schemas/runner/package-info.java} | 15 +-
.../org/apache/ignite/lang/IgniteException.java | 2 +-
.../java/org/apache/ignite/lang/package-info.java} | 15 +-
.../java/org/apache/ignite/tx/package-info.java} | 15 +-
modules/calcite/pom.xml | 11 +
.../apache/calcite/plan/volcano/VolcanoUtils.java | 9 +-
.../{VolcanoUtils.java => package-info.java} | 13 +-
.../query/calcite/SqlQueryProcessor.java | 160 ++
.../internal/processors/query/calcite/Stubs.java | 54 +
.../calcite/exec/ClosableIteratorsHolder.java | 168 ++
.../query/calcite/exec/ExchangeService.java | 84 +
.../query/calcite/exec/ExchangeServiceImpl.java | 262 +++
.../query/calcite/exec/ExecutionContext.java | 4 +-
.../query/calcite/exec/ExecutionService.java} | 30 +-
.../query/calcite/exec/ExecutionServiceImpl.java | 865 +++++++++
.../query/calcite/exec/LogicalRelImplementor.java | 654 +++++++
.../query/calcite/exec/MailboxRegistry.java | 99 +
.../query/calcite/exec/MailboxRegistryImpl.java | 169 ++
.../query/calcite/exec/QueryTaskExecutorImpl.java | 4 +-
.../processors/query/calcite/exec/rel/Inbox.java | 519 +++++
.../processors/query/calcite/exec/rel/Outbox.java | 361 ++++
.../query/calcite/exec/rel/RootNode.java | 16 +-
.../query/calcite/message/ErrorMessage.java} | 30 +-
.../message/ExecutionContextAwareMessage.java} | 27 +-
.../query/calcite/message/InboxCloseMessage.java} | 30 +-
.../query/calcite/message/MessageListener.java} | 19 +-
.../query/calcite/message/MessageService.java} | 35 +-
.../query/calcite/message/MessageServiceImpl.java | 149 ++
.../query/calcite/message/OutboxCloseMessage.java} | 30 +-
.../message/QueryBatchAcknowledgeMessage.java} | 24 +-
.../query/calcite/message/QueryBatchMessage.java} | 31 +-
.../QueryStartRequest.java} | 42 +-
.../query/calcite/message/QueryStartResponse.java} | 30 +-
.../SqlQueryMessageGroup.java} | 30 +-
.../query/calcite/metadata/AffinityService.java} | 21 +-
.../query/calcite/metadata/ColocationGroup.java | 50 +-
.../calcite/metadata/FragmentDescription.java | 12 +-
.../query/calcite/metadata/FragmentMapping.java | 12 +-
.../query/calcite/metadata/IgniteMdRowCount.java | 6 +-
.../query/calcite/metadata/MappingService.java | 3 +-
.../query/calcite/metadata/MappingServiceImpl.java | 60 +
...agmentDescription.java => RemoteException.java} | 71 +-
.../calcite/prepare/AbstractMultiStepPlan.java | 14 +-
.../processors/query/calcite/prepare/CacheKey.java | 78 +
.../processors/query/calcite/prepare/Cloner.java | 16 +-
.../{MultiStepQueryPlan.java => DdlPlan.java} | 28 +-
.../query/calcite/prepare/DummyPlanCache.java} | 17 +-
.../{MultiStepQueryPlan.java => ExplainPlan.java} | 36 +-
.../query/calcite/prepare/FieldsMetadata.java} | 25 +-
...iStepQueryPlan.java => FieldsMetadataImpl.java} | 33 +-
.../processors/query/calcite/prepare/Fragment.java | 5 +-
.../{MultiStepQueryPlan.java => FragmentPlan.java} | 31 +-
.../query/calcite/prepare/IgniteRelShuttle.java | 22 +-
...ltiStepQueryPlan.java => MultiStepDmlPlan.java} | 10 +-
.../query/calcite/prepare/MultiStepPlan.java | 8 +-
.../query/calcite/prepare/MultiStepQueryPlan.java | 2 +-
.../query/calcite/prepare/PlannerPhase.java | 9 +-
.../query/calcite/prepare/PlanningContext.java | 21 +-
.../query/calcite/prepare/QueryPlanCache.java} | 27 +-
.../query/calcite/prepare/QueryPlanFactory.java} | 19 +-
.../query/calcite/rel/IgniteRelVisitor.java | 16 +-
.../query/calcite/rel/set/IgniteIntersect.java | 68 +
.../query/calcite/rel/set/IgniteMapIntersect.java | 74 +
.../query/calcite/rel/set/IgniteMapMinus.java | 73 +-
.../{IgniteMapMinus.java => IgniteMapSetOp.java} | 87 +-
.../query/calcite/rel/set/IgniteMinus.java | 71 +
...ReduceMinus.java => IgniteReduceIntersect.java} | 65 +-
.../query/calcite/rel/set/IgniteReduceMinus.java | 51 +-
.../query/calcite/rel/set/IgniteReduceSetOp.java | 75 +
.../query/calcite/rel/set/IgniteSetOp.java | 78 +
.../calcite/rel/set/IgniteSingleIntersect.java | 68 +
.../query/calcite/rel/set/IgniteSingleMinus.java | 72 +-
...niteSingleMinus.java => IgniteSingleSetOp.java} | 63 +-
.../query/calcite/rule/SetOpConverterRule.java | 186 ++
.../query/calcite/schema/ColumnDescriptor.java | 3 -
.../query/calcite/schema/ColumnDescriptorImpl.java | 93 +
.../query/calcite/schema/IgniteTable.java | 21 +
.../query/calcite/schema/IgniteTableImpl.java | 207 ++
.../query/calcite/schema/SchemaHolder.java} | 18 +-
.../query/calcite/schema/SchemaHolderImpl.java | 124 ++
.../query/calcite/schema/TableDescriptor.java | 10 +
.../query/calcite/schema/TableDescriptorImpl.java | 149 ++
...gniteDistribution.java => AffinityAdapter.java} | 41 +-
.../{IgniteDistribution.java => AllNodes.java} | 29 +-
.../query/calcite/trait/Destination.java} | 24 +-
.../query/calcite/trait/DistributionFunction.java | 87 +
.../query/calcite/trait/DistributionTrait.java | 11 +-
.../query/calcite/trait/IgniteDistribution.java | 14 +
.../{IgniteDistribution.java => Partitioned.java} | 38 +-
.../{IgniteDistribution.java => RandomNode.java} | 36 +-
.../processors/query/calcite/util/Commons.java | 101 +-
.../NodeLeaveHandler.java} | 28 +-
.../calcite/util/StripedThreadPoolExecutor.java | 2 -
.../calcite/exec/rel/AbstractExecutionTest.java | 23 +-
.../query/calcite/planner/AbstractPlannerTest.java | 28 +-
.../query/calcite/planner/ExceptPlannerTest.java | 329 ----
.../query/calcite/planner/PlannerTest.java | 6 +-
.../query/calcite/planner/SetOpPlannerTest.java | 421 ++++
...tionTest.java => TableFunctionPlannerTest.java} | 2 +-
modules/client-common/README.md | 4 +
modules/{runner => client-common}/pom.xml | 61 +-
.../ignite/client/proto/ClientDataType.java} | 60 +-
.../ignite/client/proto/ClientErrorCode.java} | 20 +-
.../ignite/client/proto/ClientMessageDecoder.java | 146 ++
.../ignite/client/proto/ClientMessageEncoder.java} | 37 +-
.../ignite/client/proto/ClientMessagePacker.java | 125 ++
.../ignite/client/proto/ClientMessageUnpacker.java | 155 ++
.../ignite/client/proto/ClientMsgPackType.java} | 34 +-
.../org/apache/ignite/client/proto/ClientOp.java} | 39 +-
.../ignite/client/proto/ProtocolVersion.java | 141 ++
.../ignite/client/proto/ServerMessageType.java} | 17 +-
.../apache/ignite/client/proto/package-info.java} | 15 +-
.../client/proto/ClientMessageDecoderTest.java | 109 ++
.../client/proto/ClientMessageEncoderTest.java | 53 +
.../proto/ClientMessagePackerUnpackerTest.java | 50 +
modules/client-handler/README.md | 4 +
modules/{runner => client-handler}/pom.xml | 60 +-
.../ignite/client/handler/ClientContext.java | 82 +
.../ignite/client/handler/ClientHandlerModule.java | 150 ++
.../handler/ClientInboundMessageHandler.java | 493 +++++
.../ignite/client/handler/package-info.java} | 15 +-
.../handler/ClientHandlerIntegrationTest.java | 195 ++
.../client/handler}/TestConfigurationStorage.java | 24 +-
modules/client/README.md | 4 +
modules/{runner => client}/pom.xml | 68 +-
.../org/apache/ignite/client/IgniteClient.java | 120 ++
.../ignite/client/IgniteClientAddressFinder.java} | 22 +-
.../IgniteClientAuthenticationException.java} | 28 +-
.../client/IgniteClientAuthorizationException.java | 55 +
.../ignite/client/IgniteClientConfiguration.java} | 44 +-
.../client/IgniteClientConnectionException.java} | 30 +-
.../ignite/client/IgniteClientException.java | 96 +
...ClientFeatureNotSupportedByServerException.java | 56 +
.../org/apache/ignite/client/package-info.java} | 15 +-
.../ignite/internal/client/ClientChannel.java | 52 +
.../client/ClientChannelConfiguration.java | 113 ++
.../ignite/internal/client/HostAndPortRange.java | 280 +++
.../internal/client/PayloadInputChannel.java} | 43 +-
.../internal/client/PayloadOutputChannel.java} | 50 +-
.../ignite/internal/client/PayloadReader.java} | 23 +-
.../ignite/internal/client/PayloadWriter.java} | 22 +-
.../internal/client/ProtocolBitmaskFeature.java | 91 +
.../ignite/internal/client/ProtocolContext.java | 78 +
.../ignite/internal/client/ReliableChannel.java | 626 ++++++
.../ignite/internal/client/TcpClientChannel.java | 391 ++++
.../ignite/internal/client/TcpIgniteClient.java | 96 +
.../internal/client/io/ClientConnection.java} | 28 +-
.../client/io/ClientConnectionMultiplexer.java | 52 +
.../client/io/ClientConnectionStateHandler.java} | 20 +-
.../internal/client/io/ClientMessageHandler.java} | 22 +-
.../client/io/netty/NettyClientConnection.java | 90 +
.../io/netty/NettyClientConnectionMultiplexer.java | 96 +
.../io/netty/NettyClientMessageHandler.java} | 29 +-
.../ignite/internal/client/table/ClientColumn.java | 99 +
.../ignite/internal/client/table/ClientSchema.java | 102 +
.../ignite/internal/client/table/ClientTable.java | 439 +++++
.../ignite/internal/client/table/ClientTables.java | 102 +
.../internal/client/table/ClientTupleBuilder.java} | 61 +-
.../apache/ignite/client/AbstractClientTest.java | 110 ++
.../org/apache/ignite/client/ClientTableTest.java | 87 +
.../org/apache/ignite/client/ClientTablesTest.java | 103 +
.../org/apache/ignite/client/ConnectionTest.java | 70 +
.../ignite/client}/TestConfigurationStorage.java | 24 +-
.../apache/ignite/client/fakes/FakeIgnite.java} | 27 +-
.../ignite/client/fakes/FakeIgniteTables.java | 133 ++
.../ignite/client/fakes/FakeInternalTable.java | 144 ++
.../internal/client/HostAndPortRangeTest.java | 174 ++
.../HoconConverterTest.java} | 285 +--
.../configuration/json/JsonConverterTest.java | 1 +
.../tree/TraversableTreeNodeTest.java | 7 +
.../ConfigurationChangeException.java | 2 +
.../configuration/ConfigurationProperty.java | 4 +
.../ignite/configuration/ConfigurationTree.java | 3 +
.../ignite/configuration/ConfigurationValue.java | 1 +
.../configuration/NamedConfigurationTree.java | 2 +
.../ignite/configuration/NamedListChange.java | 9 +-
.../apache/ignite/configuration/NamedListView.java | 23 +-
.../org/apache/ignite/configuration/RootKey.java | 27 +-
.../annotation/ConfigurationRoot.java | 12 +-
.../configuration/annotation/NamedConfigValue.java | 24 +-
.../ignite/configuration/annotation/Value.java | 1 +
.../configuration/annotation/package-info.java} | 15 +-
.../ConfigurationNotificationEvent.java | 9 +-
.../configuration/notifications/package-info.java} | 15 +-
.../apache/ignite/configuration/package-info.java} | 15 +-
.../ConfigurationValidationException.java | 11 +
.../ignite/configuration/validation/Max.java | 7 +-
.../ignite/configuration/validation/Min.java | 7 +-
.../validation/ValidationContext.java | 23 +-
.../configuration/validation/ValidationIssue.java | 10 +-
.../configuration/validation/package-info.java} | 15 +-
.../configuration/ConfigurationManager.java | 14 +-
.../asm/ConfigurationAsmGenerator.java | 20 +-
.../hocon/HoconConfigurationVisitor.java | 122 ++
.../configuration/hocon/HoconConverter.java | 53 +
.../hocon/HoconListConfigurationSource.java | 149 ++
.../hocon/HoconObjectConfigurationSource.java | 127 ++
.../hocon/HoconPrimitiveConfigurationSource.java | 199 ++
.../internal/configuration/tree/NamedListNode.java | 24 +-
.../internal/configuration/tree/OrderedMap.java | 11 +
.../configuration/tree/OrderedMapTest.java | 4 +
.../apache/ignite/internal/util/ArrayUtils.java | 2 +-
.../apache/ignite/internal/util/Cancellable.java} | 21 +-
.../ignite/internal/util/CollectionUtils.java | 2 +-
.../apache/ignite/internal/util/IgniteUtils.java | 22 +-
.../java/org/apache/ignite/lang/IgniteBiTuple.java | 5 +-
.../lang/IgniteInternalCheckedException.java | 2 +-
.../ignite/lang/IgniteInternalException.java | 2 +-
.../java/org/apache/ignite/lang/IgniteLogger.java | 84 +-
.../apache/ignite/lang/IgniteStringBuilder.java | 49 +-
.../apache/ignite/lang/IgniteSystemProperties.java | 10 +
.../java/org/apache/ignite/lang/IgniteUuid.java | 6 +-
.../apache/ignite/lang/IgniteUuidGenerator.java | 2 +-
.../apache/ignite/lang/LoggerMessageHelper.java | 2 +
.../java/org/apache/ignite/lang/package-info.java} | 15 +-
.../extensions/communication/package-info.java} | 15 +-
.../testframework/WorkDirectoryExtension.java | 9 +-
modules/metastorage-client/pom.xml | 14 +
.../ITMetaStorageServicePersistenceTest.java | 428 +++++
.../client/ITMetaStorageServiceTest.java | 153 +-
.../internal/metastorage/client/CursorImpl.java | 10 +-
.../metastorage/client/MetaStorageService.java | 11 +
.../metastorage/client/MetaStorageServiceImpl.java | 21 +-
.../metastorage/common/command/RangeCommand.java | 28 +-
.../common/command/WatchExactKeysCommand.java | 20 +-
.../common/command/WatchRangeKeysCommand.java | 25 +-
.../command/cursor/CursorsCloseCommand.java} | 29 +-
modules/metastorage-server/pom.xml | 12 +
.../metastorage/server/KeyValueStorage.java | 23 +-
.../server/SimpleInMemoryKeyValueStorage.java | 21 +-
.../ignite/internal/metastorage/server/Value.java | 2 +-
.../server/persistence/ColumnFamily.java | 158 ++
.../server/persistence/RangeCursor.java | 184 ++
.../server/persistence/RocksDBKeyValueStorage.java | 1092 +++++++++++
.../server/persistence/RocksStorageUtils.java | 267 +++
.../persistence/StorageColumnFamilyType.java} | 36 +-
.../server/persistence/WatchCursor.java | 233 +++
.../server/raft/MetaStorageListener.java | 168 +-
...eTest.java => AbstractKeyValueStorageTest.java} | 164 +-
.../server/RocksDbKeyValueStorageTest.java} | 37 +-
.../server/SimpleInMemoryKeyValueStorageTest.java | 2032 +-------------------
.../internal/metastorage/MetaStorageManager.java | 23 +-
.../ignite/network/AbstractMessagingService.java | 46 +-
.../ignite/network/ClusterLocalConfiguration.java | 17 +-
.../apache/ignite/network/MessagingService.java | 2 +
.../org/apache/ignite/network/NodeFinder.java} | 20 +-
modules/network/pom.xml | 5 +
.../network/scalecube/ITNodeRestartsTest.java | 32 +-
.../scalecube/ITScaleCubeNetworkMessagingTest.java | 23 +-
.../apache/ignite/network/StaticNodeFinder.java | 56 +
.../scalecube/ScaleCubeClusterServiceFactory.java | 2 +-
.../network/AbstractMessagingServiceTest.java | 76 +
.../ignite/network/LocalPortRangeNodeFinder.java | 49 +
.../raft/client/service/RaftGroupListener.java | 10 +-
modules/raft/pom.xml | 19 +
.../ignite/raft/jraft/core/ITCliServiceTest.java | 14 +-
.../apache/ignite/raft/jraft/core/ITNodeTest.java | 24 +-
.../apache/ignite/raft/server/CounterListener.java | 13 +-
.../raft/server/ITJRaftCounterServerTest.java | 6 +-
.../raft/server/ITSimpleCounterServerTest.java | 13 +-
.../ignite/raft/server/RaftServerAbstractTest.java | 3 +-
.../java/org/apache/ignite/internal/raft/Loza.java | 49 +-
.../internal/raft/server/impl/JRaftServerImpl.java | 10 +-
.../internal/raft/server/impl/RaftServerImpl.java | 2 +-
.../apache/ignite/raft/jraft/core/TestCluster.java | 23 +-
.../ignite/raft/jraft/rpc/IgniteRpcTest.java | 6 +-
.../ignite/raft/jraft/rpc/TestIgniteRpcServer.java | 10 +-
.../ignite/raft/jraft/util/ThreadIdTest.java | 24 +-
modules/runner/pom.xml | 5 +
.../runner/app/LiveSchemaChangeKVViewTest.java | 7 +-
.../runner/app/LiveSchemaChangeTableTest.java | 13 +-
.../org/apache/ignite/internal/app/IgniteImpl.java | 11 +-
.../apache/ignite/internal/app/IgnitionImpl.java | 22 +-
modules/schema/README.md | 2 +-
.../ignite/internal/schema/SchemaAware.java} | 20 +-
modules/table/pom.xml | 7 +
.../ignite/distributed/ITDistributedTableTest.java | 42 +-
.../internal/table/IgniteTablesInternal.java} | 21 +-
.../ignite/internal/table/RowChunkAdapter.java | 3 +-
.../org/apache/ignite/internal/table/TableRow.java | 20 +-
.../ignite/internal/table/TupleBuilderImpl.java | 29 +-
.../internal/table/distributed/TableManager.java | 57 +-
.../table/distributed/raft/PartitionListener.java | 10 +-
.../internal/table/event/TableEventParameters.java | 4 +-
parent/pom.xml | 64 +-
pom.xml | 3 +
293 files changed, 17252 insertions(+), 4476 deletions(-)
copy modules/{calcite/src/main/java/org/apache/calcite/plan/volcano/VolcanoUtils.java => api/src/main/java/org/apache/ignite/app/package-info.java} (77%)
copy modules/{configuration-api/src/main/java/org/apache/ignite/configuration/ConfigurationProperty.java => api/src/main/java/org/apache/ignite/configuration/schemas/clientconnector/ClientConnectorConfigurationSchema.java} (50%)
copy modules/{calcite/src/main/java/org/apache/calcite/plan/volcano/VolcanoUtils.java => api/src/main/java/org/apache/ignite/configuration/schemas/clientconnector/package-info.java} (77%)
copy modules/{calcite/src/main/java/org/apache/calcite/plan/volcano/VolcanoUtils.java => api/src/main/java/org/apache/ignite/configuration/schemas/network/package-info.java} (77%)
copy modules/{calcite/src/main/java/org/apache/calcite/plan/volcano/VolcanoUtils.java => api/src/main/java/org/apache/ignite/configuration/schemas/rest/package-info.java} (77%)
copy modules/{calcite/src/main/java/org/apache/calcite/plan/volcano/VolcanoUtils.java => api/src/main/java/org/apache/ignite/configuration/schemas/runner/package-info.java} (77%)
copy modules/{calcite/src/main/java/org/apache/calcite/plan/volcano/VolcanoUtils.java => api/src/main/java/org/apache/ignite/lang/package-info.java} (77%)
copy modules/{calcite/src/main/java/org/apache/calcite/plan/volcano/VolcanoUtils.java => api/src/main/java/org/apache/ignite/tx/package-info.java} (77%)
copy modules/calcite/src/main/java/org/apache/calcite/plan/volcano/{VolcanoUtils.java => package-info.java} (81%)
create mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/SqlQueryProcessor.java
create mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/ClosableIteratorsHolder.java
create mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/ExchangeService.java
create mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/ExchangeServiceImpl.java
copy modules/{configuration-api/src/main/java/org/apache/ignite/configuration/NamedListView.java => calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/ExecutionService.java} (62%)
create mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/ExecutionServiceImpl.java
create mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/LogicalRelImplementor.java
create mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/MailboxRegistry.java
create mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/MailboxRegistryImpl.java
create mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/Inbox.java
create mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/Outbox.java
copy modules/{configuration-api/src/main/java/org/apache/ignite/configuration/NamedListView.java => calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/ErrorMessage.java} (61%)
copy modules/{configuration-api/src/main/java/org/apache/ignite/configuration/NamedListView.java => calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/ExecutionContextAwareMessage.java} (64%)
copy modules/{configuration-api/src/main/java/org/apache/ignite/configuration/NamedListView.java => calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/InboxCloseMessage.java} (61%)
copy modules/calcite/src/main/java/org/apache/{calcite/plan/volcano/VolcanoUtils.java => ignite/internal/processors/query/calcite/message/MessageListener.java} (72%)
copy modules/{configuration-api/src/main/java/org/apache/ignite/configuration/ConfigurationProperty.java => calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/MessageService.java} (53%)
create mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/MessageServiceImpl.java
copy modules/{configuration-api/src/main/java/org/apache/ignite/configuration/NamedListView.java => calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/OutboxCloseMessage.java} (61%)
copy modules/calcite/src/main/java/org/apache/{calcite/plan/volcano/VolcanoUtils.java => ignite/internal/processors/query/calcite/message/QueryBatchAcknowledgeMessage.java} (66%)
copy modules/{configuration-api/src/main/java/org/apache/ignite/configuration/NamedListView.java => calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/QueryBatchMessage.java} (63%)
copy modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/{prepare/MultiStepPlan.java => message/QueryStartRequest.java} (55%)
copy modules/{configuration-api/src/main/java/org/apache/ignite/configuration/NamedListView.java => calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/QueryStartResponse.java} (61%)
copy modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/{trait/IgniteDistribution.java => message/SqlQueryMessageGroup.java} (55%)
copy modules/calcite/src/main/java/org/apache/{calcite/plan/volcano/VolcanoUtils.java => ignite/internal/processors/query/calcite/metadata/AffinityService.java} (67%)
create mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/metadata/MappingServiceImpl.java
copy modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/metadata/{FragmentDescription.java => RemoteException.java} (54%)
create mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/CacheKey.java
copy modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/{MultiStepQueryPlan.java => DdlPlan.java} (73%)
copy modules/calcite/src/main/java/org/apache/{calcite/plan/volcano/VolcanoUtils.java => ignite/internal/processors/query/calcite/prepare/DummyPlanCache.java} (67%)
copy modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/{MultiStepQueryPlan.java => ExplainPlan.java} (63%)
copy modules/calcite/src/main/java/org/apache/{calcite/plan/volcano/VolcanoUtils.java => ignite/internal/processors/query/calcite/prepare/FieldsMetadata.java} (67%)
copy modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/{MultiStepQueryPlan.java => FieldsMetadataImpl.java} (63%)
copy modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/{MultiStepQueryPlan.java => FragmentPlan.java} (66%)
copy modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/{MultiStepQueryPlan.java => MultiStepDmlPlan.java} (80%)
copy modules/{configuration-api/src/main/java/org/apache/ignite/configuration/NamedListView.java => calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/QueryPlanCache.java} (66%)
copy modules/calcite/src/main/java/org/apache/{calcite/plan/volcano/VolcanoUtils.java => ignite/internal/processors/query/calcite/prepare/QueryPlanFactory.java} (75%)
create mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/set/IgniteIntersect.java
create mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/set/IgniteMapIntersect.java
copy modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/set/{IgniteMapMinus.java => IgniteMapSetOp.java} (63%)
create mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/set/IgniteMinus.java
copy modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/set/{IgniteReduceMinus.java => IgniteReduceIntersect.java} (50%)
create mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/set/IgniteReduceSetOp.java
create mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/set/IgniteSetOp.java
create mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/set/IgniteSingleIntersect.java
copy modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/set/{IgniteSingleMinus.java => IgniteSingleSetOp.java} (58%)
create mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rule/SetOpConverterRule.java
create mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/schema/ColumnDescriptorImpl.java
create mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/schema/IgniteTableImpl.java
copy modules/calcite/src/main/java/org/apache/{calcite/plan/volcano/VolcanoUtils.java => ignite/internal/processors/query/calcite/schema/SchemaHolder.java} (77%)
create mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/schema/SchemaHolderImpl.java
create mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/schema/TableDescriptorImpl.java
copy modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/trait/{IgniteDistribution.java => AffinityAdapter.java} (52%)
copy modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/trait/{IgniteDistribution.java => AllNodes.java} (67%)
copy modules/calcite/src/main/java/org/apache/{calcite/plan/volcano/VolcanoUtils.java => ignite/internal/processors/query/calcite/trait/Destination.java} (68%)
copy modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/trait/{IgniteDistribution.java => Partitioned.java} (53%)
copy modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/trait/{IgniteDistribution.java => RandomNode.java} (61%)
copy modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/{prepare/MultiStepQueryPlan.java => util/NodeLeaveHandler.java} (58%)
delete mode 100644 modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/planner/ExceptPlannerTest.java
create mode 100644 modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/planner/SetOpPlannerTest.java
rename modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/planner/{TableFunctionTest.java => TableFunctionPlannerTest.java} (98%)
create mode 100644 modules/client-common/README.md
copy modules/{runner => client-common}/pom.xml (70%)
copy modules/{configuration-api/src/main/java/org/apache/ignite/configuration/validation/ConfigurationValidationException.java => client-common/src/main/java/org/apache/ignite/client/proto/ClientDataType.java} (52%)
copy modules/{calcite/src/main/java/org/apache/calcite/plan/volcano/VolcanoUtils.java => client-common/src/main/java/org/apache/ignite/client/proto/ClientErrorCode.java} (68%)
create mode 100644 modules/client-common/src/main/java/org/apache/ignite/client/proto/ClientMessageDecoder.java
copy modules/{calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/MultiStepQueryPlan.java => client-common/src/main/java/org/apache/ignite/client/proto/ClientMessageEncoder.java} (52%)
create mode 100644 modules/client-common/src/main/java/org/apache/ignite/client/proto/ClientMessagePacker.java
create mode 100644 modules/client-common/src/main/java/org/apache/ignite/client/proto/ClientMessageUnpacker.java
copy modules/{configuration-api/src/main/java/org/apache/ignite/configuration/validation/Min.java => client-common/src/main/java/org/apache/ignite/client/proto/ClientMsgPackType.java} (63%)
copy modules/{calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/trait/IgniteDistribution.java => client-common/src/main/java/org/apache/ignite/client/proto/ClientOp.java} (54%)
create mode 100644 modules/client-common/src/main/java/org/apache/ignite/client/proto/ProtocolVersion.java
copy modules/{calcite/src/main/java/org/apache/calcite/plan/volcano/VolcanoUtils.java => client-common/src/main/java/org/apache/ignite/client/proto/ServerMessageType.java} (71%)
copy modules/{calcite/src/main/java/org/apache/calcite/plan/volcano/VolcanoUtils.java => client-common/src/main/java/org/apache/ignite/client/proto/package-info.java} (77%)
create mode 100644 modules/client-common/src/test/java/org/apache/ignite/client/proto/ClientMessageDecoderTest.java
create mode 100644 modules/client-common/src/test/java/org/apache/ignite/client/proto/ClientMessageEncoderTest.java
create mode 100644 modules/client-common/src/test/java/org/apache/ignite/client/proto/ClientMessagePackerUnpackerTest.java
create mode 100644 modules/client-handler/README.md
copy modules/{runner => client-handler}/pom.xml (71%)
create mode 100644 modules/client-handler/src/main/java/org/apache/ignite/client/handler/ClientContext.java
create mode 100644 modules/client-handler/src/main/java/org/apache/ignite/client/handler/ClientHandlerModule.java
create mode 100644 modules/client-handler/src/main/java/org/apache/ignite/client/handler/ClientInboundMessageHandler.java
copy modules/{calcite/src/main/java/org/apache/calcite/plan/volcano/VolcanoUtils.java => client-handler/src/main/java/org/apache/ignite/client/handler/package-info.java} (77%)
create mode 100644 modules/client-handler/src/test/java/org/apache/ignite/client/handler/ClientHandlerIntegrationTest.java
copy modules/{configuration-annotation-processor/src/test/java/org/apache/ignite/internal/configuration/json => client-handler/src/test/java/org/apache/ignite/client/handler}/TestConfigurationStorage.java (84%)
create mode 100644 modules/client/README.md
copy modules/{runner => client}/pom.xml (74%)
create mode 100644 modules/client/src/main/java/org/apache/ignite/client/IgniteClient.java
copy modules/{configuration-api/src/main/java/org/apache/ignite/configuration/ConfigurationValue.java => client/src/main/java/org/apache/ignite/client/IgniteClientAddressFinder.java} (52%)
copy modules/{configuration-api/src/main/java/org/apache/ignite/configuration/ConfigurationChangeException.java => client/src/main/java/org/apache/ignite/client/IgniteClientAuthenticationException.java} (58%)
create mode 100644 modules/client/src/main/java/org/apache/ignite/client/IgniteClientAuthorizationException.java
copy modules/{configuration-api/src/main/java/org/apache/ignite/configuration/ConfigurationProperty.java => client/src/main/java/org/apache/ignite/client/IgniteClientConfiguration.java} (53%)
copy modules/{configuration-api/src/main/java/org/apache/ignite/configuration/ConfigurationChangeException.java => client/src/main/java/org/apache/ignite/client/IgniteClientConnectionException.java} (53%)
create mode 100644 modules/client/src/main/java/org/apache/ignite/client/IgniteClientException.java
create mode 100644 modules/client/src/main/java/org/apache/ignite/client/IgniteClientFeatureNotSupportedByServerException.java
copy modules/{calcite/src/main/java/org/apache/calcite/plan/volcano/VolcanoUtils.java => client/src/main/java/org/apache/ignite/client/package-info.java} (77%)
create mode 100644 modules/client/src/main/java/org/apache/ignite/internal/client/ClientChannel.java
create mode 100644 modules/client/src/main/java/org/apache/ignite/internal/client/ClientChannelConfiguration.java
create mode 100644 modules/client/src/main/java/org/apache/ignite/internal/client/HostAndPortRange.java
copy modules/{configuration-api/src/main/java/org/apache/ignite/configuration/ConfigurationChangeException.java => client/src/main/java/org/apache/ignite/internal/client/PayloadInputChannel.java} (53%)
copy modules/{configuration-api/src/main/java/org/apache/ignite/configuration/validation/ValidationIssue.java => client/src/main/java/org/apache/ignite/internal/client/PayloadOutputChannel.java} (50%)
copy modules/{calcite/src/main/java/org/apache/calcite/plan/volcano/VolcanoUtils.java => client/src/main/java/org/apache/ignite/internal/client/PayloadReader.java} (70%)
copy modules/{calcite/src/main/java/org/apache/calcite/plan/volcano/VolcanoUtils.java => client/src/main/java/org/apache/ignite/internal/client/PayloadWriter.java} (72%)
create mode 100644 modules/client/src/main/java/org/apache/ignite/internal/client/ProtocolBitmaskFeature.java
create mode 100644 modules/client/src/main/java/org/apache/ignite/internal/client/ProtocolContext.java
create mode 100644 modules/client/src/main/java/org/apache/ignite/internal/client/ReliableChannel.java
create mode 100644 modules/client/src/main/java/org/apache/ignite/internal/client/TcpClientChannel.java
create mode 100644 modules/client/src/main/java/org/apache/ignite/internal/client/TcpIgniteClient.java
copy modules/{configuration-api/src/main/java/org/apache/ignite/configuration/NamedListView.java => client/src/main/java/org/apache/ignite/internal/client/io/ClientConnection.java} (62%)
create mode 100644 modules/client/src/main/java/org/apache/ignite/internal/client/io/ClientConnectionMultiplexer.java
copy modules/{calcite/src/main/java/org/apache/calcite/plan/volcano/VolcanoUtils.java => client/src/main/java/org/apache/ignite/internal/client/io/ClientConnectionStateHandler.java} (69%)
copy modules/{calcite/src/main/java/org/apache/calcite/plan/volcano/VolcanoUtils.java => client/src/main/java/org/apache/ignite/internal/client/io/ClientMessageHandler.java} (66%)
create mode 100644 modules/client/src/main/java/org/apache/ignite/internal/client/io/netty/NettyClientConnection.java
create mode 100644 modules/client/src/main/java/org/apache/ignite/internal/client/io/netty/NettyClientConnectionMultiplexer.java
copy modules/{calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/MultiStepQueryPlan.java => client/src/main/java/org/apache/ignite/internal/client/io/netty/NettyClientMessageHandler.java} (54%)
create mode 100644 modules/client/src/main/java/org/apache/ignite/internal/client/table/ClientColumn.java
create mode 100644 modules/client/src/main/java/org/apache/ignite/internal/client/table/ClientSchema.java
create mode 100644 modules/client/src/main/java/org/apache/ignite/internal/client/table/ClientTable.java
create mode 100644 modules/client/src/main/java/org/apache/ignite/internal/client/table/ClientTables.java
copy modules/{table/src/main/java/org/apache/ignite/internal/table/TupleBuilderImpl.java => client/src/main/java/org/apache/ignite/internal/client/table/ClientTupleBuilder.java} (66%)
create mode 100644 modules/client/src/test/java/org/apache/ignite/client/AbstractClientTest.java
create mode 100644 modules/client/src/test/java/org/apache/ignite/client/ClientTableTest.java
create mode 100644 modules/client/src/test/java/org/apache/ignite/client/ClientTablesTest.java
create mode 100644 modules/client/src/test/java/org/apache/ignite/client/ConnectionTest.java
rename modules/{configuration-annotation-processor/src/test/java/org/apache/ignite/internal/configuration/json => client/src/test/java/org/apache/ignite/client}/TestConfigurationStorage.java (84%)
copy modules/{runner/src/main/java/org/apache/ignite/internal/app/IgniteImpl.java => client/src/test/java/org/apache/ignite/client/fakes/FakeIgnite.java} (64%)
create mode 100644 modules/client/src/test/java/org/apache/ignite/client/fakes/FakeIgniteTables.java
create mode 100644 modules/client/src/test/java/org/apache/ignite/client/fakes/FakeInternalTable.java
create mode 100644 modules/client/src/test/java/org/apache/ignite/internal/client/HostAndPortRangeTest.java
copy modules/configuration-annotation-processor/src/test/java/org/apache/ignite/internal/configuration/{json/JsonConverterTest.java => hocon/HoconConverterTest.java} (57%)
copy modules/{calcite/src/main/java/org/apache/calcite/plan/volcano/VolcanoUtils.java => configuration-api/src/main/java/org/apache/ignite/configuration/annotation/package-info.java} (77%)
copy modules/{calcite/src/main/java/org/apache/calcite/plan/volcano/VolcanoUtils.java => configuration-api/src/main/java/org/apache/ignite/configuration/notifications/package-info.java} (77%)
copy modules/{calcite/src/main/java/org/apache/calcite/plan/volcano/VolcanoUtils.java => configuration-api/src/main/java/org/apache/ignite/configuration/package-info.java} (77%)
copy modules/{calcite/src/main/java/org/apache/calcite/plan/volcano/VolcanoUtils.java => configuration-api/src/main/java/org/apache/ignite/configuration/validation/package-info.java} (77%)
create mode 100644 modules/configuration/src/main/java/org/apache/ignite/internal/configuration/hocon/HoconConfigurationVisitor.java
create mode 100644 modules/configuration/src/main/java/org/apache/ignite/internal/configuration/hocon/HoconConverter.java
create mode 100644 modules/configuration/src/main/java/org/apache/ignite/internal/configuration/hocon/HoconListConfigurationSource.java
create mode 100644 modules/configuration/src/main/java/org/apache/ignite/internal/configuration/hocon/HoconObjectConfigurationSource.java
create mode 100644 modules/configuration/src/main/java/org/apache/ignite/internal/configuration/hocon/HoconPrimitiveConfigurationSource.java
copy modules/{calcite/src/main/java/org/apache/calcite/plan/volcano/VolcanoUtils.java => core/src/main/java/org/apache/ignite/internal/util/Cancellable.java} (72%)
copy modules/{calcite/src/main/java/org/apache/calcite/plan/volcano/VolcanoUtils.java => core/src/main/java/org/apache/ignite/lang/package-info.java} (77%)
copy modules/{calcite/src/main/java/org/apache/calcite/plan/volcano/VolcanoUtils.java => core/src/main/java/org/apache/ignite/plugin/extensions/communication/package-info.java} (77%)
create mode 100644 modules/metastorage-client/src/integrationTest/java/org/apache/ignite/internal/metastorage/client/ITMetaStorageServicePersistenceTest.java
copy modules/{configuration-api/src/main/java/org/apache/ignite/configuration/ConfigurationChangeException.java => metastorage-common/src/main/java/org/apache/ignite/internal/metastorage/common/command/cursor/CursorsCloseCommand.java} (57%)
create mode 100644 modules/metastorage-server/src/main/java/org/apache/ignite/internal/metastorage/server/persistence/ColumnFamily.java
create mode 100644 modules/metastorage-server/src/main/java/org/apache/ignite/internal/metastorage/server/persistence/RangeCursor.java
create mode 100644 modules/metastorage-server/src/main/java/org/apache/ignite/internal/metastorage/server/persistence/RocksDBKeyValueStorage.java
create mode 100644 modules/metastorage-server/src/main/java/org/apache/ignite/internal/metastorage/server/persistence/RocksStorageUtils.java
copy modules/{configuration-api/src/main/java/org/apache/ignite/configuration/ConfigurationChangeException.java => metastorage-server/src/main/java/org/apache/ignite/internal/metastorage/server/persistence/StorageColumnFamilyType.java} (51%)
create mode 100644 modules/metastorage-server/src/main/java/org/apache/ignite/internal/metastorage/server/persistence/WatchCursor.java
copy modules/metastorage-server/src/test/java/org/apache/ignite/internal/metastorage/server/{SimpleInMemoryKeyValueStorageTest.java => AbstractKeyValueStorageTest.java} (92%)
copy modules/{configuration-api/src/main/java/org/apache/ignite/configuration/validation/ValidationIssue.java => metastorage-server/src/test/java/org/apache/ignite/internal/metastorage/server/RocksDbKeyValueStorageTest.java} (55%)
copy modules/{calcite/src/main/java/org/apache/calcite/plan/volcano/VolcanoUtils.java => network-api/src/main/java/org/apache/ignite/network/NodeFinder.java} (67%)
create mode 100644 modules/network/src/main/java/org/apache/ignite/network/StaticNodeFinder.java
create mode 100644 modules/network/src/test/java/org/apache/ignite/network/AbstractMessagingServiceTest.java
create mode 100644 modules/network/src/test/java/org/apache/ignite/network/LocalPortRangeNodeFinder.java
rename modules/raft/src/{main => test}/java/org/apache/ignite/internal/raft/server/impl/RaftServerImpl.java (98%)
copy modules/{calcite/src/main/java/org/apache/calcite/plan/volcano/VolcanoUtils.java => schema/src/main/java/org/apache/ignite/internal/schema/SchemaAware.java} (77%)
copy modules/{calcite/src/main/java/org/apache/calcite/plan/volcano/VolcanoUtils.java => table/src/main/java/org/apache/ignite/internal/table/IgniteTablesInternal.java} (69%)