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/23 11:00:40 UTC

[ignite-3] branch ignite-14743 updated (d127d0e -> a836493)

This is an automated email from the ASF dual-hosted git repository.

amashenkov pushed a change to branch ignite-14743
in repository https://gitbox.apache.org/repos/asf/ignite-3.git.


    from d127d0e  Math operations optimization on hot-path.
     add 35432e7  IGNITE-14791 Support all primitive types in configuration (#165)
     add f29e27d  IGNITE-14819 Propagate exceptions from NettyServer and NettyClient (#161)
     add d00ff8f  IGNITE-14895 Reflection replaced with method handles in GridUnsafe. (#172)
     add 9d631e1  IGNITE-14773 Fixed an issue that led to IgniteTables#table(String tableName) could return null for the not fully initialized table. Fixes #149
     add 3cd6981  IGNITE-14709 Changed readAll in DistributedConfigurationStorage to take configuration keys stored in the vault. Fixes #160
     add d1c4f34  IGNITE-14909 Use local address instead of external in AbstractRpcTest (#177)
     add 8fbb6ba  IGNITE-14915 Fix package structure in network and network-processor modules
     add cb7d9f7  IGNITE-14910 Use local address in JRaft tests (#178)
     add 60834cb  IGNITE-14917 Configuration modules internal packages renamed. (#180)
     add 0431187  IGNITE-14560 Fixed javadoc warnings in cli module. Fixes #170
     add 7ccdb7d  IGNITE-14918 Externalize ClusterService lifecycle management - Fixes #183.
     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 bb13145  Merge branch 'main' into ignite-14743
     add a836493  Inline row reader.

No new revisions were added by this update.

Summary of changes:
 .../ignite/internal/affinity/AffinityManager.java  |    8 +-
 .../internal/affinity/AffinityManagerTest.java     |   37 +-
 .../affinity/TestConfigurationStorage.java         |   10 +-
 .../network/NetworkConfigurationSchema.java        |    2 +-
 .../schemas/rest/RestConfigurationSchema.java      |    2 +-
 .../schemas/runner/ClusterConfigurationSchema.java |    2 +-
 .../schemas/runner/NodeConfigurationSchema.java    |    2 +-
 .../schemas/table/TablesConfigurationSchema.java   |    2 +-
 .../main/java/org/apache/ignite/table/Table.java   |    8 +
 .../ignite/internal/baseline/BaselineManager.java  |    2 +-
 .../internal/processors/query/calcite/Stubs.java   |    6 -
 .../query/calcite/exec/AbstractIndexScan.java      |  107 +
 .../query/calcite/exec/ArrayRowHandler.java        |   77 +
 .../calcite/exec/ExecutionCancelledException.java} |    8 +-
 .../query/calcite/exec/ExecutionContext.java       |  292 +++
 .../query/calcite/exec/PlannerHelper.java          |  229 ++
 .../query/calcite/exec/QueryTaskExecutor.java}     |   35 +-
 .../query/calcite/exec/QueryTaskExecutorImpl.java  |   95 +
 .../processors/query/calcite/exec/RowHandler.java  |   73 +
 .../query/calcite/exec/RuntimeHashIndex.java       |  113 +
 .../query/calcite/exec/RuntimeIndex.java}          |   12 +-
 .../query/calcite/exec/RuntimeTreeIndex.java       |  196 ++
 .../query/calcite/exec/TableFunctionScan.java      |   48 +
 .../processors/query/calcite/exec/TreeIndex.java}  |   17 +-
 .../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}   |   34 +-
 .../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} |   10 +-
 .../query/calcite/exec/exp/agg/Accumulator.java}   |   27 +-
 .../calcite/exec/exp/agg/AccumulatorWrapper.java}  |   19 +-
 .../query/calcite/exec/exp/agg/Accumulators.java   | 1068 ++++++++
 .../calcite/exec/exp/agg/AccumulatorsFactory.java  |  330 +++
 .../query/calcite/exec/exp/agg/AggregateType.java} |   17 +-
 .../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}        |   31 +-
 .../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}           |   25 +-
 .../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}  |   33 +-
 .../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 ++
 .../java/org/apache/ignite/cli/IgnitePaths.java    |   26 +-
 .../cli/builtins/init/InitIgniteCommand.java       |    2 +-
 .../org/apache/ignite/cli/ui/TerminalFactory.java  |    6 +-
 modules/configuration-annotation-processor/pom.xml |   14 +-
 .../processor}/AbstractProcessorTest.java          |   10 +-
 .../configuration/processor}/ConfigSet.java        |    2 +-
 .../configuration/processor}/HasFieldMatcher.java  |    2 +-
 .../configuration/processor}/HasMethodMatcher.java |    2 +-
 .../configuration/processor}/ITProcessorTest.java  |    4 +-
 .../configuration/processor}/ParsedClass.java      |    4 +-
 .../processor}/TestConfigurationSchema.java        |    2 +-
 .../configuration/processor}/Processor.java        |  119 +-
 .../processor}/ProcessorException.java             |    2 +-
 .../configuration/processor}/Utils.java            |    2 +-
 .../services/javax.annotation.processing.Processor |    2 +-
 .../sample/ConfigurationArrayTest.java             |  116 -
 .../configuration/ConfigurationChangerTest.java    |   20 +-
 .../configuration/json/JsonConverterTest.java      |  540 ++++
 .../json/TestConfigurationStorage.java             |   13 +-
 .../notifications/ConfigurationListenerTest.java   |   12 +-
 .../sample/AutoAdjustConfigurationSchema.java      |    2 +-
 .../sample/BaselineConfigurationSchema.java        |    2 +-
 .../sample/CacheConfigurationSchema.java           |    2 +-
 .../sample/ClusterWideConfigurationSchema.java     |    2 +-
 .../sample/ConfigurationArrayTest.java             |  225 ++
 .../sample/ConstructableTreeNodeTest.java          |   10 +-
 .../sample/DiscoveryConfigurationSchema.java       |    2 +-
 .../sample/LocalConfigurationSchema.java           |    4 +-
 .../sample/NetworkConfigurationSchema.java         |    4 +-
 .../sample/NodeConfigurationSchema.java            |    2 +-
 .../sample/TraversableTreeNodeTest.java            |   16 +-
 .../configuration/sample/UsageTest.java            |    6 +-
 .../storage/TestConfigurationStorage.java          |    3 +-
 .../configuration}/util/ConfigurationUtilTest.java |   12 +-
 .../validation/ValidationUtilTest.java             |   14 +-
 .../configuration/NamedConfigurationTree.java      |    2 -
 .../configuration/{tree => }/NamedListChange.java  |    2 +-
 .../configuration/{tree => }/NamedListView.java    |    2 +-
 .../org/apache/ignite/configuration/RootKey.java   |    2 +-
 .../annotation/ConfigurationRoot.java              |    1 -
 .../{storage => annotation}/ConfigurationType.java |    2 +-
 modules/configuration/README.md                    |    7 +-
 .../configuration/internal/rest/JsonConverter.java |  358 ---
 .../configuration/ConfigurationChanger.java        |   37 +-
 .../configuration}/ConfigurationManager.java       |   14 +-
 .../configuration}/ConfigurationNode.java          |    9 +-
 .../configuration/ConfigurationRegistry.java       |   34 +-
 .../configuration}/DynamicConfiguration.java       |    7 +-
 .../configuration}/DynamicProperty.java            |    7 +-
 .../configuration}/NamedListConfiguration.java     |    7 +-
 .../configuration}/SuperRoot.java                  |    8 +-
 .../ignite/internal/configuration/TypeUtils.java   |   83 +
 .../asm/ConfigurationAsmGenerator.java             |   44 +-
 .../configuration}/asm/SchemaClassesInfo.java      |    6 +-
 .../configuration}/asm/StringSwitchBuilder.java    |   14 +-
 .../json/JsonConfigurationVisitor.java             |  127 +
 .../internal/configuration/json/JsonConverter.java |   43 +
 .../json/JsonObjectConfigurationSource.java        |  105 +
 .../json/JsonPrimitiveConfigurationSource.java     |  202 ++
 .../ConfigurationNotificationEventImpl.java        |    2 +-
 .../storage/ConfigurationStorage.java              |    3 +-
 .../storage/ConfigurationStorageListener.java      |    2 +-
 .../{ => internal}/configuration/storage/Data.java |    2 +-
 .../configuration/storage/StorageException.java    |    2 +-
 .../configuration/tree/ConfigurationSource.java    |    2 +-
 .../configuration/tree/ConfigurationVisitor.java   |    2 +-
 .../configuration/tree/ConstructableTreeNode.java  |    2 +-
 .../configuration/tree/InnerNode.java              |    2 +-
 .../configuration/tree/NamedListNode.java          |    4 +-
 .../configuration/tree/TraversableTreeNode.java    |    2 +-
 .../util/AnyNodeConfigurationVisitor.java          |    8 +-
 .../util/ConfigurationNotificationsUtil.java       |   26 +-
 .../configuration}/util/ConfigurationUtil.java     |   16 +-
 .../configuration}/util/KeyNotFoundException.java  |    2 +-
 .../util/KeysTrackingConfigurationVisitor.java     |    8 +-
 .../validation/ImmutableValidator.java             |    2 +-
 .../configuration}/validation/MaxValidator.java    |    2 +-
 .../configuration}/validation/MemberKey.java       |    2 +-
 .../configuration}/validation/MinValidator.java    |    2 +-
 .../validation/ValidationContextImpl.java          |   12 +-
 .../configuration}/validation/ValidationUtil.java  |   12 +-
 .../org/apache/ignite/internal/manager/Event.java  |    2 +-
 .../ignite/internal/manager/EventListener.java     |   47 +
 .../{Event.java => ListenerRemovedException.java}  |    7 +-
 .../apache/ignite/internal/manager/Producer.java   |   24 +-
 .../apache/ignite/internal/util/ArrayUtils.java    |    2 +
 .../org/apache/ignite/internal/util/ByteUtils.java |   11 +
 .../apache/ignite/internal/util/GridUnsafe.java    |  108 +-
 .../apache/ignite/internal/util/IgniteUtils.java   |   30 +-
 .../internal/testframework/IgniteTestUtils.java    |   71 +
 .../internal/util/IgniteIntListSelfTest.java       |  159 ++
 .../client/ITMetaStorageServiceTest.java           |   45 +-
 .../server/raft/MetaStorageListener.java           |   13 +-
 .../internal/metastorage/MetaStorageManager.java   |  146 +-
 modules/network-annotation-processor/pom.xml       |    2 +-
 .../ITTransferableObjectProcessorTest.java         |    6 +-
 .../network/processor}/AllTypesMessage.java        |    2 +-
 .../network/processor}/ConflictingTypeMessage.java |    2 +-
 .../network/processor}/ITTestMessageGroup.java     |    2 +-
 .../processor}/InvalidAnnotatedTypeMessage.java    |    2 +-
 .../processor}/InvalidParameterGetterMessage.java  |    2 +-
 .../processor}/InvalidReturnTypeGetterMessage.java |    2 +-
 .../network/processor}/SecondGroup.java            |    2 +-
 .../network/processor}/TransitiveMessage.java      |    2 +-
 .../processor}/UnmarshallableTypeMessage.java      |    2 +-
 .../UnmarshallableTypeNonSerializableMessage.java  |    2 +-
 .../network/processor}/MessageClass.java           |    2 +-
 .../network/processor}/MessageGroupWrapper.java    |    2 +-
 .../network/processor}/ProcessingException.java    |    2 +-
 .../processor}/TransferableObjectProcessor.java    |   16 +-
 .../network/processor}/TypeUtils.java              |    2 +-
 .../messages/MessageBuilderGenerator.java          |    6 +-
 .../messages/MessageFactoryGenerator.java          |    6 +-
 .../processor}/messages/MessageImplGenerator.java  |    6 +-
 .../serialization/BaseMethodNameResolver.java      |    6 +-
 .../MessageCollectionItemTypeConverter.java        |    6 +-
 .../MessageDeserializerGenerator.java              |    6 +-
 .../serialization/MessageReaderMethodResolver.java |    2 +-
 .../serialization/MessageSerializerGenerator.java  |    6 +-
 .../serialization/MessageWriterMethodResolver.java |    4 +-
 .../RegistryInitializerGenerator.java              |    6 +-
 .../SerializationFactoryGenerator.java             |    6 +-
 .../services/javax.annotation.processing.Processor |    2 +-
 .../processor}/SerializationOrderMessage.java      |    2 +-
 .../network/processor}/SerializationOrderTest.java |    2 +-
 .../network/processor}/TestMessageGroup.java       |    2 +-
 .../apache/ignite/network/MessagingService.java    |   10 +
 .../ignite/network/NetworkMessageHandler.java      |    5 +-
 .../network}/netty/ConnectionManagerTest.java      |   79 +-
 .../network}/recovery/RecoveryHandshakeTest.java   |   30 +-
 .../scalecube/ITScaleCubeNetworkMessagingTest.java |   13 +-
 .../network/NetworkMessageTypes.java               |    8 +-
 .../network}/direct/DirectMarshallingUtils.java    |    4 +-
 .../network}/direct/DirectMessageReader.java       |   10 +-
 .../network}/direct/DirectMessageWriter.java       |   10 +-
 .../network}/direct/state/DirectMessageState.java  |    2 +-
 .../direct/state/DirectMessageStateItem.java       |    2 +-
 .../direct/stream/DirectByteBufferStream.java      |    2 +-
 .../stream/DirectByteBufferStreamImplV1.java       |    2 +-
 .../network}/handshake/HandshakeAction.java        |    4 +-
 .../network}/handshake/HandshakeException.java     |    2 +-
 .../network}/handshake/HandshakeManager.java       |    6 +-
 .../network}/message/ScaleCubeMessage.java         |    4 +-
 .../network}/netty/ConnectionManager.java          |   25 +-
 .../network}/netty/HandshakeHandler.java           |   33 +-
 .../network}/netty/InboundDecoder.java             |   37 +-
 .../netty/IoExceptionSuppressingHandler.java}      |   36 +-
 .../network}/netty/MessageHandler.java             |    2 +-
 .../network}/netty/NettyClient.java                |    7 +-
 .../network}/netty/NettySender.java                |    4 +-
 .../network}/netty/NettyServer.java                |   16 +-
 .../network}/netty/NettyUtils.java                 |    2 +-
 .../network}/netty/OutboundEncoder.java            |    4 +-
 .../recovery/RecoveryClientHandshakeManager.java   |   18 +-
 .../recovery/RecoveryServerHandshakeManager.java   |   18 +-
 .../recovery/message/HandshakeStartMessage.java    |    4 +-
 .../message/HandshakeStartResponseMessage.java     |    4 +-
 .../network/MessageSerializationRegistryImpl.java  |   12 +-
 .../scalecube/ScaleCubeClusterServiceFactory.java  |   14 +-
 .../ScaleCubeDirectMarshallerTransport.java        |   12 +-
 .../scalecube/ScaleCubeMessagingService.java       |   28 +-
 .../network}/AllTypesMessage.java                  |    2 +-
 .../network}/AllTypesMessageGenerator.java         |    2 +-
 .../network}/NestedMessageMessage.java             |    2 +-
 .../network}/netty/InboundDecoderTest.java         |   10 +-
 .../netty/IoExceptionSuppressingHandlerTest.java   |   58 +
 .../network}/netty/NettyClientTest.java            |    6 +-
 .../network}/netty/NettyServerTest.java            |    6 +-
 .../MessageSerializationRegistryImplTest.java      |    4 +-
 .../client/service/impl/RaftGroupServiceImpl.java  |   14 +-
 .../raft/client/service/RaftGroupServiceTest.java  |   26 +-
 .../ignite/raft/jraft/core/ITCliServiceTest.java   |  451 ++--
 .../apache/ignite/raft/jraft/core/ITNodeTest.java  | 1924 +++++++--------
 .../raft/server/ITJRaftCounterServerTest.java      |  107 +-
 .../raft/server/ITSimpleCounterServerTest.java     |   38 +-
 .../java/org/apache/ignite/internal/raft/Loza.java |    5 +-
 .../internal/raft/server/impl/JRaftServerImpl.java |   19 +-
 .../internal/raft/server/impl/RaftServerImpl.java  |   32 +-
 .../apache/ignite/raft/jraft/RaftGroupService.java |   37 +-
 .../apache/ignite/raft/jraft/core/NodeImpl.java    |   11 +-
 .../ignite/raft/jraft/error/RemotingException.java |    1 -
 .../apache/ignite/raft/jraft/rpc/RpcClient.java    |   60 +-
 .../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       |   90 +-
 .../raft/jraft/rpc/impl/IgniteRpcServer.java       |  112 +-
 .../impl/core/AppendEntriesRequestProcessor.java   |    6 +-
 .../ignite/raft/jraft/util/internal/ThrowUtil.java |   60 +-
 .../apache/ignite/raft/jraft/core/TestCluster.java |  222 +-
 .../raft/jraft/rpc/AbstractClientServiceTest.java  |   66 +-
 .../ignite/raft/jraft/rpc/AbstractRpcTest.java     |  215 +-
 .../ignite/raft/jraft/rpc/IgniteRpcTest.java       |   47 +-
 .../ignite/raft/jraft/rpc/TestIgniteRpcServer.java |   56 +-
 .../snapshot/local/LocalSnapshotReaderTest.java    |    9 +-
 .../apache/ignite/raft/jraft/test/TestUtils.java   |   70 +-
 .../java/org/apache/ignite/rest/RestModule.java    |    8 +-
 .../rest/presentation/json/JsonConverter.java      |  358 ---
 .../rest/presentation/json/JsonPresentation.java   |    9 +-
 .../rest/presentation/json/JsonConverterTest.java  |  401 ---
 .../runner/app/DynamicTableCreationTest.java       |   28 +-
 .../ignite/internal/runner/app/IgnitionTest.java   |    2 -
 .../apache/ignite/internal/app/IgnitionImpl.java   |   14 +-
 .../storage/DistributedConfigurationStorage.java   |   79 +-
 .../storage/LocalConfigurationStorage.java         |   10 +-
 .../ignite/internal/schema/SchemaManager.java      |   42 +-
 .../SchemaConfigurationConverter.java              |   17 +-
 .../configuration/SchemaTableValidatorImpl.java    |    7 +-
 .../ignite/internal/schema/row/ChunkReader.java    |  213 --
 .../ignite/internal/schema/row/ChunkWriter.java    |   14 +-
 .../org/apache/ignite/internal/schema/row/Row.java |  217 +-
 .../ignite/internal/schema/row/RowAssembler.java   |    6 +-
 .../{VarTableFormat.java => RowFormatHelper.java}  |   56 +-
 .../SchemaConfigurationConverterTest.java          |    2 +-
 .../configuration/TestConfigurationStorage.java    |   10 +-
 .../ignite/distributed/ITDistributedTableTest.java |   20 +-
 .../ignite/internal/table/InternalTable.java       |    7 +
 .../apache/ignite/internal/table/TableImpl.java    |   16 +-
 .../internal/table/distributed/TableManager.java   |  287 ++-
 .../distributed/storage/InternalTableImpl.java     |   17 +-
 .../internal/table/event/TableEventParameters.java |   57 +-
 .../ignite/internal/table/TableManagerTest.java    |  231 +-
 .../internal/table/TestConfigurationStorage.java   |   10 +-
 .../table/impl/DummyInternalTableImpl.java         |    5 +
 .../apache/ignite/internal/vault/VaultManager.java |   74 +-
 .../internal/vault/common/VaultListener.java       |   43 -
 .../ignite/internal/vault/common/VaultWatch.java   |   85 -
 .../ignite/internal/vault/common/WatcherImpl.java  |  151 --
 .../internal/vault/impl/VaultServiceImpl.java      |   25 -
 .../internal/vault/service/VaultService.java       |   17 -
 .../vault/impl/VaultBaseContractsTest.java         |   99 +-
 parent/pom.xml                                     |    2 +-
 322 files changed, 23416 insertions(+), 5123 deletions(-)
 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-annotation-processor/src/integrationTest/resources/org/apache/ignite/network/processor/internal/InvalidAnnotatedTypeMessage.java => calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/ExecutionCancelledException.java} (78%)
 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
 copy modules/{vault/src/main/java/org/apache/ignite/internal/vault/common/Watcher.java => calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/QueryTaskExecutor.java} (52%)
 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/src/main/java/org/apache/ignite/network/internal/direct/state/DirectMessageStateItem.java => calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/RuntimeIndex.java} (73%)
 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/src/main/java/org/apache/ignite/network/internal/direct/state/DirectMessageStateItem.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/{network/src/main/java/org/apache/ignite/network/internal/handshake/HandshakeException.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-annotation-processor/src/integrationTest/resources/org/apache/ignite/network/processor/internal/InvalidAnnotatedTypeMessage.java => calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/exp/Scalar.java} (75%)
 copy modules/{network-annotation-processor/src/test/java/org/apache/ignite/network/processor/internal/SerializationOrderMessage.java => calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/exp/agg/Accumulator.java} (61%)
 copy modules/{network-annotation-processor/src/integrationTest/resources/org/apache/ignite/network/processor/internal/ConflictingTypeMessage.java => calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/exp/agg/AccumulatorWrapper.java} (74%)
 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/{configuration-api/src/main/java/org/apache/ignite/configuration/storage/ConfigurationType.java => calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/exp/agg/AggregateType.java} (78%)
 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
 rename modules/{vault/src/main/java/org/apache/ignite/internal/vault/common/Watcher.java => calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/Downstream.java} (56%)
 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/{configuration/src/main/java/org/apache/ignite/configuration/internal/util/KeyNotFoundException.java => calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/Mailbox.java} (66%)
 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-annotation-processor/src/test/java/org/apache/ignite/network/processor/internal/SerializationOrderMessage.java => calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/SingleNode.java} (64%)
 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/{configuration/src/main/java/org/apache/ignite/configuration/internal/notifications/ConfigurationNotificationEventImpl.java => calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/util/TransformingIterator.java} (51%)
 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
 rename modules/configuration-annotation-processor/src/integrationTest/java/org/apache/ignite/{configuration/processor/internal => internal/configuration/processor}/AbstractProcessorTest.java (98%)
 rename modules/configuration-annotation-processor/src/integrationTest/java/org/apache/ignite/{configuration/processor/internal => internal/configuration/processor}/ConfigSet.java (98%)
 rename modules/configuration-annotation-processor/src/integrationTest/java/org/apache/ignite/{configuration/processor/internal => internal/configuration/processor}/HasFieldMatcher.java (98%)
 rename modules/configuration-annotation-processor/src/integrationTest/java/org/apache/ignite/{configuration/processor/internal => internal/configuration/processor}/HasMethodMatcher.java (98%)
 rename modules/configuration-annotation-processor/src/integrationTest/java/org/apache/ignite/{configuration/processor/internal => internal/configuration/processor}/ITProcessorTest.java (92%)
 rename modules/configuration-annotation-processor/src/integrationTest/java/org/apache/ignite/{configuration/processor/internal => internal/configuration/processor}/ParsedClass.java (98%)
 rename modules/configuration-annotation-processor/src/integrationTest/resources/org/apache/ignite/{configuration/processor/internal => internal/configuration/processor}/TestConfigurationSchema.java (95%)
 rename modules/configuration-annotation-processor/src/main/java/org/apache/ignite/{configuration/processor/internal => internal/configuration/processor}/Processor.java (79%)
 rename modules/configuration-annotation-processor/src/main/java/org/apache/ignite/{configuration/processor/internal => internal/configuration/processor}/ProcessorException.java (94%)
 rename modules/configuration-annotation-processor/src/main/java/org/apache/ignite/{configuration/processor/internal => internal/configuration/processor}/Utils.java (97%)
 delete mode 100644 modules/configuration-annotation-processor/src/test/java/org/apache/ignite/configuration/sample/ConfigurationArrayTest.java
 rename modules/configuration-annotation-processor/src/test/java/org/apache/ignite/{ => internal}/configuration/ConfigurationChangerTest.java (94%)
 create mode 100644 modules/configuration-annotation-processor/src/test/java/org/apache/ignite/internal/configuration/json/JsonConverterTest.java
 rename modules/{rest/src/test/java/org/apache/ignite/rest/presentation => configuration-annotation-processor/src/test/java/org/apache/ignite/internal/configuration}/json/TestConfigurationStorage.java (81%)
 rename modules/configuration-annotation-processor/src/test/java/org/apache/ignite/{ => internal}/configuration/notifications/ConfigurationListenerTest.java (93%)
 rename modules/configuration-annotation-processor/src/test/java/org/apache/ignite/{ => internal}/configuration/sample/AutoAdjustConfigurationSchema.java (95%)
 rename modules/configuration-annotation-processor/src/test/java/org/apache/ignite/{ => internal}/configuration/sample/BaselineConfigurationSchema.java (95%)
 rename modules/configuration-annotation-processor/src/test/java/org/apache/ignite/{ => internal}/configuration/sample/CacheConfigurationSchema.java (95%)
 rename modules/configuration-annotation-processor/src/test/java/org/apache/ignite/{ => internal}/configuration/sample/ClusterWideConfigurationSchema.java (95%)
 create mode 100644 modules/configuration-annotation-processor/src/test/java/org/apache/ignite/internal/configuration/sample/ConfigurationArrayTest.java
 rename modules/configuration-annotation-processor/src/test/java/org/apache/ignite/{ => internal}/configuration/sample/ConstructableTreeNodeTest.java (94%)
 rename modules/configuration-annotation-processor/src/test/java/org/apache/ignite/{ => internal}/configuration/sample/DiscoveryConfigurationSchema.java (95%)
 rename modules/configuration-annotation-processor/src/test/java/org/apache/ignite/{ => internal}/configuration/sample/LocalConfigurationSchema.java (90%)
 rename modules/configuration-annotation-processor/src/test/java/org/apache/ignite/{ => internal}/configuration/sample/NetworkConfigurationSchema.java (90%)
 rename modules/configuration-annotation-processor/src/test/java/org/apache/ignite/{ => internal}/configuration/sample/NodeConfigurationSchema.java (95%)
 rename modules/configuration-annotation-processor/src/test/java/org/apache/ignite/{ => internal}/configuration/sample/TraversableTreeNodeTest.java (95%)
 rename modules/configuration-annotation-processor/src/test/java/org/apache/ignite/{ => internal}/configuration/sample/UsageTest.java (96%)
 rename modules/configuration-annotation-processor/src/test/java/org/apache/ignite/{ => internal}/configuration/storage/TestConfigurationStorage.java (96%)
 rename modules/configuration-annotation-processor/src/test/java/org/apache/ignite/{configuration/internal => internal/configuration}/util/ConfigurationUtilTest.java (97%)
 rename modules/configuration-annotation-processor/src/test/java/org/apache/ignite/{configuration/internal => internal/configuration}/validation/ValidationUtilTest.java (93%)
 rename modules/configuration-api/src/main/java/org/apache/ignite/configuration/{tree => }/NamedListChange.java (98%)
 rename modules/configuration-api/src/main/java/org/apache/ignite/configuration/{tree => }/NamedListView.java (96%)
 rename modules/configuration-api/src/main/java/org/apache/ignite/configuration/{storage => annotation}/ConfigurationType.java (94%)
 delete mode 100644 modules/configuration/src/main/java/org/apache/ignite/configuration/internal/rest/JsonConverter.java
 rename modules/configuration/src/main/java/org/apache/ignite/{ => internal}/configuration/ConfigurationChanger.java (93%)
 rename modules/configuration/src/main/java/org/apache/ignite/{configuration/internal => internal/configuration}/ConfigurationManager.java (92%)
 rename modules/configuration/src/main/java/org/apache/ignite/{configuration/internal => internal/configuration}/ConfigurationNode.java (94%)
 rename modules/configuration/src/main/java/org/apache/ignite/{ => internal}/configuration/ConfigurationRegistry.java (86%)
 rename modules/configuration/src/main/java/org/apache/ignite/{configuration/internal => internal/configuration}/DynamicConfiguration.java (93%)
 rename modules/configuration/src/main/java/org/apache/ignite/{configuration/internal => internal/configuration}/DynamicProperty.java (92%)
 rename modules/configuration/src/main/java/org/apache/ignite/{configuration/internal => internal/configuration}/NamedListConfiguration.java (94%)
 rename modules/configuration/src/main/java/org/apache/ignite/{configuration/internal => internal/configuration}/SuperRoot.java (94%)
 create mode 100644 modules/configuration/src/main/java/org/apache/ignite/internal/configuration/TypeUtils.java
 rename modules/configuration/src/main/java/org/apache/ignite/{configuration/internal => internal/configuration}/asm/ConfigurationAsmGenerator.java (97%)
 rename modules/configuration/src/main/java/org/apache/ignite/{configuration/internal => internal/configuration}/asm/SchemaClassesInfo.java (92%)
 rename modules/configuration/src/main/java/org/apache/ignite/{configuration/internal => internal/configuration}/asm/StringSwitchBuilder.java (99%)
 create mode 100644 modules/configuration/src/main/java/org/apache/ignite/internal/configuration/json/JsonConfigurationVisitor.java
 create mode 100644 modules/configuration/src/main/java/org/apache/ignite/internal/configuration/json/JsonConverter.java
 create mode 100644 modules/configuration/src/main/java/org/apache/ignite/internal/configuration/json/JsonObjectConfigurationSource.java
 create mode 100644 modules/configuration/src/main/java/org/apache/ignite/internal/configuration/json/JsonPrimitiveConfigurationSource.java
 rename modules/configuration/src/main/java/org/apache/ignite/{configuration/internal => internal/configuration}/notifications/ConfigurationNotificationEventImpl.java (96%)
 rename modules/configuration/src/main/java/org/apache/ignite/{ => internal}/configuration/storage/ConfigurationStorage.java (94%)
 rename modules/configuration/src/main/java/org/apache/ignite/{ => internal}/configuration/storage/ConfigurationStorageListener.java (95%)
 rename modules/configuration/src/main/java/org/apache/ignite/{ => internal}/configuration/storage/Data.java (96%)
 rename modules/configuration/src/main/java/org/apache/ignite/{ => internal}/configuration/storage/StorageException.java (95%)
 rename modules/configuration/src/main/java/org/apache/ignite/{ => internal}/configuration/tree/ConfigurationSource.java (97%)
 rename modules/configuration/src/main/java/org/apache/ignite/{ => internal}/configuration/tree/ConfigurationVisitor.java (97%)
 rename modules/configuration/src/main/java/org/apache/ignite/{ => internal}/configuration/tree/ConstructableTreeNode.java (96%)
 rename modules/configuration/src/main/java/org/apache/ignite/{ => internal}/configuration/tree/InnerNode.java (98%)
 rename modules/configuration/src/main/java/org/apache/ignite/{ => internal}/configuration/tree/NamedListNode.java (95%)
 rename modules/configuration/src/main/java/org/apache/ignite/{ => internal}/configuration/tree/TraversableTreeNode.java (95%)
 rename modules/configuration/src/main/java/org/apache/ignite/{configuration/internal => internal/configuration}/util/AnyNodeConfigurationVisitor.java (86%)
 rename modules/configuration/src/main/java/org/apache/ignite/{configuration/internal => internal/configuration}/util/ConfigurationNotificationsUtil.java (90%)
 rename modules/configuration/src/main/java/org/apache/ignite/{configuration/internal => internal/configuration}/util/ConfigurationUtil.java (97%)
 rename modules/configuration/src/main/java/org/apache/ignite/{configuration/internal => internal/configuration}/util/KeyNotFoundException.java (95%)
 rename modules/configuration/src/main/java/org/apache/ignite/{configuration/internal => internal/configuration}/util/KeysTrackingConfigurationVisitor.java (95%)
 rename modules/configuration/src/main/java/org/apache/ignite/{configuration/internal => internal/configuration}/validation/ImmutableValidator.java (96%)
 rename modules/configuration/src/main/java/org/apache/ignite/{configuration/internal => internal/configuration}/validation/MaxValidator.java (96%)
 rename modules/configuration/src/main/java/org/apache/ignite/{configuration/internal => internal/configuration}/validation/MemberKey.java (96%)
 rename modules/configuration/src/main/java/org/apache/ignite/{configuration/internal => internal/configuration}/validation/MinValidator.java (96%)
 rename modules/configuration/src/main/java/org/apache/ignite/{configuration/internal => internal/configuration}/validation/ValidationContextImpl.java (90%)
 rename modules/configuration/src/main/java/org/apache/ignite/{configuration/internal => internal/configuration}/validation/ValidationUtil.java (94%)
 create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/manager/EventListener.java
 copy modules/core/src/main/java/org/apache/ignite/internal/manager/{Event.java => ListenerRemovedException.java} (76%)
 create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/util/IgniteIntListSelfTest.java
 rename modules/network-annotation-processor/src/integrationTest/java/org/apache/ignite/{network/processor/internal => internal/network/processor}/ITTransferableObjectProcessorTest.java (98%)
 rename modules/network-annotation-processor/src/integrationTest/resources/org/apache/ignite/{network/processor/internal => internal/network/processor}/AllTypesMessage.java (96%)
 rename modules/network-annotation-processor/src/integrationTest/resources/org/apache/ignite/{network/processor/internal => internal/network/processor}/ConflictingTypeMessage.java (95%)
 rename modules/network-annotation-processor/src/integrationTest/resources/org/apache/ignite/{network/processor/internal => internal/network/processor}/ITTestMessageGroup.java (94%)
 rename modules/network-annotation-processor/src/integrationTest/resources/org/apache/ignite/{network/processor/internal => internal/network/processor}/InvalidAnnotatedTypeMessage.java (94%)
 rename modules/network-annotation-processor/src/integrationTest/resources/org/apache/ignite/{network/processor/internal => internal/network/processor}/InvalidParameterGetterMessage.java (94%)
 rename modules/network-annotation-processor/src/integrationTest/resources/org/apache/ignite/{network/processor/internal => internal/network/processor}/InvalidReturnTypeGetterMessage.java (94%)
 rename modules/network-annotation-processor/src/integrationTest/resources/org/apache/ignite/{network/processor/internal => internal/network/processor}/SecondGroup.java (94%)
 rename modules/network-annotation-processor/src/integrationTest/resources/org/apache/ignite/{network/processor/internal => internal/network/processor}/TransitiveMessage.java (95%)
 rename modules/network-annotation-processor/src/integrationTest/resources/org/apache/ignite/{network/processor/internal => internal/network/processor}/UnmarshallableTypeMessage.java (95%)
 rename modules/network-annotation-processor/src/integrationTest/resources/org/apache/ignite/{network/processor/internal => internal/network/processor}/UnmarshallableTypeNonSerializableMessage.java (95%)
 rename modules/network-annotation-processor/src/main/java/org/apache/ignite/{network/processor/internal => internal/network/processor}/MessageClass.java (98%)
 rename modules/network-annotation-processor/src/main/java/org/apache/ignite/{network/processor/internal => internal/network/processor}/MessageGroupWrapper.java (98%)
 rename modules/network-annotation-processor/src/main/java/org/apache/ignite/{network/processor/internal => internal/network/processor}/ProcessingException.java (97%)
 rename modules/network-annotation-processor/src/main/java/org/apache/ignite/{network/processor/internal => internal/network/processor}/TransferableObjectProcessor.java (95%)
 rename modules/network-annotation-processor/src/main/java/org/apache/ignite/{network/processor/internal => internal/network/processor}/TypeUtils.java (98%)
 rename modules/network-annotation-processor/src/main/java/org/apache/ignite/{network/processor/internal => internal/network/processor}/messages/MessageBuilderGenerator.java (94%)
 rename modules/network-annotation-processor/src/main/java/org/apache/ignite/{network/processor/internal => internal/network/processor}/messages/MessageFactoryGenerator.java (93%)
 rename modules/network-annotation-processor/src/main/java/org/apache/ignite/{network/processor/internal => internal/network/processor}/messages/MessageImplGenerator.java (97%)
 rename modules/network-annotation-processor/src/main/java/org/apache/ignite/{network/processor/internal => internal/network/processor}/serialization/BaseMethodNameResolver.java (96%)
 rename modules/network-annotation-processor/src/main/java/org/apache/ignite/{network/processor/internal => internal/network/processor}/serialization/MessageCollectionItemTypeConverter.java (96%)
 rename modules/network-annotation-processor/src/main/java/org/apache/ignite/{network/processor/internal => internal/network/processor}/serialization/MessageDeserializerGenerator.java (97%)
 rename modules/network-annotation-processor/src/main/java/org/apache/ignite/{network/processor/internal => internal/network/processor}/serialization/MessageReaderMethodResolver.java (98%)
 rename modules/network-annotation-processor/src/main/java/org/apache/ignite/{network/processor/internal => internal/network/processor}/serialization/MessageSerializerGenerator.java (96%)
 rename modules/network-annotation-processor/src/main/java/org/apache/ignite/{network/processor/internal => internal/network/processor}/serialization/MessageWriterMethodResolver.java (97%)
 rename modules/network-annotation-processor/src/main/java/org/apache/ignite/{network/processor/internal => internal/network/processor}/serialization/RegistryInitializerGenerator.java (95%)
 rename modules/network-annotation-processor/src/main/java/org/apache/ignite/{network/processor/internal => internal/network/processor}/serialization/SerializationFactoryGenerator.java (95%)
 rename modules/network-annotation-processor/src/test/java/org/apache/ignite/{network/processor/internal => internal/network/processor}/SerializationOrderMessage.java (95%)
 rename modules/network-annotation-processor/src/test/java/org/apache/ignite/{network/processor/internal => internal/network/processor}/SerializationOrderTest.java (98%)
 rename modules/network-annotation-processor/src/test/java/org/apache/ignite/{network/processor/internal => internal/network/processor}/TestMessageGroup.java (95%)
 rename modules/network/src/integrationTest/java/org/apache/ignite/{network/internal => internal/network}/netty/ConnectionManagerTest.java (73%)
 rename modules/network/src/integrationTest/java/org/apache/ignite/{network/internal => internal/network}/recovery/RecoveryHandshakeTest.java (92%)
 rename modules/network/src/main/java/org/apache/ignite/{ => internal}/network/NetworkMessageTypes.java (85%)
 rename modules/network/src/main/java/org/apache/ignite/{network/internal => internal/network}/direct/DirectMarshallingUtils.java (93%)
 rename modules/network/src/main/java/org/apache/ignite/{network/internal => internal/network}/direct/DirectMessageReader.java (97%)
 rename modules/network/src/main/java/org/apache/ignite/{network/internal => internal/network}/direct/DirectMessageWriter.java (97%)
 rename modules/network/src/main/java/org/apache/ignite/{network/internal => internal/network}/direct/state/DirectMessageState.java (97%)
 rename modules/network/src/main/java/org/apache/ignite/{network/internal => internal/network}/direct/state/DirectMessageStateItem.java (94%)
 rename modules/network/src/main/java/org/apache/ignite/{network/internal => internal/network}/direct/stream/DirectByteBufferStream.java (99%)
 rename modules/network/src/main/java/org/apache/ignite/{network/internal => internal/network}/direct/stream/DirectByteBufferStreamImplV1.java (99%)
 rename modules/network/src/main/java/org/apache/ignite/{network/internal => internal/network}/handshake/HandshakeAction.java (90%)
 rename modules/network/src/main/java/org/apache/ignite/{network/internal => internal/network}/handshake/HandshakeException.java (95%)
 rename modules/network/src/main/java/org/apache/ignite/{network/internal => internal/network}/handshake/HandshakeManager.java (91%)
 rename modules/network/src/main/java/org/apache/ignite/{network/scalecube => internal/network}/message/ScaleCubeMessage.java (91%)
 rename modules/network/src/main/java/org/apache/ignite/{network/internal => internal/network}/netty/ConnectionManager.java (91%)
 rename modules/network/src/main/java/org/apache/ignite/{network/internal => internal/network}/netty/HandshakeHandler.java (78%)
 rename modules/network/src/main/java/org/apache/ignite/{network/internal => internal/network}/netty/InboundDecoder.java (80%)
 copy modules/{cli/src/main/java/org/apache/ignite/cli/ui/TerminalFactory.java => network/src/main/java/org/apache/ignite/internal/network/netty/IoExceptionSuppressingHandler.java} (52%)
 rename modules/network/src/main/java/org/apache/ignite/{network/internal => internal/network}/netty/MessageHandler.java (97%)
 rename modules/network/src/main/java/org/apache/ignite/{network/internal => internal/network}/netty/NettyClient.java (97%)
 rename modules/network/src/main/java/org/apache/ignite/{network/internal => internal/network}/netty/NettySender.java (96%)
 rename modules/network/src/main/java/org/apache/ignite/{network/internal => internal/network}/netty/NettyServer.java (95%)
 rename modules/network/src/main/java/org/apache/ignite/{network/internal => internal/network}/netty/NettyUtils.java (98%)
 rename modules/network/src/main/java/org/apache/ignite/{network/internal => internal/network}/netty/OutboundEncoder.java (97%)
 rename modules/network/src/main/java/org/apache/ignite/{network/internal => internal/network}/recovery/RecoveryClientHandshakeManager.java (86%)
 rename modules/network/src/main/java/org/apache/ignite/{network/internal => internal/network}/recovery/RecoveryServerHandshakeManager.java (86%)
 rename modules/network/src/main/java/org/apache/ignite/{network/internal => internal/network}/recovery/message/HandshakeStartMessage.java (90%)
 rename modules/network/src/main/java/org/apache/ignite/{network/internal => internal/network}/recovery/message/HandshakeStartResponseMessage.java (91%)
 rename modules/network/src/test/java/org/apache/ignite/{network/internal => internal/network}/AllTypesMessage.java (97%)
 rename modules/network/src/test/java/org/apache/ignite/{network/internal => internal/network}/AllTypesMessageGenerator.java (99%)
 rename modules/network/src/test/java/org/apache/ignite/{network/internal => internal/network}/NestedMessageMessage.java (96%)
 rename modules/network/src/test/java/org/apache/ignite/{network/internal => internal/network}/netty/InboundDecoderTest.java (96%)
 create mode 100644 modules/network/src/test/java/org/apache/ignite/internal/network/netty/IoExceptionSuppressingHandlerTest.java
 rename modules/network/src/test/java/org/apache/ignite/{network/internal => internal/network}/netty/NettyClientTest.java (97%)
 rename modules/network/src/test/java/org/apache/ignite/{network/internal => internal/network}/netty/NettyServerTest.java (98%)
 delete mode 100644 modules/rest/src/main/java/org/apache/ignite/rest/presentation/json/JsonConverter.java
 delete mode 100644 modules/rest/src/test/java/org/apache/ignite/rest/presentation/json/JsonConverterTest.java
 delete mode 100644 modules/schema/src/main/java/org/apache/ignite/internal/schema/row/ChunkReader.java
 rename modules/schema/src/main/java/org/apache/ignite/internal/schema/row/{VarTableFormat.java => RowFormatHelper.java} (84%)
 delete mode 100644 modules/vault/src/main/java/org/apache/ignite/internal/vault/common/VaultListener.java
 delete mode 100644 modules/vault/src/main/java/org/apache/ignite/internal/vault/common/VaultWatch.java
 delete mode 100644 modules/vault/src/main/java/org/apache/ignite/internal/vault/common/WatcherImpl.java