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/11/03 15:00:51 UTC
[ignite-3] branch ignite-15212 updated (6fef4c3 -> 754aab8)
This is an automated email from the ASF dual-hosted git repository.
amashenkov pushed a change to branch ignite-15212
in repository https://gitbox.apache.org/repos/asf/ignite-3.git.
discard 6fef4c3 Add meta to SqlRow
discard 8d43c01 Drop TxSession.
discard 0a7efa3 IGNITE-15600 Cache for Calcite SQL plans in 3.0 (#403)
discard da1e280 IGNITE-15599 Get rid Guava in Calcite module (#398)
discard dc30df6 IGNITE-15402 Partition drop in storage & table folder deletion. (#402)
discard 0744f75 IGNITE-15601 Implement stop for calcite module in 3.0 (#395)
discard 4d06262 IGNITE-13667: Add schema columns mapping from user order to system order (#401)
discard e336c7c Update modules/api/src/main/java/org/apache/ignite/query/sql/ColumnMetadata.java
discard 389e6a5 Merge branch 'main' into ignite-15212
discard f0a39da Merge branch 'main' into ignite-15212
add 46c7169 Drop TxSession.
add e6533fe Add meta to SqlRow
add 0fc9fe9 IGNITE-13667: Add schema columns mapping from user order to system order (#401)
add c947f30 IGNITE-15601 Implement stop for calcite module in 3.0 (#395)
add 723bdcc IGNITE-15402 Partition drop in storage & table folder deletion. (#402)
add 03e9467 IGNITE-15599 Get rid Guava in Calcite module (#398)
add 4760f67 IGNITE-15600 Cache for Calcite SQL plans in 3.0 (#403)
add 47f7693 IGNITE-15775 Provide documentation for Alpha 3 release (#404)
add a4920be IGNITE-15799 Fix WorkDirectoryExtension for test classes with no tests (#407)
add c2b8000 IGNITE-15819 Prepare DEB package for Ignite 3.0 (#413)
add ec8292a IGNITE-15692 Implement TableManager component stop. Fixes #399
add 0c4ec19 IGNITE-15536 Use VarHandle to replace UNSAFE in IgniteSpinReadWriteLock (#414)
add c086555 IGNITE-15744 Fix vartable size overflow issue (#409)
add 4792963 IGNITE-15669 Get rid of leakage of Calcite classes through SqlCursor class (#410)
add 445f455 IGNITE-14645 Support polymorphic configuration nodes. (#366)
add 7050546 IGNITE-15477 Network module readme. Netty thread naming improvement. (#406)
add 0996363 IGNITE-15842 Fixed RocksDbStorageTest#testSnapshot fail on Windows platform. Fixes #417
add 8948b40 IGNITE-15699 Rename TableSchemaBuilder. (#421)
add 8e79100 IGNITE-14291: Implement KeyValueView API (#416)
add 808173f IGNITE-15754: Fix marshaller exception handling (#408)
add 97c5197 IGNITE-15414 Schema validation refactoring with configuration validators (#360)
add 2b400c0 IGNITE-15371 Switch to Google code style. Fixes #377
add a323c22 IGNITE-15462 Replace usages of map of int to IntMap where possible in Calcite module. (#411)
add 08283aa Merge branch 'main' into ignite-15212
add 754aab8 Merge branch 'master1' into ignite-15212
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (6fef4c3)
\
N -- N -- N refs/heads/ignite-15212 (754aab8)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
check-rules/checkstyle-rules.xml | 453 ++-
deliveries/{rpm => deb}/build.sh | 23 +-
deliveries/deb/changelog | 5 +
deliveries/deb/control | 14 +
deliveries/deb/copyright | 11 +
deliveries/deb/rules | 36 +
deliveries/rpm/apache-ignite.spec | 9 +-
deliveries/rpm/build.sh | 4 +-
docs/_data/toc.yaml | 10 +
docs/_docs/binary-protocol.adoc | 26 +
docs/_docs/ignite-cli-tool.adoc | 5 +-
.../includes/ignite-cli-download-windows.adoc | 2 +-
docs/_docs/index.adoc | 24 +-
docs/_docs/installation/installing-using-exe.adoc | 5 +
...-cli-download-windows.adoc => persistence.adoc} | 13 +-
docs/_docs/quick-start/getting-started-guide.adoc | 48 +-
docs/_docs/rebalance.adoc | 30 +
docs/_docs/sql/calcite-based-sql-engine.adoc | 237 ++
docs/_docs/sql/jdbc-driver.adoc | 78 +
.../ignite/example/rebalance/RebalanceExample.java | 106 +-
.../ignite/example/sql/jdbc/SqlJdbcExample.java | 84 +-
.../ignite/example/table/KeyValueViewExample.java | 52 +-
.../ignite/example/table/RecordViewExample.java | 52 +-
.../apache/ignite/example/ExampleTestUtils.java | 21 +-
.../ignite/example/sql/jdbc/SqlExamplesTest.java | 33 +-
.../ignite/example/table/TableExamplesTest.java | 25 +-
idea/intellij-java-google-style.xml | 617 ++++
.../ignite/internal/affinity/AffinityUtils.java | 18 +-
.../affinity/RendezvousAffinityFunction.java | 128 +-
.../internal/affinity/AffinityServiceTest.java | 42 +-
.../affinity/RendezvousAffinityFunctionTest.java | 86 +-
.../src/main/java/org/apache/ignite/Ignite.java | 31 +-
.../src/main/java/org/apache/ignite/Ignition.java | 19 +-
.../java/org/apache/ignite/IgnitionManager.java | 54 +-
.../org/apache/ignite/binary/package-info.java | 1 +
.../schemas/clientconnector/package-info.java | 1 +
.../network/ScaleCubeConfigurationSchema.java | 7 +-
.../schemas/network/package-info.java | 1 +
.../configuration/schemas/rest/package-info.java | 1 +
.../configuration/schemas/runner/package-info.java | 1 +
.../schemas/table/ColumnConfigurationSchema.java | 3 +
.../table/ColumnTypeConfigurationSchema.java | 9 +
...ableValidator.java => ColumnTypeValidator.java} | 12 +-
.../schemas/table/TableConfigurationSchema.java | 4 +-
.../schemas/table/TableValidator.java | 10 +-
.../configuration/schemas/table/package-info.java | 1 +
.../org/apache/ignite/lang/IgniteException.java | 8 +-
.../ignite/lang/TableAlreadyExistsException.java | 3 +-
.../java/org/apache/ignite/lang/package-info.java | 1 +
.../main/java/org/apache/ignite/package-info.java | 1 +
.../apache/ignite/query/sql/ColumnMetadata.java | 8 +-
.../org/apache/ignite/query/sql/IgniteSql.java | 2 +-
.../apache/ignite/query/sql/MultiResultSet.java | 3 +-
.../org/apache/ignite/query/sql/ResultSet.java | 11 +-
.../apache/ignite/query/sql/ResultSetMetadata.java | 8 +-
.../org/apache/ignite/query/sql/SQLException.java | 12 +-
.../java/org/apache/ignite/query/sql/Session.java | 28 +-
.../java/org/apache/ignite/query/sql/SqlRow.java | 3 +-
.../org/apache/ignite/query/sql/Statement.java | 20 +-
.../query/sql/async/AsyncMultiResultSet.java | 13 +-
.../ignite/query/sql/async/AsyncResultSet.java | 12 +-
.../ignite/query/sql/async/AsyncSession.java | 11 +-
.../query/sql/reactive/ReactiveResultSet.java | 10 +-
.../ignite/query/sql/reactive/ReactiveSession.java | 10 +-
.../ignite/schema/definition/ColumnType.java | 183 +-
.../schema/definition/SchemaManagementMode.java | 12 +-
.../ignite/schema/definition/TableDefinition.java | 3 +-
.../builder/ColumnDefinitionBuilder.java | 6 +-
.../builder/HashIndexDefinitionBuilder.java | 6 +-
.../builder/PartialIndexDefinitionBuilder.java | 21 +-
.../builder/PrimaryKeyDefinitionBuilder.java | 3 +-
.../builder/SortedIndexDefinitionBuilder.java | 6 +-
...emaBuilder.java => TableDefinitionBuilder.java} | 25 +-
.../definition/index/HashIndexDefinition.java | 3 +-
.../schema/definition/index/IndexDefinition.java | 9 +-
.../definition/index/PartialIndexDefinition.java | 3 +-
.../definition/index/SortedIndexDefinition.java | 9 +-
.../schema/definition/index/package-info.java | 1 +
.../ignite/schema/definition/package-info.java | 1 +
.../schema/modification/AlterColumnBuilder.java | 9 +-
.../modification/TableModificationBuilder.java | 8 +-
.../ignite/schema/modification/package-info.java | 1 +
.../apache/ignite/table/IgniteTableStatistics.java | 25 +-
.../org/apache/ignite/table/InvocationContext.java | 30 +-
.../org/apache/ignite/table/InvokeProcessor.java | 18 +-
.../java/org/apache/ignite/table/KeyValueView.java | 159 +-
.../java/org/apache/ignite/table/RecordView.java | 151 +-
.../main/java/org/apache/ignite/table/Table.java | 62 +-
.../main/java/org/apache/ignite/table/Tuple.java | 96 +-
.../java/org/apache/ignite/table/TupleImpl.java | 154 +-
.../apache/ignite/table/manager/IgniteTables.java | 80 +-
.../apache/ignite/table/manager/package-info.java | 1 +
.../table/mapper/{ValueMapper.java => Mapper.java} | 43 +-
.../org/apache/ignite/table/mapper/Mappers.java | 12 +-
.../apache/ignite/table/mapper/RecordMapper.java | 61 -
.../apache/ignite/table/mapper/package-info.java | 1 +
.../java/org/apache/ignite/table/package-info.java | 1 +
.../org/apache/ignite/tx/IgniteTransactions.java | 4 +-
.../java/org/apache/ignite/tx/Transaction.java | 12 +-
.../java/org/apache/ignite/tx/package-info.java | 1 +
.../ignite/internal/baseline/BaselineManager.java | 25 +-
.../facebook/presto/bytecode/ClassGenerator.java | 15 +-
.../apache/calcite/plan/volcano/package-info.java | 1 +
.../query/calcite/ResultFieldMetadata.java} | 46 +-
.../calcite/{Stubs.java => ResultSetMetadata.java} | 17 +-
.../processors/query/calcite/SqlCursor.java | 5 +-
.../query/calcite/SqlQueryProcessor.java | 157 +-
.../internal/processors/query/calcite/Stubs.java | 5 +-
.../query/calcite/exec/AbstractIndexScan.java | 85 +-
.../query/calcite/exec/ArrayRowHandler.java | 39 +-
.../calcite/exec/ClosableIteratorsHolder.java | 105 +-
.../query/calcite/exec/ExchangeService.java | 39 +-
.../query/calcite/exec/ExchangeServiceImpl.java | 234 +-
.../calcite/exec/ExecutionCancelledException.java | 4 +-
.../query/calcite/exec/ExecutionContext.java | 136 +-
.../query/calcite/exec/ExecutionService.java | 3 +-
.../query/calcite/exec/ExecutionServiceImpl.java | 1011 ++++---
.../query/calcite/exec/LogicalRelImplementor.java | 459 +--
.../query/calcite/exec/MailboxRegistry.java | 23 +-
.../query/calcite/exec/MailboxRegistryImpl.java | 121 +-
.../query/calcite/exec/PlannerHelper.java | 99 +-
.../query/calcite/exec/QueryTaskExecutor.java | 11 +-
.../query/calcite/exec/QueryTaskExecutorImpl.java | 97 +-
.../processors/query/calcite/exec/RowHandler.java | 87 +-
.../query/calcite/exec/RuntimeHashIndex.java | 66 +-
.../query/calcite/exec/RuntimeIndex.java | 8 +-
.../query/calcite/exec/RuntimeTreeIndex.java | 132 +-
.../query/calcite/exec/TableFunctionScan.java | 29 +-
.../processors/query/calcite/exec/TreeIndex.java | 1 +
.../query/calcite/exec/exp/CallImplementor.java | 11 +-
.../query/calcite/exec/exp/ConverterUtils.java | 369 +--
.../query/calcite/exec/exp/ExpressionFactory.java | 48 +-
.../calcite/exec/exp/ExpressionFactoryImpl.java | 431 ++-
.../calcite/exec/exp/IgniteBuiltInMethod.java | 18 +-
.../query/calcite/exec/exp/IgniteSqlFunctions.java | 70 +-
.../calcite/exec/exp/ImplementableFunction.java | 1 +
.../query/calcite/exec/exp/NotNullImplementor.java | 12 +-
.../exec/exp/ReflectiveCallNotNullImplementor.java | 35 +-
.../query/calcite/exec/exp/RexImpTable.java | 1596 ++++++----
.../query/calcite/exec/exp/RexToLixTranslator.java | 904 +++---
.../processors/query/calcite/exec/exp/Scalar.java | 8 +-
.../query/calcite/exec/exp/agg/Accumulator.java | 25 +-
.../calcite/exec/exp/agg/AccumulatorWrapper.java | 24 +-
.../query/calcite/exec/exp/agg/Accumulators.java | 824 +++--
.../calcite/exec/exp/agg/AccumulatorsFactory.java | 247 +-
.../query/calcite/exec/exp/agg/GroupKey.java | 70 +-
.../query/calcite/exec/rel/AbstractNode.java | 160 +-
.../query/calcite/exec/rel/AbstractSetOpNode.java | 234 +-
.../exec/rel/CorrelatedNestedLoopJoinNode.java | 235 +-
.../query/calcite/exec/rel/Downstream.java | 4 +-
.../query/calcite/exec/rel/FilterNode.java | 73 +-
.../query/calcite/exec/rel/HashAggregateNode.java | 241 +-
.../processors/query/calcite/exec/rel/Inbox.java | 364 ++-
.../query/calcite/exec/rel/IndexSpoolNode.java | 148 +-
.../query/calcite/exec/rel/IntersectNode.java | 60 +-
.../query/calcite/exec/rel/LimitNode.java | 50 +-
.../processors/query/calcite/exec/rel/Mailbox.java | 4 +-
.../query/calcite/exec/rel/MergeJoinNode.java | 608 ++--
.../query/calcite/exec/rel/MinusNode.java | 52 +-
.../query/calcite/exec/rel/ModifyNode.java | 132 +-
.../query/calcite/exec/rel/NestedLoopJoinNode.java | 492 +--
.../processors/query/calcite/exec/rel/Node.java | 13 +-
.../processors/query/calcite/exec/rel/Outbox.java | 226 +-
.../query/calcite/exec/rel/ProjectNode.java | 33 +-
.../query/calcite/exec/rel/RootNode.java | 169 +-
.../query/calcite/exec/rel/ScanNode.java | 56 +-
.../query/calcite/exec/rel/SingleNode.java | 19 +-
.../query/calcite/exec/rel/SortAggregateNode.java | 227 +-
.../query/calcite/exec/rel/SortNode.java | 57 +-
.../query/calcite/exec/rel/TableScanNode.java | 160 +-
.../query/calcite/exec/rel/TableSpoolNode.java | 67 +-
.../query/calcite/exec/rel/UnionAllNode.java | 41 +-
.../query/calcite/externalize/RelInputEx.java | 5 +-
.../query/calcite/externalize/RelJson.java | 1060 ++++---
.../query/calcite/externalize/RelJsonReader.java | 280 +-
.../query/calcite/externalize/RelJsonWriter.java | 90 +-
.../query/calcite/message/ErrorMessage.java | 1 -
.../message/ExecutionContextAwareMessage.java | 1 -
.../query/calcite/message/InboxCloseMessage.java | 1 -
.../query/calcite/message/MessageListener.java | 2 +-
.../query/calcite/message/MessageService.java | 4 +-
.../query/calcite/message/MessageServiceImpl.java | 92 +-
.../query/calcite/message/OutboxCloseMessage.java | 1 -
.../query/calcite/message/QueryBatchMessage.java | 1 -
.../query/calcite/message/QueryStartResponse.java | 1 -
.../calcite/message/SqlQueryMessageGroup.java | 4 +-
.../query/calcite/metadata/ColocationGroup.java | 121 +-
.../calcite/metadata/FragmentDescription.java | 56 +-
.../query/calcite/metadata/FragmentMapping.java | 103 +-
.../calcite/metadata/FragmentMappingException.java | 13 +-
.../query/calcite/metadata/IgniteMdCollation.java | 329 +-
.../calcite/metadata/IgniteMdCumulativeCost.java | 57 +-
.../calcite/metadata/IgniteMdDistinctRowCount.java | 22 +-
.../calcite/metadata/IgniteMdDistribution.java | 17 +-
.../calcite/metadata/IgniteMdFragmentMapping.java | 90 +-
.../metadata/IgniteMdNonCumulativeCost.java | 21 +-
.../metadata/IgniteMdPercentageOriginalRows.java | 35 +-
.../query/calcite/metadata/IgniteMdPredicates.java | 15 +-
.../query/calcite/metadata/IgniteMdRowCount.java | 101 +-
.../calcite/metadata/IgniteMdSelectivity.java | 80 +-
.../query/calcite/metadata/IgniteMetadata.java | 43 +-
.../query/calcite/metadata/MappingService.java | 9 +-
.../query/calcite/metadata/MappingServiceImpl.java | 23 +-
.../calcite/metadata/NodeMappingException.java | 9 +-
.../query/calcite/metadata/RelMetadataQueryEx.java | 38 +-
.../query/calcite/metadata/RemoteException.java | 18 +-
.../query/calcite/metadata/cost/IgniteCost.java | 168 +-
.../calcite/metadata/cost/IgniteCostFactory.java | 34 +-
.../calcite/prepare/AbstractMultiStepPlan.java | 115 +-
.../processors/query/calcite/prepare/CacheKey.java | 38 +-
.../processors/query/calcite/prepare/Cloner.java | 127 +-
.../processors/query/calcite/prepare/DdlPlan.java | 22 +-
.../query/calcite/prepare/ExplainPlan.java | 12 +-
.../query/calcite/prepare/FieldsMetadata.java | 1 -
.../query/calcite/prepare/FieldsMetadataImpl.java | 23 +-
.../processors/query/calcite/prepare/Fragment.java | 120 +-
.../query/calcite/prepare/FragmentPlan.java | 22 +-
.../query/calcite/prepare/FragmentSplitter.java | 61 +-
.../query/calcite/prepare/IdGenerator.java | 19 +-
.../query/calcite/prepare/IgnitePlanner.java | 205 +-
.../query/calcite/prepare/IgnitePrograms.java | 23 +-
.../query/calcite/prepare/IgniteRelShuttle.java | 95 +-
.../query/calcite/prepare/IgniteSqlValidator.java | 182 +-
.../query/calcite/prepare/MultiStepDmlPlan.java | 8 +-
.../query/calcite/prepare/MultiStepPlan.java | 15 +-
.../query/calcite/prepare/MultiStepQueryPlan.java | 8 +-
.../query/calcite/prepare/PlannerHelper.java | 106 +-
.../query/calcite/prepare/PlannerPhase.java | 240 +-
.../query/calcite/prepare/PlanningContext.java | 163 +-
.../query/calcite/prepare/QueryPlan.java | 4 +-
.../query/calcite/prepare/QueryPlanCache.java | 5 +-
.../query/calcite/prepare/QueryPlanCacheImpl.java | 25 +-
.../query/calcite/prepare/QueryTemplate.java | 83 +-
.../calcite/prepare/ResultFieldMetadataImpl.java | 86 +
.../calcite/prepare/ResultSetMetadataImpl.java | 79 +
...etadata.java => ResultSetMetadataInternal.java} | 14 +-
.../processors/query/calcite/prepare/Splitter.java | 56 +-
.../query/calcite/prepare/ValidationResult.java | 18 +-
.../calcite/prepare/ddl/ColumnDefinition.java | 14 +-
.../calcite/prepare/ddl/CreateTableCommand.java | 75 +-
.../query/calcite/prepare/ddl/DdlCommand.java | 1 +
.../prepare/ddl/DdlSqlToCommandConverter.java | 249 +-
.../query/calcite/rel/AbstractIgniteJoin.java | 135 +-
.../query/calcite/rel/AbstractIgniteSpool.java | 21 +-
.../query/calcite/rel/AbstractIndexScan.java | 44 +-
.../query/calcite/rel/IgniteAggregate.java | 64 +-
.../query/calcite/rel/IgniteConvention.java | 14 +-
.../rel/IgniteCorrelatedNestedLoopJoin.java | 167 +-
.../query/calcite/rel/IgniteExchange.java | 43 +-
.../processors/query/calcite/rel/IgniteFilter.java | 111 +-
.../query/calcite/rel/IgniteHashIndexSpool.java | 73 +-
.../query/calcite/rel/IgniteIndexScan.java | 132 +-
.../processors/query/calcite/rel/IgniteLimit.java | 125 +-
.../query/calcite/rel/IgniteMergeJoin.java | 289 +-
.../query/calcite/rel/IgniteNestedLoopJoin.java | 91 +-
.../query/calcite/rel/IgniteProject.java | 190 +-
.../query/calcite/rel/IgniteReceiver.java | 106 +-
.../processors/query/calcite/rel/IgniteRel.java | 11 +-
.../query/calcite/rel/IgniteRelVisitor.java | 1 +
.../processors/query/calcite/rel/IgniteSender.java | 94 +-
.../processors/query/calcite/rel/IgniteSort.java | 95 +-
.../query/calcite/rel/IgniteSortedIndexSpool.java | 85 +-
.../query/calcite/rel/IgniteTableFunctionScan.java | 43 +-
.../query/calcite/rel/IgniteTableModify.java | 79 +-
.../query/calcite/rel/IgniteTableScan.java | 120 +-
.../query/calcite/rel/IgniteTableSpool.java | 42 +-
.../query/calcite/rel/IgniteTrimExchange.java | 65 +-
.../query/calcite/rel/IgniteUnionAll.java | 120 +-
.../processors/query/calcite/rel/IgniteValues.java | 25 +-
.../rel/ProjectableFilterableTableScan.java | 95 +-
.../query/calcite/rel/SourceAwareIgniteRel.java | 8 +-
.../calcite/rel/agg/IgniteHashAggregateBase.java | 11 +-
.../calcite/rel/agg/IgniteMapAggregateBase.java | 49 +-
.../calcite/rel/agg/IgniteMapHashAggregate.java | 47 +-
.../calcite/rel/agg/IgniteMapSortAggregate.java | 73 +-
.../calcite/rel/agg/IgniteReduceAggregateBase.java | 125 +-
.../calcite/rel/agg/IgniteReduceHashAggregate.java | 67 +-
.../calcite/rel/agg/IgniteReduceSortAggregate.java | 80 +-
.../calcite/rel/agg/IgniteSingleAggregateBase.java | 47 +-
.../calcite/rel/agg/IgniteSingleHashAggregate.java | 21 +-
.../calcite/rel/agg/IgniteSingleSortAggregate.java | 37 +-
.../calcite/rel/agg/IgniteSortAggregateBase.java | 24 +-
.../rel/logical/IgniteLogicalIndexScan.java | 89 +-
.../rel/logical/IgniteLogicalTableScan.java | 42 +-
.../query/calcite/rel/set/IgniteIntersect.java | 17 +-
.../query/calcite/rel/set/IgniteMapIntersect.java | 32 +-
.../query/calcite/rel/set/IgniteMapMinus.java | 32 +-
.../query/calcite/rel/set/IgniteMapSetOp.java | 79 +-
.../query/calcite/rel/set/IgniteMinus.java | 17 +-
.../query/calcite/rel/set/IgniteMinusBase.java | 59 +-
.../calcite/rel/set/IgniteReduceIntersect.java | 62 +-
.../query/calcite/rel/set/IgniteReduceMinus.java | 62 +-
.../query/calcite/rel/set/IgniteReduceSetOp.java | 49 +-
.../query/calcite/rel/set/IgniteSetOp.java | 38 +-
.../calcite/rel/set/IgniteSingleIntersect.java | 26 +-
.../query/calcite/rel/set/IgniteSingleMinus.java | 26 +-
.../query/calcite/rel/set/IgniteSingleSetOp.java | 77 +-
.../calcite/rule/AbstractIgniteConverterRule.java | 21 +-
.../calcite/rule/CorrelateToNestedLoopRule.java | 77 +-
.../calcite/rule/CorrelatedNestedLoopJoinRule.java | 99 +-
.../query/calcite/rule/FilterConverterRule.java | 14 +-
.../rule/FilterSpoolMergeToHashIndexSpoolRule.java | 73 +-
.../FilterSpoolMergeToSortedIndexSpoolRule.java | 96 +-
.../calcite/rule/HashAggregateConverterRule.java | 82 +-
.../calcite/rule/LogicalScanConverterRule.java | 79 +-
.../query/calcite/rule/MergeJoinConverterRule.java | 20 +-
.../query/calcite/rule/MinusConverterRule.java | 44 +-
.../calcite/rule/NestedLoopJoinConverterRule.java | 7 +-
.../query/calcite/rule/ProjectConverterRule.java | 11 +-
.../query/calcite/rule/SetOpConverterRule.java | 119 +-
.../calcite/rule/SortAggregateConverterRule.java | 106 +-
.../query/calcite/rule/SortConverterRule.java | 23 +-
.../rule/TableFunctionScanConverterRule.java | 22 +-
.../calcite/rule/TableModifyConverterRule.java | 13 +-
.../query/calcite/rule/UnionConverterRule.java | 31 +-
.../query/calcite/rule/ValuesConverterRule.java | 15 +-
.../calcite/rule/logical/ExposeIndexRule.java | 28 +-
.../calcite/rule/logical/FilterScanMergeRule.java | 112 +-
.../calcite/rule/logical/LogicalOrToUnionRule.java | 79 +-
.../calcite/rule/logical/ProjectScanMergeRule.java | 161 +-
.../query/calcite/schema/ColumnDescriptor.java | 33 +-
.../query/calcite/schema/ColumnDescriptorImpl.java | 53 +-
.../query/calcite/schema/IgniteIndex.java | 32 +-
.../query/calcite/schema/IgniteSchema.java | 12 +-
.../query/calcite/schema/IgniteTable.java | 16 +-
.../query/calcite/schema/IgniteTableImpl.java | 138 +-
.../query/calcite/schema/SchemaHolderImpl.java | 90 +-
.../query/calcite/schema/TableDescriptor.java | 43 +-
.../query/calcite/schema/TableDescriptorImpl.java | 147 +-
.../query/calcite/sql/IgniteSqlConformance.java | 4 +-
.../query/calcite/sql/IgniteSqlCreateTable.java | 31 +-
.../calcite/sql/IgniteSqlCreateTableOption.java | 69 +-
.../sql/IgniteSqlCreateTableOptionEnum.java | 1 +
.../calcite/sql/fun/IgniteSqlOperatorTable.java | 15 +-
.../calcite/sql/fun/SqlSystemRangeFunction.java | 25 +-
.../query/calcite/trait/AffinityAdapter.java | 33 +-
.../processors/query/calcite/trait/AllNodes.java | 20 +-
.../query/calcite/trait/CorrelationTrait.java | 113 +-
.../query/calcite/trait/CorrelationTraitDef.java | 23 +-
.../query/calcite/trait/Destination.java | 4 +-
.../query/calcite/trait/DistributionFunction.java | 220 +-
.../query/calcite/trait/DistributionTrait.java | 176 +-
.../query/calcite/trait/DistributionTraitDef.java | 19 +-
.../query/calcite/trait/IgniteDistribution.java | 14 +-
.../query/calcite/trait/IgniteDistributions.java | 31 +-
.../query/calcite/trait/Partitioned.java | 32 +-
.../processors/query/calcite/trait/RandomNode.java | 24 +-
.../processors/query/calcite/trait/RelFactory.java | 7 +-
.../query/calcite/trait/RewindabilityTrait.java | 67 +-
.../query/calcite/trait/RewindabilityTraitDef.java | 23 +-
.../processors/query/calcite/trait/TraitUtils.java | 591 ++--
.../query/calcite/trait/TraitsAwareIgniteRel.java | 40 +-
.../query/calcite/type/IgniteTypeFactory.java | 40 +-
.../query/calcite/type/IgniteTypeSystem.java | 11 +-
.../processors/query/calcite/util/Commons.java | 559 ++--
.../query/calcite/util/FilteringIterator.java | 27 +-
.../processors/query/calcite/util/HintUtils.java | 48 +-
.../query/calcite/util/IgniteMethod.java | 17 +-
.../query/calcite/util/IgniteResource.java | 23 +-
.../query/calcite/util/IndexConditions.java | 72 +-
.../query/calcite/util/NodeLeaveHandler.java | 8 +-
.../processors/query/calcite/util/Primitives.java | 156 +-
.../processors/query/calcite/util/RexUtils.java | 614 ++--
.../query/calcite/util/TransformingIterator.java | 17 +-
.../processors/query/calcite/util/TypeUtils.java | 333 +-
.../query/calcite/StopCalciteModuleTest.java | 134 +-
.../query/calcite/exec/RuntimeTreeIndexTest.java | 117 +-
.../calcite/exec/rel/AbstractExecutionTest.java | 226 +-
.../exec/rel/AbstractSetOpExecutionTest.java | 76 +-
.../query/calcite/exec/rel/BaseAggregateTest.java | 636 ++--
.../query/calcite/exec/rel/ExecutionTest.java | 623 ++--
.../exec/rel/HashAggregateExecutionTest.java | 127 +-
.../rel/HashAggregateSingleGroupExecutionTest.java | 527 ++--
.../exec/rel/HashIndexSpoolExecutionTest.java | 99 +-
.../calcite/exec/rel/IntersectExecutionTest.java | 56 +-
.../calcite/exec/rel/MergeJoinExecutionTest.java | 421 +--
.../query/calcite/exec/rel/MinusExecutionTest.java | 56 +-
.../exec/rel/NestedLoopJoinExecutionTest.java | 410 +--
.../exec/rel/SortAggregateExecutionTest.java | 141 +-
.../calcite/exec/rel/TableSpoolExecutionTest.java | 44 +-
.../exec/rel/TreeIndexSpoolExecutionTest.java | 157 +-
.../planner/AbstractAggregatePlannerTest.java | 40 +-
.../query/calcite/planner/AbstractPlannerTest.java | 877 +++---
.../planner/AggregateDistinctPlannerTest.java | 78 +-
.../calcite/planner/AggregatePlannerTest.java | 187 +-
.../CorrelatedNestedLoopJoinPlannerTest.java | 158 +-
.../calcite/planner/HashAggregatePlannerTest.java | 55 +-
.../calcite/planner/HashIndexSpoolPlannerTest.java | 212 +-
.../calcite/planner/JoinColocationPlannerTest.java | 110 +-
.../query/calcite/planner/PlannerTest.java | 2167 ++++++-------
.../query/calcite/planner/SetOpPlannerTest.java | 331 +-
.../calcite/planner/SortAggregatePlannerTest.java | 90 +-
.../planner/SortedIndexSpoolPlannerTest.java | 193 +-
.../query/calcite/planner/TableDmlPlannerTest.java | 24 +-
.../calcite/planner/TableFunctionPlannerTest.java | 30 +-
.../calcite/planner/TableSpoolPlannerTest.java | 86 +-
.../query/calcite/sql/SqlDdlParserTest.java | 246 +-
.../apache/ignite/cli/common/IgniteCommand.java | 8 +-
.../org/apache/ignite/cli/common/package-info.java | 4 +-
...igCommandTest.java => ItConfigCommandTest.java} | 84 +-
.../apache/ignite/cli/CliPathsConfigLoader.java | 51 +-
.../java/org/apache/ignite/cli/CliVersionInfo.java | 6 +-
.../java/org/apache/ignite/cli/CommandFactory.java | 5 +-
.../java/org/apache/ignite/cli/ErrorHandler.java | 31 +-
.../org/apache/ignite/cli/HelpFactoryImpl.java | 64 +-
.../java/org/apache/ignite/cli/IgniteCliApp.java | 19 +-
...teCLIException.java => IgniteCliException.java} | 8 +-
.../java/org/apache/ignite/cli/IgnitePaths.java | 49 +-
.../org/apache/ignite/cli/InteractiveWrapper.java | 19 +-
.../src/main/java/org/apache/ignite/cli/Table.java | 63 +-
.../org/apache/ignite/cli/VersionProvider.java | 7 +-
.../ignite/cli/builtins/SystemPathResolver.java | 18 +-
.../cli/builtins/config/ConfigurationClient.java | 92 +-
.../cli/builtins/config/HttpClientFactory.java | 8 +-
.../ignite/cli/builtins/config/package-info.java | 1 +
.../cli/builtins/init/InitIgniteCommand.java | 83 +-
.../ignite/cli/builtins/init/package-info.java | 1 +
.../cli/builtins/module/MavenArtifactResolver.java | 124 +-
.../cli/builtins/module/MavenCoordinates.java | 18 +-
.../ignite/cli/builtins/module/ModuleManager.java | 181 +-
.../ignite/cli/builtins/module/ModuleRegistry.java | 68 +-
.../builtins/module/StandardModuleDefinition.java | 14 +-
.../ignite/cli/builtins/module/package-info.java | 1 +
.../ignite/cli/builtins/node/NodeManager.java | 187 +-
.../ignite/cli/builtins/node/package-info.java | 1 +
.../apache/ignite/cli/builtins/package-info.java | 1 +
.../java/org/apache/ignite/cli/package-info.java | 1 +
.../org/apache/ignite/cli/spec/CategorySpec.java | 7 +-
.../apache/ignite/cli/spec/ConfigCommandSpec.java | 74 +-
.../org/apache/ignite/cli/spec/IgniteCliSpec.java | 88 +-
.../ignite/cli/spec/InitIgniteCommandSpec.java | 7 +-
.../apache/ignite/cli/spec/ModuleCommandSpec.java | 95 +-
.../apache/ignite/cli/spec/NodeCommandSpec.java | 69 +-
.../org/apache/ignite/cli/spec/SpecAdapter.java | 34 +-
.../org/apache/ignite/cli/spec/package-info.java | 1 +
.../java/org/apache/ignite/cli/ui/ProgressBar.java | 20 +-
.../java/org/apache/ignite/cli/ui/Spinner.java | 8 +-
.../org/apache/ignite/cli/ui/TerminalFactory.java | 7 +-
.../org/apache/ignite/cli/AbstractCliTest.java | 4 +-
.../apache/ignite/cli/IgniteCliInterfaceTest.java | 472 +--
.../cli/builtins/init/InitIgniteCommandTest.java | 65 +-
.../ignite/cli/builtins/init/package-info.java | 1 +
.../cli/builtins/module/ModuleMangerTest.java | 105 +-
.../ignite/cli/builtins/module/package-info.java | 1 +
.../java/org/apache/ignite/cli/package-info.java | 1 +
.../org/apache/ignite/cli/ui/ProgressBarTest.java | 48 +-
.../java/org/apache/ignite/cli/ui/SpinnerTest.java | 12 +-
.../org/apache/ignite/cli/ui/package-info.java | 1 +
.../client/proto/query/IgniteQueryErrorCode.java | 4 +-
.../proto/query/event/BatchExecuteRequest.java | 14 +-
.../proto/query/event/BatchExecuteResult.java | 17 +-
.../proto/query/event/ClientMessageUtils.java | 10 +-
.../client/proto/query/event/JdbcColumnMeta.java | 268 +-
.../proto/query/event/JdbcMetaColumnsRequest.java | 13 +-
.../proto/query/event/JdbcMetaColumnsResult.java | 21 +-
.../query/event/JdbcMetaPrimaryKeysRequest.java | 11 +-
.../query/event/JdbcMetaPrimaryKeysResult.java | 15 +-
.../proto/query/event/JdbcMetaSchemasRequest.java | 9 +-
.../proto/query/event/JdbcMetaSchemasResult.java | 21 +-
.../proto/query/event/JdbcMetaTablesRequest.java | 22 +-
.../proto/query/event/JdbcMetaTablesResult.java | 18 +-
.../proto/query/event/JdbcPrimaryKeyMeta.java | 41 +-
.../query/event/JdbcQueryMetadataRequest.java | 9 +-
.../client/proto/query/event/JdbcTableMeta.java | 38 +-
.../ignite/client/proto/query/event/Query.java | 11 +-
.../proto/query/event/QueryCloseRequest.java | 9 +-
.../client/proto/query/event/QueryCloseResult.java | 5 +-
.../proto/query/event/QueryExecuteRequest.java | 17 +-
.../proto/query/event/QueryExecuteResult.java | 20 +-
.../proto/query/event/QueryFetchRequest.java | 9 +-
.../client/proto/query/event/QueryFetchResult.java | 25 +-
.../proto/query/event/QuerySingleResult.java | 29 +-
.../ignite/client/proto/query/event/Response.java | 19 +-
.../client/proto/ClientMessageDecoder.java | 35 +-
.../internal/client/proto/ClientMessagePacker.java | 299 +-
.../client/proto/ClientMessageUnpacker.java | 187 +-
.../internal/client/proto/ProtocolVersion.java | 30 +-
.../ignite/internal/client/proto/package-info.java | 1 +
.../client/proto/ClientMessageDecoderTest.java | 15 +-
.../proto/ClientMessagePackerUnpackerTest.java | 192 +-
...ntHandlerTest.java => ItClientHandlerTest.java} | 115 +-
.../ignite/client/handler/ClientContext.java | 8 +-
.../ignite/client/handler/ClientHandlerModule.java | 56 +-
.../handler/ClientInboundMessageHandler.java | 53 +-
.../client/handler/JdbcQueryEventHandlerImpl.java | 273 +-
.../apache/ignite/client/handler/package-info.java | 1 +
.../requests/sql/ClientSqlCloseRequest.java | 10 +-
.../sql/ClientSqlColumnMetadataRequest.java | 10 +-
.../requests/sql/ClientSqlExecuteBatchRequest.java | 10 +-
.../requests/sql/ClientSqlExecuteRequest.java | 4 +-
.../requests/sql/ClientSqlFetchRequest.java | 10 +-
.../sql/ClientSqlPrimaryKeyMetadataRequest.java | 10 +-
.../sql/ClientSqlQueryMetadataRequest.java | 10 +-
.../sql/ClientSqlSchemasMetadataRequest.java | 10 +-
.../sql/ClientSqlTableMetadataRequest.java | 10 +-
.../handler/requests/sql/JdbcMetadataCatalog.java | 242 +-
.../client/handler/requests/sql/package-info.java | 1 +
.../requests/table/ClientSchemasGetRequest.java | 16 +-
.../handler/requests/table/ClientTableCommon.java | 356 +--
.../requests/table/ClientTableDropRequest.java | 2 +-
.../requests/table/ClientTableGetRequest.java | 9 +-
.../requests/table/ClientTablesGetRequest.java | 2 +-
.../table/ClientTupleContainsKeyRequest.java | 10 +-
.../table/ClientTupleDeleteAllExactRequest.java | 12 +-
.../table/ClientTupleDeleteAllRequest.java | 12 +-
.../table/ClientTupleDeleteExactRequest.java | 10 +-
.../requests/table/ClientTupleDeleteRequest.java | 10 +-
.../requests/table/ClientTupleGetAllRequest.java | 12 +-
.../table/ClientTupleGetAndDeleteRequest.java | 12 +-
.../table/ClientTupleGetAndReplaceRequest.java | 12 +-
.../ClientTupleGetAndReplaceSchemalessRequest.java | 12 +-
.../table/ClientTupleGetAndUpsertRequest.java | 12 +-
.../ClientTupleGetAndUpsertSchemalessRequest.java | 12 +-
.../requests/table/ClientTupleGetRequest.java | 12 +-
.../table/ClientTupleInsertAllRequest.java | 12 +-
.../ClientTupleInsertAllSchemalessRequest.java | 12 +-
.../requests/table/ClientTupleInsertRequest.java | 10 +-
.../table/ClientTupleInsertSchemalessRequest.java | 10 +-
.../table/ClientTupleReplaceExactRequest.java | 12 +-
.../ClientTupleReplaceExactSchemalessRequest.java | 10 +-
.../requests/table/ClientTupleReplaceRequest.java | 10 +-
.../table/ClientTupleReplaceSchemalessRequest.java | 10 +-
.../table/ClientTupleUpsertAllRequest.java | 8 +-
.../ClientTupleUpsertAllSchemalessRequest.java | 8 +-
.../requests/table/ClientTupleUpsertRequest.java | 8 +-
.../table/ClientTupleUpsertSchemalessRequest.java | 8 +-
.../handler/requests/table/package-info.java | 1 +
.../org/apache/ignite/client/IgniteClient.java | 40 +-
.../ignite/client/IgniteClientAddressFinder.java | 10 +-
.../IgniteClientAuthenticationException.java | 2 +-
.../client/IgniteClientAuthorizationException.java | 2 +-
.../ignite/client/IgniteClientConfiguration.java | 6 +-
.../client/IgniteClientConnectionException.java | 2 +-
.../ignite/client/IgniteClientException.java | 8 +-
...ClientFeatureNotSupportedByServerException.java | 2 +-
.../org/apache/ignite/client/package-info.java | 1 +
.../ignite/internal/client/ClientChannel.java | 9 +-
.../client/ClientChannelConfiguration.java | 2 +-
.../ignite/internal/client/HostAndPortRange.java | 84 +-
.../client/IgniteClientConfigurationImpl.java | 27 +-
.../internal/client/PayloadInputChannel.java | 3 +-
.../internal/client/PayloadOutputChannel.java | 5 +-
.../internal/client/ProtocolBitmaskFeature.java | 13 +-
.../ignite/internal/client/ProtocolContext.java | 6 +-
.../ignite/internal/client/ReliableChannel.java | 186 +-
.../ignite/internal/client/TcpClientChannel.java | 93 +-
.../ignite/internal/client/TcpIgniteClient.java | 118 +-
.../internal/client/io/ClientConnection.java | 3 +-
.../client/io/ClientConnectionMultiplexer.java | 7 +-
.../internal/client/io/ClientMessageHandler.java | 2 +-
.../client/io/netty/NettyClientConnection.java | 16 +-
.../io/netty/NettyClientConnectionMultiplexer.java | 26 +-
.../client/io/netty/NettyClientMessageHandler.java | 12 +-
.../client/query/JdbcClientQueryEventHandler.java | 29 +-
.../ignite/internal/client/table/ClientColumn.java | 9 +-
.../client/table/ClientKeyValueBinaryView.java | 132 +-
.../client/table/ClientRecordBinaryView.java | 222 +-
.../ignite/internal/client/table/ClientSchema.java | 9 +-
.../ignite/internal/client/table/ClientTable.java | 307 +-
.../ignite/internal/client/table/ClientTables.java | 43 +-
.../ignite/internal/client/table/ClientTuple.java | 147 +-
.../ignite/internal/jdbc/ConnectionProperties.java | 4 +-
.../internal/jdbc/ConnectionPropertiesImpl.java | 356 ++-
.../ignite/internal/jdbc/JdbcConnection.java | 375 ++-
.../ignite/internal/jdbc/JdbcDatabaseMetadata.java | 1769 ++++++-----
.../internal/jdbc/JdbcPreparedStatement.java | 390 ++-
.../apache/ignite/internal/jdbc/JdbcResultSet.java | 1329 ++++----
.../internal/jdbc/JdbcResultSetMetadata.java | 130 +-
.../apache/ignite/internal/jdbc/JdbcStatement.java | 468 +--
.../apache/ignite/internal/jdbc/package-info.java | 1 +
.../org/apache/ignite/jdbc/IgniteJdbcDriver.java | 39 +-
.../java/org/apache/ignite/jdbc/package-info.java | 1 +
.../apache/ignite/client/AbstractClientTest.java | 79 +-
.../client/ClientKeyValueBinaryViewTest.java | 14 +-
.../org/apache/ignite/client/ClientTableTest.java | 20 +-
.../org/apache/ignite/client/ClientTablesTest.java | 9 +-
.../org/apache/ignite/client/ClientTupleTest.java | 142 +-
.../apache/ignite/client/ConfigurationTest.java | 14 +-
.../org/apache/ignite/client/ConnectionTest.java | 8 +-
.../java/org/apache/ignite/client/CustomTuple.java | 155 +-
.../org/apache/ignite/client/ReconnectTest.java | 9 +-
.../org/apache/ignite/client/fakes/FakeCursor.java | 40 +-
.../org/apache/ignite/client/fakes/FakeIgnite.java | 60 +-
.../client/fakes/FakeIgniteQueryProcessor.java | 9 +-
.../ignite/client/fakes/FakeIgniteTables.java | 147 +-
.../ignite/client/fakes/FakeInternalTable.java | 214 +-
.../ignite/client/fakes/FakeSchemaRegistry.java | 21 +-
.../internal/client/HostAndPortRangeTest.java | 20 +-
.../processor/AbstractProcessorTest.java | 46 +-
.../configuration/processor/ConfigSet.java | 12 +-
.../configuration/processor/HasFieldMatcher.java | 39 +-
.../configuration/processor/HasMethodMatcher.java | 38 +-
.../configuration/processor/ITProcessorTest.java | 161 -
.../configuration/processor/ItProcessorTest.java | 264 ++
.../configuration/processor/ParsedClass.java | 29 +-
.../ErrorInternal1ConfigurationSchema.java | 3 +-
.../ErrorInternal2ConfigurationSchema.java | 3 +-
.../ErrorPolymorphic0ConfigurationSchema.java} | 12 +-
.../ErrorPolymorphic1ConfigurationSchema.java} | 12 +-
.../ErrorPolymorphic2ConfigurationSchema.java} | 10 +-
.../ErrorPolymorphic3ConfigurationSchema.java} | 16 +-
.../ErrorPolymorphic4ConfigurationSchema.java} | 22 +-
.../ErrorPolymorphic5ConfigurationSchema.java} | 14 +-
.../ErrorPolymorphic6ConfigurationSchema.java} | 25 +-
.../ErrorPolymorphic7ConfigurationSchema.java} | 25 +-
.../ErrorPolymorphic8ConfigurationSchema.java} | 31 +-
...orPolymorphicInstance0ConfigurationSchema.java} | 12 +-
...orPolymorphicInstance1ConfigurationSchema.java} | 12 +-
...orPolymorphicInstance2ConfigurationSchema.java} | 10 +-
...orPolymorphicInstance3ConfigurationSchema.java} | 21 +-
...orPolymorphicInstance4ConfigurationSchema.java} | 25 +-
...orPolymorphicInstance5ConfigurationSchema.java} | 29 +-
...orPolymorphicInstance6ConfigurationSchema.java} | 25 +-
.../polymorphic/SimpleConfigurationSchema.java} | 22 +-
.../SimplePolymorphicConfigurationSchema.java} | 21 +-
...plePolymorphicInstanceConfigurationSchema.java} | 21 +-
.../SimpleRootConfigurationSchema.java} | 26 +-
.../configuration/processor/Processor.java | 962 ++++--
.../processor/ProcessorException.java | 1 +
.../internal/configuration/processor/Utils.java | 45 +-
.../configuration/processor/UtilsTest.java} | 39 +-
.../ConfigurationChangeException.java | 3 +-
.../configuration/ConfigurationProperty.java | 10 +-
...on.java => ConfigurationReadOnlyException.java} | 17 +-
.../ignite/configuration/ConfigurationTree.java | 8 +-
.../ignite/configuration/ConfigurationValue.java | 10 +-
...figurationWrongPolymorphicTypeIdException.java} | 17 +-
.../configuration/DirectConfigurationProperty.java | 28 +-
.../configuration/NamedConfigurationTree.java | 23 +-
.../ignite/configuration/NamedListChange.java | 18 +-
.../apache/ignite/configuration/NamedListView.java | 8 +-
.../{package-info.java => PolymorphicChange.java} | 11 +-
.../org/apache/ignite/configuration/RootKey.java | 9 +-
.../ignite/configuration/annotation/Config.java | 12 +-
.../configuration/annotation/ConfigValue.java | 8 +-
.../annotation/ConfigurationRoot.java | 10 +-
.../configuration/annotation/DirectAccess.java | 20 +-
.../annotation/InternalConfiguration.java | 19 +-
.../configuration/annotation/NamedConfigValue.java | 13 +-
...nfigurationRoot.java => PolymorphicConfig.java} | 30 +-
...ionRoot.java => PolymorphicConfigInstance.java} | 27 +-
.../{ConfigValue.java => PolymorphicId.java} | 28 +-
.../ignite/configuration/annotation/Value.java | 19 +-
.../configuration/annotation/package-info.java | 1 +
.../notifications/ConfigurationListener.java | 6 +-
.../ConfigurationNamedListListener.java | 36 +-
.../ConfigurationNotificationEvent.java | 27 +-
.../configuration/notifications/package-info.java | 1 +
.../apache/ignite/configuration/package-info.java | 1 +
.../configuration/validation/ExceptKeys.java | 8 +-
.../ignite/configuration/validation/Immutable.java | 6 +-
.../ignite/configuration/validation/Max.java | 6 +-
.../ignite/configuration/validation/Min.java | 6 +-
.../ignite/configuration/validation/OneOf.java | 12 +-
.../validation/ValidationContext.java | 14 +-
.../configuration/validation/ValidationIssue.java | 4 +-
.../ignite/configuration/validation/Validator.java | 12 +-
.../configuration/validation/package-info.java | 1 +
.../configuration/ConfigurationChanger.java | 394 ++-
.../configuration/ConfigurationManager.java | 63 +-
.../internal/configuration/ConfigurationNode.java | 86 +-
.../configuration/ConfigurationRegistry.java | 313 +-
.../configuration/ConfigurationTreeWrapper.java | 68 +
.../DirectConfigurationTreeWrapper.java | 47 +
.../configuration/DirectDynamicConfiguration.java | 30 +-
.../configuration/DirectDynamicProperty.java | 36 +-
.../DirectNamedListConfiguration.java | 38 +-
.../configuration/DynamicConfiguration.java | 194 +-
.../configuration/DynamicConfigurationChanger.java | 8 +-
.../internal/configuration/DynamicProperty.java | 85 +-
.../configuration/NamedListConfiguration.java | 127 +-
.../internal/configuration/RootInnerNode.java | 2 +-
.../ignite/internal/configuration/SuperRoot.java | 58 +-
.../ignite/internal/configuration/TypeUtils.java | 44 +-
.../asm/ConfigurationAsmGenerator.java | 3189 ++++++++++++++------
.../configuration/asm/SchemaClassesInfo.java | 4 +-
.../configuration/asm/StringSwitchBuilder.java | 93 +-
.../configuration/hocon/HoconConverter.java | 13 +-
.../hocon/HoconListConfigurationSource.java | 59 +-
.../hocon/HoconObjectConfigurationSource.java | 88 +-
.../hocon/HoconPrimitiveConfigurationSource.java | 94 +-
.../storage/ConfigurationStorage.java | 15 +-
.../storage/ConfigurationStorageListener.java | 1 +
.../internal/configuration/storage/Data.java | 6 +-
.../configuration/storage/StorageException.java | 1 +
.../configuration/tree/ConfigurationSource.java | 32 +-
.../configuration/tree/ConfigurationVisitor.java | 4 +-
.../configuration/tree/ConstructableTreeNode.java | 4 +-
.../configuration/tree/ConverterToMapVisitor.java | 33 +-
.../internal/configuration/tree/InnerNode.java | 73 +-
.../internal/configuration/tree/NamedListNode.java | 422 ++-
.../internal/configuration/tree/OrderedMap.java | 48 +-
.../configuration/tree/TraversableTreeNode.java | 8 +-
.../util/AnyNodeConfigurationVisitor.java | 11 +-
.../configuration/util/ConfigurationContainer.java | 15 +-
.../configuration/util/ConfigurationFlattener.java | 166 +-
.../util/ConfigurationNotificationEventImpl.java | 41 +-
.../util/ConfigurationNotificationsUtil.java | 743 ++---
.../configuration/util/ConfigurationUtil.java | 978 +++---
.../configuration/util/KeyNotFoundException.java | 4 +-
.../util/KeysTrackingConfigurationVisitor.java | 97 +-
...n.java => WrongPolymorphicTypeIdException.java} | 18 +-
.../validation/ExceptKeysValidator.java | 6 +-
.../validation/ImmutableValidator.java | 7 +-
.../configuration/validation/MaxValidator.java | 5 +-
.../configuration/validation/MemberKey.java | 20 +-
.../configuration/validation/MinValidator.java | 5 +-
.../configuration/validation/OneOfValidator.java | 10 +-
.../validation/ValidationContextImpl.java | 72 +-
.../configuration/validation/ValidationUtil.java | 103 +-
.../configuration/ConfigurationChangerTest.java | 477 +--
.../configuration/ConfigurationRegistryTest.java | 195 +-
.../configuration/DirectPropertiesTest.java | 183 +-
.../configuration/TestConfigurationChanger.java | 58 +-
.../asm/ConfigurationAsmGeneratorTest.java | 584 +++-
.../configuration/hocon/HoconConverterTest.java | 640 ++--
.../ConfigurationAnyListenerTest.java | 727 ++---
.../notifications/ConfigurationListenerTest.java | 750 ++---
.../ConfigurationListenerTestUtils.java | 85 +-
.../internal/configuration/sample/UsageTest.java | 130 +-
.../storage/TestConfigurationStorage.java | 46 +-
.../testframework/BasicConfigurationSchema.java | 4 +-
.../testframework/ConfigurationExtension.java | 187 +-
.../testframework/ConfigurationExtensionTest.java | 74 +-
.../testframework/ExtendedConfigurationSchema.java | 4 +-
.../testframework/InjectConfiguration.java | 22 +-
.../configuration/tree/ConfigurationArrayTest.java | 144 +-
.../tree/ConstructableTreeNodeTest.java | 96 +-
.../configuration/tree/NamedListNodeTest.java | 395 +--
.../configuration/tree/OrderedMapTest.java | 6 +-
.../tree/TraversableTreeNodeTest.java | 165 +-
.../configuration/util/ConfigurationUtilTest.java | 1037 ++++---
.../validation/OneOfValidatorTest.java | 34 +-
.../validation/ValidationUtilTest.java | 75 +-
modules/core/pom.xml | 293 ++
.../org/apache/ignite/internal/manager/Event.java | 1 +
.../ignite/internal/manager/EventListener.java | 12 +-
.../ignite/internal/manager/EventParameters.java | 4 +-
.../ignite/internal/manager/IgniteComponent.java | 13 +-
.../internal/manager/ListenerRemovedException.java | 2 +
.../apache/ignite/internal/manager/Producer.java | 48 +-
.../ignite/internal/thread/IgniteThread.java | 23 +-
.../ignite/internal/thread/NamedThreadFactory.java | 26 +-
.../internal/thread/StripedThreadPoolExecutor.java | 161 +-
.../internal/tostring/CircularStringBuilder.java | 71 +-
.../ignite/internal/tostring/ClassDescriptor.java | 15 +-
.../ignite/internal/tostring/FieldDescriptor.java | 87 +-
.../internal/tostring/IgniteToStringBuilder.java | 2079 ++++++-------
.../internal/tostring/IgniteToStringExclude.java | 5 +-
.../internal/tostring/IgniteToStringInclude.java | 12 +-
.../internal/tostring/IgniteToStringOrder.java | 7 +-
.../org/apache/ignite/internal/tostring/S.java | 4 +-
.../tostring/SensitiveDataLoggingPolicy.java | 2 +-
...Length.java => StringBuilderLimitedLength.java} | 110 +-
.../apache/ignite/internal/util/ArrayFactory.java | 4 +-
.../apache/ignite/internal/util/ArrayUtils.java | 188 +-
.../org/apache/ignite/internal/util/ByteUtils.java | 27 +-
.../apache/ignite/internal/util/Cancellable.java | 7 +-
.../ignite/internal/util/CollectionUtils.java | 264 +-
.../ignite/internal/util/FeatureChecker.java | 28 +-
.../apache/ignite/internal/util/GridUnsafe.java | 1506 ++++-----
.../ignite/internal/util/IgniteIntIterator.java | 8 +-
.../apache/ignite/internal/util/IgniteIntList.java | 231 +-
.../ignite/internal/util/IgniteSpinBusyLock.java | 27 +-
.../internal/util/IgniteSpinReadWriteLock.java | 403 +--
.../apache/ignite/internal/util/IgniteUtils.java | 427 +--
.../java/org/apache/ignite/lang/ByteArray.java | 30 +-
.../java/org/apache/ignite/lang/IgniteBiTuple.java | 117 +-
.../lang/IgniteInternalCheckedException.java | 12 +-
.../ignite/lang/IgniteInternalException.java | 8 +-
.../java/org/apache/ignite/lang/IgniteLogger.java | 101 +-
.../apache/ignite/lang/IgniteStringBuilder.java | 127 +-
.../apache/ignite/lang/IgniteSystemProperties.java | 144 +-
.../java/org/apache/ignite/lang/IgniteUuid.java | 45 +-
.../apache/ignite/lang/JavaLoggerFormatter.java | 39 +-
.../apache/ignite/lang/LoggerMessageHelper.java | 187 +-
.../apache/ignite/lang/NodeStoppingException.java | 9 +-
.../java/org/apache/ignite/lang/package-info.java | 1 +
.../extensions/communication/package-info.java | 1 +
.../internal/testframework/IgniteAbstractTest.java | 30 +-
.../internal/testframework/IgniteTestUtils.java | 113 +-
.../testframework/SystemPropertiesExtension.java | 45 +-
.../testframework/SystemPropertiesList.java | 4 +-
.../internal/testframework/WithSystemProperty.java | 18 +-
.../internal/testframework/WorkDirectory.java | 4 +-
.../testframework/WorkDirectoryExtension.java | 126 +-
.../testframework/WorkDirectoryExtensionTest.java | 167 +-
.../matchers/CompletableFutureMatcher.java | 23 +-
.../tostring/CircularStringBuilderSelfTest.java | 43 +-
.../tostring/IgniteToStringBuilderSelfTest.java | 452 +--
.../tostring/SensitiveDataToStringTest.java | 80 +-
.../ignite/internal/util/CollectionUtilsTest.java | 85 +-
.../internal/util/IgniteIntListSelfTest.java | 61 +-
.../internal/util/IgniteSpinReadWriteLockTest.java | 422 +++
.../ignite/internal/util/IgniteUtilsTest.java | 14 +-
.../org/apache/ignite/lang/LoggerHelperTest.java | 105 +-
...va => ItMetaStorageServicePersistenceTest.java} | 87 +-
...viceTest.java => ItMetaStorageServiceTest.java} | 404 +--
.../metastorage/client/CompactedException.java | 6 +-
.../internal/metastorage/client/Condition.java | 70 +-
.../internal/metastorage/client/Conditions.java | 4 +-
.../internal/metastorage/client/CursorImpl.java | 63 +-
.../internal/metastorage/client/EntryEvent.java | 23 +-
.../internal/metastorage/client/EntryImpl.java | 54 +-
.../metastorage/client/MetaStorageService.java | 112 +-
.../metastorage/client/MetaStorageServiceImpl.java | 269 +-
.../internal/metastorage/client/Operation.java | 23 +-
.../client/OperationTimeoutException.java | 5 +-
.../internal/metastorage/client/Operations.java | 6 +-
.../internal/metastorage/client/WatchEvent.java | 4 +-
.../internal/metastorage/client/WatchListener.java | 7 +-
.../internal/metastorage/client/package-info.java | 1 +
.../metastorage/common/command/ConditionInfo.java | 6 +-
.../metastorage/common/command/GetAllCommand.java | 15 +-
.../common/command/GetAndPutAllCommand.java | 10 +-
.../common/command/GetAndPutCommand.java | 10 +-
.../common/command/GetAndRemoveAllCommand.java | 9 +-
.../common/command/GetAndRemoveCommand.java | 7 +-
.../metastorage/common/command/GetCommand.java | 8 +-
.../metastorage/common/command/InvokeCommand.java | 2 +-
.../metastorage/common/command/OperationInfo.java | 4 +-
.../metastorage/common/command/PutAllCommand.java | 3 +-
.../metastorage/common/command/PutCommand.java | 10 +-
.../metastorage/common/command/RangeCommand.java | 54 +-
.../common/command/RemoveAllCommand.java | 6 +-
.../metastorage/common/command/RemoveCommand.java | 3 +-
.../common/command/SingleEntryResponse.java | 12 +-
.../common/command/WatchExactKeysCommand.java | 29 +-
.../common/command/WatchRangeKeysCommand.java | 44 +-
.../common/command/cursor/CursorCloseCommand.java | 3 +-
.../command/cursor/CursorHasNextCommand.java | 3 +-
.../common/command/cursor/CursorNextCommand.java | 3 +-
.../common/command/cursor/CursorsCloseCommand.java | 7 +-
.../internal/metastorage/common/package-info.java | 1 +
.../metastorage/server/AbstractCondition.java | 3 +-
.../metastorage/server/CompactedException.java | 6 +-
.../internal/metastorage/server/Condition.java | 4 +-
.../ignite/internal/metastorage/server/Entry.java | 64 +-
.../metastorage/server/ExistenceCondition.java | 14 +-
.../metastorage/server/KeyValueStorage.java | 39 +-
.../internal/metastorage/server/Operation.java | 27 +-
.../metastorage/server/RevisionCondition.java | 25 +-
.../metastorage/server/TombstoneCondition.java | 6 +-
.../ignite/internal/metastorage/server/Value.java | 2 +-
.../metastorage/server/ValueCondition.java | 13 +-
.../internal/metastorage/server/WatchEvent.java | 4 +-
.../server/persistence/RangeCursor.java | 52 +-
...lueStorage.java => RocksDbKeyValueStorage.java} | 826 ++---
.../server/persistence/RocksStorageUtils.java | 34 +-
.../server/persistence/WatchCursor.java | 80 +-
.../server/raft/MetaStorageListener.java | 203 +-
.../server/AbstractKeyValueStorageTest.java | 661 ++--
.../metastorage/server/ExistenceConditionTest.java | 8 +-
.../metastorage/server/RevisionConditionTest.java | 8 +-
.../server/RocksDbKeyValueStorageTest.java | 11 +-
.../server/SimpleInMemoryKeyValueStorage.java | 315 +-
.../server/SimpleInMemoryKeyValueStorageTest.java | 3 +-
.../metastorage/server/TombstoneConditionTest.java | 8 +-
.../metastorage/server/ValueConditionTest.java | 10 +-
.../internal/metastorage/MetaStorageManager.java | 556 ++--
.../metastorage/watch/AggregatedWatch.java | 7 +-
.../internal/metastorage/watch/KeyCriterion.java | 152 +-
.../metastorage/watch/WatchAggregator.java | 61 +-
.../internal/metastorage/WatchAggregatorTest.java | 80 +-
...java => ItTransferableObjectProcessorTest.java} | 64 +-
.../network/processor/InheritedMessageClash.java | 1 -
.../internal/network/processor/MessageClass.java | 51 +-
.../network/processor/MessageGroupWrapper.java | 5 +-
.../network/processor/ProcessingException.java | 8 +-
.../processor/TransferableObjectProcessor.java | 76 +-
.../internal/network/processor/TypeUtils.java | 30 +-
.../messages/MessageBuilderGenerator.java | 70 +-
.../messages/MessageFactoryGenerator.java | 32 +-
.../processor/messages/MessageImplGenerator.java | 238 +-
.../serialization/BaseMethodNameResolver.java | 43 +-
.../MessageCollectionItemTypeConverter.java | 23 +-
.../MessageDeserializerGenerator.java | 128 +-
.../serialization/MessageReaderMethodResolver.java | 67 +-
.../serialization/MessageSerializerGenerator.java | 88 +-
.../serialization/MessageWriterMethodResolver.java | 77 +-
.../RegistryInitializerGenerator.java | 42 +-
.../SerializationFactoryGenerator.java | 84 +-
.../ignite/network/AbstractClusterService.java | 24 +-
.../ignite/network/AbstractMessagingService.java | 16 +-
.../ignite/network/AbstractTopologyService.java | 3 +-
.../ignite/network/ClusterLocalConfiguration.java | 5 +-
.../org/apache/ignite/network/ClusterNode.java | 22 +-
.../org/apache/ignite/network/ClusterService.java | 7 +-
.../ignite/network/ClusterServiceFactory.java | 7 +-
.../apache/ignite/network/MessagingService.java | 40 +-
.../org/apache/ignite/network/NetworkAddress.java | 20 +-
.../network/NetworkConfigurationException.java | 2 +-
.../org/apache/ignite/network/NetworkMessage.java | 15 +-
.../ignite/network/NetworkMessageHandler.java | 6 +-
.../ignite/network/TopologyEventHandler.java | 5 +-
.../org/apache/ignite/network/TopologyService.java | 3 +-
.../ignite/network/annotations/MessageGroup.java | 31 +-
.../ignite/network/annotations/Transferable.java | 16 +-
.../ignite/network/annotations/package-info.java | 1 +
.../org/apache/ignite/network/package-info.java | 1 +
.../serialization/MessageMappingException.java | 2 +-
.../network/serialization/MessageReader.java | 23 +-
.../serialization/MessageSerializationFactory.java | 3 +-
.../MessageSerializationRegistry.java | 28 +-
.../network/serialization/MessageSerializer.java | 2 +-
.../network/serialization/MessageWriter.java | 78 +-
.../ignite/network/serialization/package-info.java | 1 +
.../apache/ignite/network/NetworkAddressTest.java | 6 +-
modules/network/README.md | 48 +
modules/network/docs/network-flow.png | Bin 0 -> 67254 bytes
modules/network/docs/network-flow.puml | 72 +
modules/network/docs/threading-2.png | Bin 0 -> 45474 bytes
modules/network/docs/threading-2.puml | 43 +
modules/network/docs/threading.png | Bin 0 -> 32334 bytes
modules/network/docs/threading.puml | 39 +
...nagerTest.java => ItConnectionManagerTest.java} | 56 +-
...shakeTest.java => ItRecoveryHandshakeTest.java} | 158 +-
...deRestartsTest.java => ItNodeRestartsTest.java} | 42 +-
...t.java => ItScaleCubeNetworkMessagingTest.java} | 168 +-
.../TestScaleCubeClusterServiceFactory.java | 16 +-
.../ignite/network/scalecube/package-info.java | 1 +
.../ignite/utils/ClusterServiceTestUtils.java | 113 +-
.../network/direct/DirectMarshallingUtils.java | 5 +-
.../network/direct/DirectMessageReader.java | 123 +-
.../network/direct/DirectMessageWriter.java | 129 +-
.../network/direct/state/DirectMessageState.java | 10 +-
.../direct/stream/DirectByteBufferStream.java | 44 +-
.../stream/DirectByteBufferStreamImplV1.java | 917 +++---
.../network/handshake/HandshakeException.java | 2 +-
.../network/handshake/HandshakeManager.java | 2 +-
.../internal/network/message/ScaleCubeMessage.java | 6 +-
.../internal/network/netty/ConnectionManager.java | 197 +-
.../internal/network/netty/HandshakeHandler.java | 22 +-
.../internal/network/netty/InboundDecoder.java | 32 +-
.../netty/IoExceptionSuppressingHandler.java | 7 +-
.../internal/network/netty/MessageHandler.java | 9 +-
.../network/netty/NamedNioEventLoopGroup.java | 58 +
.../ignite/internal/network/netty/NettyClient.java | 101 +-
.../ignite/internal/network/netty/NettySender.java | 6 +-
.../ignite/internal/network/netty/NettyServer.java | 364 +--
.../ignite/internal/network/netty/NettyUtils.java | 31 +-
.../internal/network/netty/OutboundEncoder.java | 35 +-
.../recovery/RecoveryClientHandshakeManager.java | 41 +-
.../recovery/RecoveryServerHandshakeManager.java | 35 +-
.../network/MessageSerializationRegistryImpl.java | 20 +-
.../apache/ignite/network/NodeFinderFactory.java | 13 +-
.../org/apache/ignite/network/package-info.java | 1 +
.../scalecube/DelegatingTransportFactory.java | 44 +-
.../scalecube/ScaleCubeClusterServiceFactory.java | 108 +-
.../ScaleCubeDirectMarshallerTransport.java | 93 +-
.../scalecube/ScaleCubeMessagingService.java | 112 +-
.../scalecube/ScaleCubeTopologyService.java | 35 +-
.../ignite/network/scalecube/package-info.java | 1 +
.../ignite/internal/network/AllTypesMessage.java | 48 +-
.../internal/network/AllTypesMessageGenerator.java | 117 +-
.../internal/network/AllTypesMessageTest.java | 10 +-
.../internal/network/netty/InboundDecoderTest.java | 64 +-
.../netty/IoExceptionSuppressingHandlerTest.java | 16 +-
.../internal/network/netty/NettyClientTest.java | 67 +-
.../internal/network/netty/NettyServerTest.java | 217 +-
.../internal/network/processor/EmptyMessage.java | 4 +-
.../network/processor/EmptyMessageTest.java | 14 +-
.../network/processor/InheritedMessage.java | 24 +-
.../network/processor/InheritedMessageTest.java | 43 +-
.../network/processor/NetworkMessage1.java} | 16 +-
.../network/processor/NetworkMessage2.java} | 13 +-
.../processor/SerializationOrderMessage.java | 24 +-
.../network/processor/SerializationOrderTest.java | 55 +-
.../network/AbstractMessagingServiceTest.java | 31 +-
.../MessageSerializationRegistryImplTest.java | 59 +-
.../apache/ignite/network/TestMessageTypes.java | 12 +-
.../java/org/apache/ignite/raft/client/Peer.java | 22 +-
.../ignite/raft/client/service/CommandClosure.java | 3 +-
.../raft/client/service/RaftGroupListener.java | 23 +-
.../raft/client/service/RaftGroupService.java | 131 +-
.../raft/{ITLozaTest.java => ItLozaTest.java} | 94 +-
...st.java => ItAbstractListenerSnapshotTest.java} | 126 +-
...ITCliServiceTest.java => ItCliServiceTest.java} | 4 +-
.../core/{ITNodeTest.java => ItNodeTest.java} | 6 +-
.../apache/ignite/raft/server/CounterListener.java | 21 +-
.../ignite/raft/server/CounterSnapshotFile.java | 5 +-
...rverTest.java => ItJraftCounterServerTest.java} | 164 +-
...verTest.java => ItSimpleCounterServerTest.java} | 48 +-
.../ignite/raft/server/RaftServerAbstractTest.java | 27 +-
.../java/org/apache/ignite/internal/raft/Loza.java | 191 +-
.../ignite/internal/raft/server/RaftServer.java | 14 +-
.../{JRaftServerImpl.java => JraftServerImpl.java} | 184 +-
.../jraft/rpc/impl/ActionRequestProcessor.java | 10 +-
.../org/apache/ignite/raft/jraft/util/Utils.java | 52 +-
.../ignite/disruptor/StripedDisruptorTest.java | 87 +-
.../internal/raft/server/impl/RaftServerImpl.java | 235 +-
.../java/org/apache/ignite/rest/ErrorResult.java | 2 +-
.../java/org/apache/ignite/rest/RestModule.java | 170 +-
.../apache/ignite/rest/netty/RestApiHandler.java | 46 +-
.../ignite/rest/netty/RestApiHttpRequest.java | 6 +-
.../ignite/rest/netty/RestApiHttpResponse.java | 22 +-
.../ignite/rest/netty/RestApiInitializer.java | 3 +-
.../org/apache/ignite/rest/netty/package-info.java | 1 +
.../java/org/apache/ignite/rest/package-info.java | 1 +
.../presentation/ConfigurationPresentation.java | 6 +-
.../rest/presentation/hocon/HoconPresentation.java | 42 +-
.../rest/presentation/hocon/package-info.java | 1 +
.../ignite/rest/presentation/package-info.java | 1 +
.../java/org/apache/ignite/rest/routes/Route.java | 50 +-
.../java/org/apache/ignite/rest/routes/Router.java | 30 +-
.../apache/ignite/rest/routes/package-info.java | 1 +
.../ignite/rest/netty/RestApiHttpResponseTest.java | 20 +-
.../ConfigurationPresentationTest.java | 133 +-
.../org/apache/ignite/rest/routes/RouteTest.java | 32 +-
.../ignite/internal/rocksdb/ColumnFamily.java | 29 +-
.../apache/ignite/internal/rocksdb/RocksUtils.java | 38 +-
.../ignite/internal/{ITUtils.java => ItUtils.java} | 4 +-
.../calcite/AbstractBasicIntegrationTest.java | 237 +-
.../internal/calcite/ITOrToUnionRuleTest.java | 231 --
.../calcite/ITProjectScanMergeRuleTest.java | 157 -
.../internal/calcite/ITSecondaryIndexTest.java | 831 -----
...ITAggregatesTest.java => ItAggregatesTest.java} | 167 +-
.../{ITDataTypesTest.java => ItDataTypesTest.java} | 49 +-
.../{ITFunctionsTest.java => ItFunctionsTest.java} | 236 +-
...ITIndexSpoolTest.java => ItIndexSpoolTest.java} | 74 +-
.../{ITMetadataTest.java => ItMetadataTest.java} | 98 +-
...xedQueriesTest.java => ItMixedQueriesTest.java} | 331 +-
.../internal/calcite/ItOrToUnionRuleTest.java | 238 ++
.../calcite/ItProjectScanMergeRuleTest.java | 161 +
.../internal/calcite/ItSecondaryIndexTest.java | 929 ++++++
.../calcite/{ITSetOpTest.java => ItSetOpTest.java} | 184 +-
...AggregateTest.java => ItSortAggregateTest.java} | 85 +-
.../ignite/internal/calcite/util/Commons.java | 2 +-
.../ignite/internal/calcite/util/QueryChecker.java | 386 ++-
... ItDistributedConfigurationPropertiesTest.java} | 277 +-
... => ItDistributedConfigurationStorageTest.java} | 162 +-
.../runner/app/AbstractSchemaChangeTest.java | 367 +--
.../runner/app/ITDynamicTableCreationTest.java | 256 --
.../ignite/internal/runner/app/ITIgnitionTest.java | 213 --
.../runner/app/ITSchemaChangeKVViewTest.java | 306 --
.../runner/app/ITSchemaChangeTableViewTest.java | 332 --
.../internal/runner/app/ITTableCreationTest.java | 264 --
...ChangesTest.java => ItBaselineChangesTest.java} | 83 +-
.../runner/app/ItDynamicTableCreationTest.java | 398 +++
...startTest.java => ItIgniteNodeRestartTest.java} | 97 +-
.../ignite/internal/runner/app/ItIgnitionTest.java | 217 ++
...Test.java => ItLiveSchemaChangeKvViewTest.java} | 147 +-
...eTest.java => ItLiveSchemaChangeTableTest.java} | 254 +-
.../internal/runner/app/ItNoThreadsLeftTest.java | 135 +
.../runner/app/ItSchemaChangeKvViewTest.java | 281 ++
.../runner/app/ItSchemaChangeTableViewTest.java | 305 ++
.../internal/runner/app/ItTableCreationTest.java | 274 ++
.../{ITTablesApiTest.java => ItTablesApiTest.java} | 170 +-
...onTest.java => ItThinClientConnectionTest.java} | 85 +-
.../runner/app/PlatformTestNodeRunner.java | 50 +-
.../runner/app/jdbc/AbstractJdbcSelfTest.java | 9 +-
...st.java => ItJdbcConnectionPropertiesTest.java} | 8 +-
...SelfTest.java => ItJdbcConnectionSelfTest.java} | 382 ++-
...taSelfTest.java => ItJdbcMetadataSelfTest.java} | 84 +-
...tSelfTest.java => ItJdbcResultSetSelfTest.java} | 174 +-
...tSelfTest.java => ItJdbcStatementSelfTest.java} | 150 +-
.../org/apache/ignite/app/IgniteCliRunner.java | 55 +-
.../org/apache/ignite/internal/app/IgniteImpl.java | 547 ++--
.../apache/ignite/internal/app/IgnitionImpl.java | 93 +-
.../storage/DistributedConfigurationStorage.java | 223 +-
.../storage/LocalConfigurationStorage.java | 38 +-
.../org/apache/ignite/utils/IgniteProperties.java | 17 +-
.../storage/ConfigurationStorageTest.java | 18 +-
.../DistributedConfigurationStorageTest.java | 107 +-
.../storage/LocalConfigurationStorageTest.java | 15 +-
.../ignite/internal/schema/AssemblyException.java | 6 +-
.../apache/ignite/internal/schema/BinaryRow.java | 17 +-
.../ignite/internal/schema/BitmaskNativeType.java | 34 +-
.../ignite/internal/schema/ByteBufferRow.java | 54 +-
.../org/apache/ignite/internal/schema/Column.java | 104 +-
.../org/apache/ignite/internal/schema/Columns.java | 102 +-
.../ignite/internal/schema/DecimalNativeType.java | 25 +-
.../apache/ignite/internal/schema/NativeType.java | 59 +-
.../ignite/internal/schema/NativeTypeSpec.java | 125 +-
.../apache/ignite/internal/schema/NativeTypes.java | 242 +-
.../ignite/internal/schema/NumberNativeType.java | 35 +-
.../ignite/internal/schema/SchemaDescriptor.java | 29 +-
.../ignite/internal/schema/SchemaException.java | 2 +-
.../schema/SchemaModificationException.java | 2 +-
.../ignite/internal/schema/SchemaRegistry.java | 29 +-
.../apache/ignite/internal/schema/SchemaUtils.java | 106 +-
.../ignite/internal/schema/TemporalNativeType.java | 15 +-
.../ignite/internal/schema/VarlenNativeType.java | 10 +-
.../configuration/ColumnTypeValidatorImpl.java | 64 +
.../SchemaConfigurationConverter.java | 120 +-
.../configuration/SchemaDescriptorConverter.java | 116 +-
.../schema/configuration/TableValidatorImpl.java | 84 +-
.../schema/definition/AbstractSchemaObject.java | 10 +-
.../schema/definition/ColumnDefinitionImpl.java | 21 +-
.../schema/definition/TableDefinitionImpl.java | 39 +-
.../definition/builder/AbstractIndexBuilder.java | 5 +-
.../builder/ColumnDefinitionBuilderImpl.java | 16 +-
.../builder/HashIndexDefinitionBuilderImpl.java | 9 +-
.../builder/PartialIndexDefinitionBuilderImpl.java | 34 +-
.../builder/PrimaryKeyDefinitionBuilderImpl.java | 22 +-
.../builder/SortedIndexDefinitionBuilderImpl.java | 39 +-
...erImpl.java => TableDefinitionBuilderImpl.java} | 105 +-
.../definition/index/HashIndexDefinitionImpl.java | 12 +-
.../index/IndexColumnDefinitionImpl.java | 3 +-
.../index/PartialIndexDefinitionImpl.java | 20 +-
.../definition/index/PrimaryKeyDefinitionImpl.java | 17 +-
.../index/SortedIndexColumnDefinitionImpl.java | 11 +-
.../index/SortedIndexDefinitionImpl.java | 20 +-
.../internal/schema/mapping/ColumnMapper.java | 6 +-
.../internal/schema/mapping/ColumnMapperImpl.java | 19 +-
.../internal/schema/mapping/ColumnMapping.java | 23 +-
.../schema/marshaller/AbstractSerializer.java | 71 +-
.../internal/schema/marshaller/BinaryMode.java | 2 +-
.../internal/schema/marshaller/MarshallerUtil.java | 67 +-
.../schema/marshaller/SerializationException.java | 2 +-
.../internal/schema/marshaller/Serializer.java | 24 +-
.../schema/marshaller/SerializerFactory.java | 8 +-
.../marshaller/asm/AsmSerializerGenerator.java | 414 ++-
.../marshaller/asm/ColumnAccessCodeGenerator.java | 20 +-
.../asm/IdentityMarshallerCodeGenerator.java | 35 +-
.../marshaller/asm/MarshallerCodeGenerator.java | 18 +-
.../asm/ObjectMarshallerCodeGenerator.java | 131 +-
.../marshaller/reflection/FieldAccessor.java | 168 +-
.../marshaller/reflection/JavaSerializer.java | 132 +-
.../reflection/JavaSerializerFactory.java | 3 +-
.../schema/marshaller/reflection/Marshaller.java | 82 +-
.../schema/AbstractSchemaSerializer.java | 7 +-
.../schema/marshaller/schema/SchemaSerializer.java | 2 +-
.../marshaller/schema/SchemaSerializerImpl.java | 179 +-
.../modification/AlterColumnBuilderImpl.java | 18 +-
.../modification/TableModificationBuilderImpl.java | 36 +-
.../ignite/internal/schema/package-info.java | 6 +-
.../SchemaRegistrationConflictException.java | 3 +-
.../schema/registry/SchemaRegistryException.java | 2 +-
.../schema/registry/SchemaRegistryImpl.java | 59 +-
.../schema/registry/UpgradingRowAdapter.java | 189 +-
.../internal/schema/registry/package-info.java | 1 +
.../internal/schema/row/ExpandableByteBuf.java | 64 +-
.../org/apache/ignite/internal/schema/row/Row.java | 253 +-
.../ignite/internal/schema/row/RowAssembler.java | 749 ++---
.../internal/schema/row/TemporalTypesHelper.java | 87 +-
.../ignite/internal/schema/row/VarTableFormat.java | 198 +-
.../apache/ignite/internal/util/ObjectFactory.java | 17 +-
.../java/org/apache/ignite/internal/util/Pair.java | 2 +-
.../org/apache/ignite/schema/SchemaBuilders.java | 14 +-
.../org/apache/ignite/schema/package-info.java | 1 +
.../benchmarks/SerializerBenchmarkTest.java | 130 +-
.../internal/schema/ColumnDefinitionTest.java | 18 +-
.../apache/ignite/internal/schema/ColumnsTest.java | 299 +-
.../internal/schema/ExpandableByteBufTest.java | 26 +-
.../ignite/internal/schema/NativeTypeTest.java | 54 +-
.../schema/RowAssemblerAdvancedSchemaTest.java | 399 +--
.../schema/RowAssemblerSimpleSchemaTest.java | 637 ++--
.../org/apache/ignite/internal/schema/RowTest.java | 419 +--
.../internal/schema/SchemaConfigurationTest.java | 144 +-
.../internal/schema/SchemaDescriptorTest.java | 43 +-
.../ignite/internal/schema/TemporalTypesTest.java | 12 +-
.../apache/ignite/internal/schema/TestUtils.java | 24 +-
.../builder/ColumnDefinitionBuilderTest.java | 6 +-
.../builder/HashIndexDefinitionBuilderTest.java | 10 +-
.../builder/PartialIndexDefinitionBuilderTest.java | 4 +-
.../PrimaryKeyDefinitionDefinitionBuilderTest.java | 14 +-
.../builder/SortedIndexDefinitionBuilderTest.java | 6 +-
.../schema/builder/TableDefinitionBuilderTest.java | 20 +-
.../SchemaConfigurationConverterTest.java | 163 +-
.../SchemaDescriptorConverterTest.java | 165 +-
.../configuration/TableValidatorImplTest.java | 52 +-
.../schema/marshaller/JavaSerializerTest.java | 683 +++--
.../marshaller/reflection/FieldAccessorTest.java | 223 +-
.../schema/registry/SchemaRegistryImplTest.java | 240 +-
.../schema/registry/UpgradingRowAdapterTest.java | 192 +-
.../schema/serializer/AbstractSerializerTest.java | 100 +-
modules/sql/pom.xml | 76 +-
modules/sql/src/test/java/IgniteSqlTest.java | 412 +--
modules/sql/src/test/java/TestRow.java | 346 ++-
.../ignite/internal/storage/InvokeClosure.java | 10 +-
.../ignite/internal/storage/PartitionStorage.java | 9 +-
.../ignite/internal/storage/StorageException.java | 2 +-
.../storage/basic/DeleteExactInvokeClosure.java | 12 +-
.../storage/basic/GetAndRemoveInvokeClosure.java | 12 +-
.../storage/basic/GetAndReplaceInvokeClosure.java | 14 +-
.../storage/basic/InsertInvokeClosure.java | 12 +-
.../storage/basic/ReplaceExactInvokeClosure.java | 14 +-
.../internal/storage/basic/SimpleDataRow.java | 28 +-
.../storage/basic/SimpleReadInvokeClosure.java | 9 +-
.../storage/basic/SimpleRemoveInvokeClosure.java | 9 +-
.../storage/basic/SimpleWriteInvokeClosure.java | 9 +-
.../internal/storage/engine/StorageEngine.java | 14 +-
.../storage/AbstractPartitionStorageTest.java | 508 ++--
.../basic/ConcurrentHashMapPartitionStorage.java | 112 +-
.../storage/rocksdb/RocksDbDataRegion.java | 14 +-
.../storage/rocksdb/RocksDbPartitionStorage.java | 390 +--
.../storage/rocksdb/RocksDbStorageEngine.java | 22 +-
.../storage/rocksdb/RocksDbTableStorage.java | 177 +-
.../storage/rocksdb/RocksDbStorageTest.java | 36 +-
...dTableTest.java => ItDistributedTableTest.java} | 234 +-
...eScanTest.java => ItInternalTableScanTest.java} | 267 +-
...stenceTest.java => ItTablePersistenceTest.java} | 107 +-
.../org/apache/ignite/binary/BinaryObjects.java | 4 +-
.../org/apache/ignite/binary/package-info.java | 1 +
.../schema/ExtendedTableConfigurationSchema.java | 4 +-
.../{KVSerializer.java => KvMarshaller.java} | 30 +-
.../schema/marshaller/TupleMarshaller.java | 24 +-
.../marshaller/TupleMarshallerException.java} | 22 +-
.../marshaller}/TupleMarshallerImpl.java | 381 +--
.../internal/table/AbstractRowTupleAdapter.java | 141 +-
.../ignite/internal/table/AbstractTableView.java | 43 +-
.../internal/table/IgniteTablesInternal.java | 7 +-
.../ignite/internal/table/InternalTable.java | 68 +-
.../internal/table/KeyValueBinaryViewImpl.java | 376 ++-
.../ignite/internal/table/KeyValueViewImpl.java | 403 ++-
.../internal/table/MutableRowTupleAdapter.java | 154 +-
.../internal/table/RecordBinaryViewImpl.java | 395 +--
.../ignite/internal/table/RecordViewImpl.java | 139 +-
.../apache/ignite/internal/table/TableImpl.java | 20 +-
.../org/apache/ignite/internal/table/TableRow.java | 40 +-
.../internal/table/distributed/TableManager.java | 1585 ++++++----
.../table/distributed/command/CommandUtils.java | 31 +-
.../distributed/command/DeleteAllCommand.java | 4 +-
.../table/distributed/command/DeleteCommand.java | 6 +-
.../distributed/command/DeleteExactAllCommand.java | 4 +-
.../distributed/command/DeleteExactCommand.java | 6 +-
.../table/distributed/command/GetAllCommand.java | 3 +-
.../distributed/command/GetAndDeleteCommand.java | 7 +-
.../distributed/command/GetAndReplaceCommand.java | 7 +-
.../distributed/command/GetAndUpsertCommand.java | 6 +-
.../table/distributed/command/GetCommand.java | 6 +-
.../distributed/command/InsertAllCommand.java | 3 +-
.../table/distributed/command/InsertCommand.java | 6 +-
.../table/distributed/command/ReplaceCommand.java | 11 +-
.../distributed/command/ReplaceIfExistCommand.java | 9 +-
.../distributed/command/UpsertAllCommand.java | 3 +-
.../table/distributed/command/UpsertCommand.java | 6 +-
.../command/response/MultiRowsResponse.java | 1 +
.../command/response/SingleRowResponse.java | 7 +-
.../distributed/command/scan/ScanCloseCommand.java | 3 +-
.../distributed/command/scan/ScanInitCommand.java | 15 +-
.../command/scan/ScanRetrieveBatchCommand.java | 16 +-
.../table/distributed/raft/PartitionListener.java | 141 +-
.../distributed/storage/InternalTableImpl.java | 257 +-
.../internal/table/event/TableEventParameters.java | 6 +-
.../apache/ignite/internal/table/package-info.java | 1 +
.../TupleMarshallerFixlenOnlyBenchmark.java | 36 +-
.../TupleMarshallerVarlenOnlyBenchmark.java | 52 +-
.../org/apache/ignite/internal/table/Example.java | 114 +-
.../table/KeyValueBinaryViewOperationsTest.java | 272 +-
.../internal/table/KeyValueOperationsTest.java | 302 ++
.../internal/table/MutableRowTupleAdapterTest.java | 555 ++--
.../table/RecordBinaryViewOperationsTest.java | 326 +-
.../internal/table/StrictSchemaOperationsTest.java | 151 +-
.../ignite/internal/table/TableManagerTest.java | 402 ++-
.../org/apache/ignite/internal/table/TxTest.java | 78 +-
.../raft/PartitionCommandListenerTest.java | 105 +-
.../table/impl/DummyInternalTableImpl.java | 135 +-
.../table/impl/DummySchemaManagerImpl.java | 12 +-
.../internal/table/impl/TestTupleBuilder.java | 127 +-
.../table/type/NumericTypesSerializerTest.java | 277 +-
.../org/apache/ignite/table/TupleImplTest.java | 142 +-
.../org/apache/ignite/internal/tx/LockManager.java | 13 +-
.../org/apache/ignite/internal/tx/Timestamp.java | 34 +-
.../ignite/internal/tx/impl/HeapLockManager.java | 91 +-
.../internal/tx/AbstractLockManagerTest.java | 118 +-
.../ignite/internal/tx/HeapLockManagerTest.java | 7 +-
...> ItPersistencePropertiesVaultServiceTest.java} | 36 +-
...Test.java => ItPersistentVaultServiceTest.java} | 9 +-
.../apache/ignite/internal/vault/VaultEntry.java | 14 +-
.../apache/ignite/internal/vault/VaultManager.java | 32 +-
.../apache/ignite/internal/vault/VaultService.java | 13 +-
.../vault/inmemory/InMemoryVaultService.java | 56 +-
.../vault/persistence/PersistentVaultService.java | 77 +-
.../vault/persistence/RocksIteratorAdapter.java | 25 +-
.../ignite/internal/vault/VaultManagerTest.java | 26 +-
.../ignite/internal/vault/VaultServiceTest.java | 43 +-
.../vault/inmemory/InMemoryVaultServiceTest.java | 3 +-
parent/pom.xml | 17 +-
1270 files changed, 69036 insertions(+), 51076 deletions(-)
copy deliveries/{rpm => deb}/build.sh (59%)
create mode 100644 deliveries/deb/changelog
create mode 100644 deliveries/deb/control
create mode 100644 deliveries/deb/copyright
create mode 100644 deliveries/deb/rules
create mode 100644 docs/_docs/binary-protocol.adoc
copy docs/_docs/{includes/ignite-cli-download-windows.adoc => persistence.adoc} (51%)
create mode 100644 docs/_docs/rebalance.adoc
create mode 100644 docs/_docs/sql/calcite-based-sql-engine.adoc
create mode 100644 docs/_docs/sql/jdbc-driver.adoc
create mode 100644 idea/intellij-java-google-style.xml
copy modules/api/src/main/java/org/apache/ignite/configuration/schemas/table/{TableValidator.java => ColumnTypeValidator.java} (87%)
rename modules/api/src/main/java/org/apache/ignite/schema/definition/builder/{TableSchemaBuilder.java => TableDefinitionBuilder.java} (71%)
rename modules/api/src/main/java/org/apache/ignite/table/mapper/{ValueMapper.java => Mapper.java} (71%)
delete mode 100644 modules/api/src/main/java/org/apache/ignite/table/mapper/RecordMapper.java
copy modules/{api/src/main/java/org/apache/ignite/query/sql/ColumnMetadata.java => calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/ResultFieldMetadata.java} (50%)
copy modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/{Stubs.java => ResultSetMetadata.java} (82%)
create mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/ResultFieldMetadataImpl.java
create mode 100644 modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/ResultSetMetadataImpl.java
copy modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/{FieldsMetadata.java => ResultSetMetadataInternal.java} (81%)
rename modules/cli/src/integrationTest/java/org/apache/ignite/cli/{ITConfigCommandTest.java => ItConfigCommandTest.java} (79%)
rename modules/cli/src/main/java/org/apache/ignite/cli/{IgniteCLIException.java => IgniteCliException.java} (85%)
rename modules/client-handler/src/integrationTest/java/org/apache/ignite/client/handler/{ITClientHandlerTest.java => ItClientHandlerTest.java} (85%)
delete mode 100644 modules/configuration-annotation-processor/src/integrationTest/java/org/apache/ignite/internal/configuration/processor/ITProcessorTest.java
create mode 100644 modules/configuration-annotation-processor/src/integrationTest/java/org/apache/ignite/internal/configuration/processor/ItProcessorTest.java
copy modules/configuration-annotation-processor/src/integrationTest/resources/org/apache/ignite/internal/configuration/processor/{internal/ErrorInternal2ConfigurationSchema.java => polymorphic/ErrorPolymorphic0ConfigurationSchema.java} (71%)
copy modules/{configuration/src/test/java/org/apache/ignite/internal/configuration/testframework/BasicConfigurationSchema.java => configuration-annotation-processor/src/integrationTest/resources/org/apache/ignite/internal/configuration/processor/polymorphic/ErrorPolymorphic1ConfigurationSchema.java} (73%)
copy modules/configuration-annotation-processor/src/integrationTest/resources/org/apache/ignite/internal/configuration/processor/{internal/ErrorInternal2ConfigurationSchema.java => polymorphic/ErrorPolymorphic2ConfigurationSchema.java} (73%)
copy modules/{calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/MessageListener.java => configuration-annotation-processor/src/integrationTest/resources/org/apache/ignite/internal/configuration/processor/polymorphic/ErrorPolymorphic3ConfigurationSchema.java} (66%)
copy modules/{calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/QueryPlan.java => configuration-annotation-processor/src/integrationTest/resources/org/apache/ignite/internal/configuration/processor/polymorphic/ErrorPolymorphic4ConfigurationSchema.java} (71%)
copy modules/{configuration/src/test/java/org/apache/ignite/internal/configuration/testframework/BasicConfigurationSchema.java => configuration-annotation-processor/src/integrationTest/resources/org/apache/ignite/internal/configuration/processor/polymorphic/ErrorPolymorphic5ConfigurationSchema.java} (69%)
copy modules/{calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/SqlCursor.java => configuration-annotation-processor/src/integrationTest/resources/org/apache/ignite/internal/configuration/processor/polymorphic/ErrorPolymorphic6ConfigurationSchema.java} (63%)
copy modules/{api/src/main/java/org/apache/ignite/schema/definition/index/SortedIndexDefinition.java => configuration-annotation-processor/src/integrationTest/resources/org/apache/ignite/internal/configuration/processor/polymorphic/ErrorPolymorphic7ConfigurationSchema.java} (59%)
copy modules/{api/src/main/java/org/apache/ignite/configuration/schemas/table/ColumnTypeConfigurationSchema.java => configuration-annotation-processor/src/integrationTest/resources/org/apache/ignite/internal/configuration/processor/polymorphic/ErrorPolymorphic8ConfigurationSchema.java} (62%)
copy modules/configuration-annotation-processor/src/integrationTest/resources/org/apache/ignite/internal/configuration/processor/{internal/ErrorInternal2ConfigurationSchema.java => polymorphic/ErrorPolymorphicInstance0ConfigurationSchema.java} (70%)
copy modules/{configuration/src/test/java/org/apache/ignite/internal/configuration/testframework/BasicConfigurationSchema.java => configuration-annotation-processor/src/integrationTest/resources/org/apache/ignite/internal/configuration/processor/polymorphic/ErrorPolymorphicInstance1ConfigurationSchema.java} (73%)
copy modules/configuration-annotation-processor/src/integrationTest/resources/org/apache/ignite/internal/configuration/processor/{internal/ErrorInternal2ConfigurationSchema.java => polymorphic/ErrorPolymorphicInstance2ConfigurationSchema.java} (73%)
copy modules/{calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/QueryPlan.java => configuration-annotation-processor/src/integrationTest/resources/org/apache/ignite/internal/configuration/processor/polymorphic/ErrorPolymorphicInstance3ConfigurationSchema.java} (71%)
copy modules/{runner/src/integrationTest/java/org/apache/ignite/internal/ITUtils.java => configuration-annotation-processor/src/integrationTest/resources/org/apache/ignite/internal/configuration/processor/polymorphic/ErrorPolymorphicInstance4ConfigurationSchema.java} (65%)
copy modules/{api/src/main/java/org/apache/ignite/configuration/schemas/table/ColumnConfigurationSchema.java => configuration-annotation-processor/src/integrationTest/resources/org/apache/ignite/internal/configuration/processor/polymorphic/ErrorPolymorphicInstance5ConfigurationSchema.java} (59%)
copy modules/{calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/SqlCursor.java => configuration-annotation-processor/src/integrationTest/resources/org/apache/ignite/internal/configuration/processor/polymorphic/ErrorPolymorphicInstance6ConfigurationSchema.java} (60%)
copy modules/{api/src/main/java/org/apache/ignite/configuration/schemas/table/ColumnConfigurationSchema.java => configuration-annotation-processor/src/integrationTest/resources/org/apache/ignite/internal/configuration/processor/polymorphic/SimpleConfigurationSchema.java} (70%)
copy modules/{configuration/src/test/java/org/apache/ignite/internal/configuration/testframework/BasicConfigurationSchema.java => configuration-annotation-processor/src/integrationTest/resources/org/apache/ignite/internal/configuration/processor/polymorphic/SimplePolymorphicConfigurationSchema.java} (65%)
copy modules/{configuration/src/test/java/org/apache/ignite/internal/configuration/testframework/BasicConfigurationSchema.java => configuration-annotation-processor/src/integrationTest/resources/org/apache/ignite/internal/configuration/processor/polymorphic/SimplePolymorphicInstanceConfigurationSchema.java} (65%)
copy modules/{api/src/main/java/org/apache/ignite/configuration/schemas/table/ColumnConfigurationSchema.java => configuration-annotation-processor/src/integrationTest/resources/org/apache/ignite/internal/configuration/processor/polymorphic/SimpleRootConfigurationSchema.java} (66%)
copy modules/{schema/src/test/java/org/apache/ignite/internal/schema/builder/PartialIndexDefinitionBuilderTest.java => configuration-annotation-processor/src/test/java/org/apache/ignite/internal/configuration/processor/UtilsTest.java} (53%)
copy modules/configuration-api/src/main/java/org/apache/ignite/configuration/{ConfigurationChangeException.java => ConfigurationReadOnlyException.java} (71%)
copy modules/configuration-api/src/main/java/org/apache/ignite/configuration/{ConfigurationChangeException.java => ConfigurationWrongPolymorphicTypeIdException.java} (71%)
copy modules/configuration-api/src/main/java/org/apache/ignite/configuration/{package-info.java => PolymorphicChange.java} (68%)
copy modules/configuration-api/src/main/java/org/apache/ignite/configuration/annotation/{ConfigurationRoot.java => PolymorphicConfig.java} (69%)
copy modules/configuration-api/src/main/java/org/apache/ignite/configuration/annotation/{ConfigurationRoot.java => PolymorphicConfigInstance.java} (67%)
copy modules/configuration-api/src/main/java/org/apache/ignite/configuration/annotation/{ConfigValue.java => PolymorphicId.java} (65%)
create mode 100644 modules/configuration/src/main/java/org/apache/ignite/internal/configuration/ConfigurationTreeWrapper.java
create mode 100644 modules/configuration/src/main/java/org/apache/ignite/internal/configuration/DirectConfigurationTreeWrapper.java
copy modules/configuration/src/main/java/org/apache/ignite/internal/configuration/util/{KeyNotFoundException.java => WrongPolymorphicTypeIdException.java} (70%)
rename modules/core/src/main/java/org/apache/ignite/internal/tostring/{SBLimitedLength.java => StringBuilderLimitedLength.java} (71%)
create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/util/IgniteSpinReadWriteLockTest.java
rename modules/metastorage-client/src/integrationTest/java/org/apache/ignite/internal/metastorage/client/{ITMetaStorageServicePersistenceTest.java => ItMetaStorageServicePersistenceTest.java} (72%)
rename modules/metastorage-client/src/integrationTest/java/org/apache/ignite/internal/metastorage/client/{ITMetaStorageServiceTest.java => ItMetaStorageServiceTest.java} (76%)
rename modules/metastorage-server/src/main/java/org/apache/ignite/internal/metastorage/server/persistence/{RocksDBKeyValueStorage.java => RocksDbKeyValueStorage.java} (73%)
rename modules/network-annotation-processor/src/integrationTest/java/org/apache/ignite/internal/network/processor/{ITTransferableObjectProcessorTest.java => ItTransferableObjectProcessorTest.java} (83%)
create mode 100644 modules/network/docs/network-flow.png
create mode 100644 modules/network/docs/network-flow.puml
create mode 100644 modules/network/docs/threading-2.png
create mode 100644 modules/network/docs/threading-2.puml
create mode 100644 modules/network/docs/threading.png
create mode 100644 modules/network/docs/threading.puml
rename modules/network/src/integrationTest/java/org/apache/ignite/internal/network/netty/{ITConnectionManagerTest.java => ItConnectionManagerTest.java} (94%)
rename modules/network/src/integrationTest/java/org/apache/ignite/internal/network/recovery/{ITRecoveryHandshakeTest.java => ItRecoveryHandshakeTest.java} (78%)
rename modules/network/src/integrationTest/java/org/apache/ignite/network/scalecube/{ITNodeRestartsTest.java => ItNodeRestartsTest.java} (86%)
rename modules/network/src/integrationTest/java/org/apache/ignite/network/scalecube/{ITScaleCubeNetworkMessagingTest.java => ItScaleCubeNetworkMessagingTest.java} (80%)
create mode 100644 modules/network/src/main/java/org/apache/ignite/internal/network/netty/NamedNioEventLoopGroup.java
copy modules/{network-annotation-processor/src/integrationTest/resources/org/apache/ignite/internal/network/processor/InheritedMessageClash.java => network/src/test/java/org/apache/ignite/internal/network/processor/NetworkMessage1.java} (82%)
rename modules/{api/src/main/java/org/apache/ignite/table/mapper/KeyMapper.java => network/src/test/java/org/apache/ignite/internal/network/processor/NetworkMessage2.java} (81%)
rename modules/raft/src/integrationTest/java/org/apache/ignite/internal/raft/{ITLozaTest.java => ItLozaTest.java} (71%)
rename modules/raft/src/integrationTest/java/org/apache/ignite/raft/client/service/{ITAbstractListenerSnapshotTest.java => ItAbstractListenerSnapshotTest.java} (80%)
rename modules/raft/src/integrationTest/java/org/apache/ignite/raft/jraft/core/{ITCliServiceTest.java => ItCliServiceTest.java} (99%)
rename modules/raft/src/integrationTest/java/org/apache/ignite/raft/jraft/core/{ITNodeTest.java => ItNodeTest.java} (99%)
rename modules/raft/src/integrationTest/java/org/apache/ignite/raft/server/{ITJRaftCounterServerTest.java => ItJraftCounterServerTest.java} (83%)
rename modules/raft/src/integrationTest/java/org/apache/ignite/raft/server/{ITSimpleCounterServerTest.java => ItSimpleCounterServerTest.java} (81%)
rename modules/raft/src/main/java/org/apache/ignite/internal/raft/server/impl/{JRaftServerImpl.java => JraftServerImpl.java} (71%)
rename modules/runner/src/integrationTest/java/org/apache/ignite/internal/{ITUtils.java => ItUtils.java} (96%)
delete mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/calcite/ITOrToUnionRuleTest.java
delete mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/calcite/ITProjectScanMergeRuleTest.java
delete mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/calcite/ITSecondaryIndexTest.java
rename modules/runner/src/integrationTest/java/org/apache/ignite/internal/calcite/{ITAggregatesTest.java => ItAggregatesTest.java} (70%)
rename modules/runner/src/integrationTest/java/org/apache/ignite/internal/calcite/{ITDataTypesTest.java => ItDataTypesTest.java} (80%)
rename modules/runner/src/integrationTest/java/org/apache/ignite/internal/calcite/{ITFunctionsTest.java => ItFunctionsTest.java} (60%)
rename modules/runner/src/integrationTest/java/org/apache/ignite/internal/calcite/{ITIndexSpoolTest.java => ItIndexSpoolTest.java} (69%)
rename modules/runner/src/integrationTest/java/org/apache/ignite/internal/calcite/{ITMetadataTest.java => ItMetadataTest.java} (67%)
rename modules/runner/src/integrationTest/java/org/apache/ignite/internal/calcite/{ITMixedQueriesTest.java => ItMixedQueriesTest.java} (61%)
create mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/calcite/ItOrToUnionRuleTest.java
create mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/calcite/ItProjectScanMergeRuleTest.java
create mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/calcite/ItSecondaryIndexTest.java
rename modules/runner/src/integrationTest/java/org/apache/ignite/internal/calcite/{ITSetOpTest.java => ItSetOpTest.java} (69%)
rename modules/runner/src/integrationTest/java/org/apache/ignite/internal/calcite/{ITSortAggregateTest.java => ItSortAggregateTest.java} (52%)
rename modules/runner/src/integrationTest/java/org/apache/ignite/internal/configuration/{ITDistributedConfigurationPropertiesTest.java => ItDistributedConfigurationPropertiesTest.java} (74%)
rename modules/runner/src/integrationTest/java/org/apache/ignite/internal/configuration/storage/{ITDistributedConfigurationStorageTest.java => ItDistributedConfigurationStorageTest.java} (77%)
delete mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/ITDynamicTableCreationTest.java
delete mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/ITIgnitionTest.java
delete mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/ITSchemaChangeKVViewTest.java
delete mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/ITSchemaChangeTableViewTest.java
delete mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/ITTableCreationTest.java
rename modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/{ITBaselineChangesTest.java => ItBaselineChangesTest.java} (74%)
create mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/ItDynamicTableCreationTest.java
rename modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/{ITIgniteNodeRestartTest.java => ItIgniteNodeRestartTest.java} (65%)
create mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/ItIgnitionTest.java
rename modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/{ITLiveSchemaChangeKVViewTest.java => ItLiveSchemaChangeKvViewTest.java} (81%)
rename modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/{ITLiveSchemaChangeTableTest.java => ItLiveSchemaChangeTableTest.java} (74%)
create mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/ItNoThreadsLeftTest.java
create mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/ItSchemaChangeKvViewTest.java
create mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/ItSchemaChangeTableViewTest.java
create mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/ItTableCreationTest.java
rename modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/{ITTablesApiTest.java => ItTablesApiTest.java} (68%)
rename modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/{ITThinClientConnectionTest.java => ItThinClientConnectionTest.java} (77%)
rename modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/jdbc/{ITJdbcConnectionPropertiesTest.java => ItJdbcConnectionPropertiesTest.java} (97%)
rename modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/jdbc/{ITJdbcConnectionSelfTest.java => ItJdbcConnectionSelfTest.java} (76%)
rename modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/jdbc/{ITJdbcMetadataSelfTest.java => ItJdbcMetadataSelfTest.java} (90%)
rename modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/jdbc/{ITJdbcResultSetSelfTest.java => ItJdbcResultSetSelfTest.java} (87%)
rename modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/jdbc/{ITJdbcStatementSelfTest.java => ItJdbcStatementSelfTest.java} (88%)
create mode 100644 modules/schema/src/main/java/org/apache/ignite/internal/schema/configuration/ColumnTypeValidatorImpl.java
rename modules/schema/src/main/java/org/apache/ignite/internal/schema/definition/builder/{TableSchemaBuilderImpl.java => TableDefinitionBuilderImpl.java} (74%)
rename modules/table/src/integrationTest/java/org/apache/ignite/distributed/{ITDistributedTableTest.java => ItDistributedTableTest.java} (77%)
rename modules/table/src/integrationTest/java/org/apache/ignite/distributed/{ITInternalTableScanTest.java => ItInternalTableScanTest.java} (74%)
rename modules/table/src/integrationTest/java/org/apache/ignite/distributed/{ITTablePersistenceTest.java => ItTablePersistenceTest.java} (68%)
rename modules/table/src/main/java/org/apache/ignite/internal/schema/marshaller/{KVSerializer.java => KvMarshaller.java} (59%)
copy modules/{schema/src/main/java/org/apache/ignite/internal/schema/marshaller/SerializationException.java => table/src/main/java/org/apache/ignite/internal/schema/marshaller/TupleMarshallerException.java} (70%)
rename modules/table/src/main/java/org/apache/ignite/internal/{table => schema/marshaller}/TupleMarshallerImpl.java (60%)
create mode 100644 modules/table/src/test/java/org/apache/ignite/internal/table/KeyValueOperationsTest.java
rename modules/vault/src/integrationTest/java/org/apache/ignite/internal/vault/persistence/{ITPersistencePropertiesVaultServiceTest.java => ItPersistencePropertiesVaultServiceTest.java} (82%)
rename modules/vault/src/integrationTest/java/org/apache/ignite/internal/vault/persistence/{ITPersistentVaultServiceTest.java => ItPersistentVaultServiceTest.java} (90%)